RocketMQ部署

参考

• https://github.com/apache/rocketmq
• https://github.com/apache/rocketmq-docker
• https://github.com/apache/rocketmq-clients/blob/master/java/README-CN.md

• https://rocketmq.apache.org/
• https://rocketmq.apache.org/zh/docs/
• https://hub.docker.com/r/apache/rocketmq/tags

异步转Reactor

• https://medium.com/javarevisited/converting-async-client-to-reactive-69a506f80d34
• https://stackoverflow.com/questions/50363612/convert-a-callback-into-a-reactive-publisher-flux

原生方式部署

# 版本 5.1.4

# 启动
nohup sh bin/mqnamesrv &
nohup sh bin/mqbroker -n localhost:9876 &

# 关闭
sh bin/mqshutdown broker
sh bin/mqshutdown namesrv

# 验证
export NAMESRV_ADDR=10.10.51.4:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

# dashboard
docker run -d --name rocketmq-dashboard -e "JAVA_OPTS=-Drocketmq.namesrv.addr=10.10.51.4:9876" -p 38080:8080 -t apacherocketmq/rocketmq-dashboard:latest

控制台

10.10.51.4:9876
http://10.10.51.4:38080

常用操作

sh bin/mqadmin updateTopic -c DefaultCluster -t TopicTest2 -n 10.10.51.4:9876