Windows上使用RocketMQ

下载RocketMQ地址

配置两个全局变量,就和配置[JAVA_HOME]一样

ROCKETMQ_HOME=C:\Application\MQ\RocketMQ-4.8.0
NAMESRV_ADDR=127.0.0.1:9876

启动[mqnamesrv.cmd]

.\bin\mqnamesrv.cmd

启动[mqbroker.cmd]

.\bin\mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

测试发送消息

.\bin\tools.cmd org.apache.rocketmq.example.quickstart.Producer

测试接收消息

.\bin\tools.cmd org.apache.rocketmq.example.quickstart.Consumer

可视化工具下载地址

#这里其实就是一个SpringBoot项目,修改配置文件
rocketmq.config.namesrvAddr=127.0.0.1:9876
# 在项目根目录进行maven打包
mvn clean package -Dmaven.test.skip=true
# 在项目根目录运行jar
java -jar .\target\rocketmq-console-ng-1.0.0.jar
# 浏览器访问就可以了