本地部署 RocketMQ

参考：https://rocketmq.apache.org/zh/docs/quickStart/01quickstart

# 启动NameServer
nohup sh bin/mqnamesrv -n 192.168.105:9876  >> logs/mqnamesrv.log &
tail -f logs/mqnamesrv.log
# 启动Broker+Proxy
nohup sh bin/mqbroker -n 192.168.105:9876 -c conf/broker.conf --enable-proxy >> logs/mqbroker.log &
tail -f logs/mqbroker.log
# 停止NameServer
bin/mqshutdown namesrv
# 停止Broker+Proxy
bin/mqshutdown broker

使用命令行工具

# 查看broker状态
bin/mqadmin brokerStatus -n 192.168.1.105:9876 -b 192.168.1.105:10911
# 创建topic
bin/mqadmin updatetopic -n 192.168.1.105:9876 -t TestTopic -b 192.168.1.105:10911
# 创建组
bin/mqadmin updateSubGroup -n 192.168.1.105:9876 -b 192.168.1.105:10911 -g TestGroup