spring webSocket+rabbitmq集成

git项目地址

##windows下安装rabbitmq

1. 添加了rabbitmq的windows安装包,window下安装rabbitmq,须要先下载erlang,本项目提供了64位的19.3安装包,须要添加环境变量 配置环境变量 ERLANG_HOME C:\Program Files (x86)\erl5.9 ,添加到PATH %ERLANG_HOME%\bin. 安装包在resources/install里.

• 2 接着下载rabbitmq的安装包,安装以后,添加rabbitmq的环境变量,rabbitmq_home和path,如%RABBITMQ_SERVER%\sbin; 安装包在resources/install里,版本3.6.9.

• 3 接着启动rabbitmq,以管理员的身份运行cmd,进入到 %RABBITMQ_SERVER%\sbin目录下;接着运行rabbitmq-plugins.bat,具体命令为:rabbitmq-plugins.bat enable rabbitmq_management ;无误后,接着启动 rabbitmq-service.bat .

命令以下:启动:rabbitmq-service.bat start;关闭:rabbitmq-service.bat stop 从新添加:rabbitmq-service.bat install

windows安装完成以后会自动注册为服务,开机自启,无需手动启动,以下图:

• 4 启用STOMP插件服务

rabbitmq-plugins enable rabbitmq_stomp

• 5 查看rabbitmq的服务状态,http://localhost:15672;用户名/密码 guest,guest

具体参考博客:http://blog.csdn.net/madun/article/details/20837925 ##添加spring的依赖 这三个jar不知道干啥用的,别人提到要加上

该博客连接 http://blog.csdn.net/q_an1314/article/details/52869051

<dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-core</artifactId>
            <version>2.0.8.RELEASE</version>
       </dependency>
       
        <dependency>
            <groupId>io.projectreactor</groupId>
            <artifactId>reactor-net</artifactId>
            <version>2.0.8.RELEASE</version>
        </dependency>

        <dependency>
            <groupId>io.netty</groupId>
            <artifactId>netty-all</artifactId>
            <version>4.1.6.Final</version>
        </dependency>

##设置webSocket配置 将WebSocketConfig里的config.enableSimpleBroker("/topic");改成config.enableStompBrokerRelay("/topic","/queue");这样就能使用rabbitmq做为代理器了.

另外,须要设置regist.setAllowedOrigins("*"),容许跨域请求.