SpringBoot（十三） 集成消息队列RocketMq

一、本地安装RocketMq服务

（1）、下载并解压rocketMq

http://rocketmq.apache.org/dowloading/releases/

下载解压到本地如下：

（2）、配置环境变量：

变量名：ROCKETMQ_HOME
变量值：D:\rocketMq\rocketmq-all-4.6.0-bin-release

（3）、启动nameServer：进入bin目录输入命令：start mqnamesrv.cmd

弹出新的窗口，提示success，表示nameserver启动成功，弹窗不要关闭。

（4）、启动broker：在刚才的命令窗口继续执行：start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

弹出新弹框，提示success，表示启动成功！弹窗不要关闭

（注：如果弹出 错误: 找不到或无法加载主类，可能是因为环境变量JAVA_HOME中配置存在空格导致的，如Program Files这类的，需要修改下bin下的runbroker.cmd文件，如下位置添加双引号）

二、下载并且配置rocketMq可视化工具

https://github.com/apache/rocketmq-externals.git

解压后如下：

 

（2）、修改配置文件

在路径：rocketmq-console\src\main\resources文件夹，打开application.properties，修改namesrvAddr为启动的rocketMq服务

（3）、编译项目：进入\rocketmq-externals\rocketmq-console文件夹，执行mvn clean package -Dmaven.test.skip=true

如果mvn命令不能用，请参考：https://blog.csdn.net/qq_40875057/article/details/94760227

进入target目录，执行：java -jar rocketmq-console-ng-1.0.0.jar  启动服务

（4）、打开验证 http://localhost:8081/