RocketMq消息队列

本地安装目录

#安装目录 
~/work/rocketmq-all-4.8.0-bin-release/bin

#启动namesrv bash
nohup sh mqnamesrv &
#查看日志 
tail -f ~/logs/rocketmqlogs/namesrv.log
#启动mqbroker
nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true &
#查看日志
tail -f ~/logs/rocketmqlogs/broker.log

#控制台

控制台

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

#下载控制台git代码后本地启动
http://localhost:8080/#/

#修改application.properties
rocketmq.config.namesrvAddr=localhost:9876
##  启动时会报错，本地连接不上，所以要加上启动国参数
##  在idea上配置program arguments
java -jar rocketmq-console-ng-1.0.1.jar --rocketmq.config.namesrvAddr=localhost:9876

创建Topic

java