RocketMQ是阿里巴巴开源的分布式消息中间件。支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。它里面有几个区别于标准消息中件间的概念，如Group、Topic、Queue等。系统组成则由Producer、Consumer、Broker、NameServer等。

官方网站

https://rocketmq.apache.org/docs/quick-start/ 

下载、解压、编译

wget https://archive.apache.org/dist/rocketmq/4.9.2/rocketmq-all-4.9.2-source-release.zip
unzip rocketmq-all-4.9.2-source-release.zip
cd rocketmq-all-4.9.2/
mvn -Prelease-all -DskipTests clean install -U
cd distribution/target/rocketmq-4.9.2/rocketmq-4.9.2

启动 Name Server

nohup sh bin/mqnamesrv &
tail -f ~/logs/rocketmqlogs/namesrv.log

启动 Broker

nohup sh bin/mqbroker -n 0.0.0.0:9876 &
tail -f ~/logs/rocketmqlogs/broker.log

可以使用如下命令进行启动

nohup sh bin/mqnamesrv > mqnamesrv.log 2>&1 &
nohup sh bin/mqbroker -n 0.0.0.0:9876 > mqbroker.log 2>&1 &

测试连接

export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

停止服务

sh bin/mqshutdown namesrv
sh bin/mqshutdown broker

如果是本地或者虚拟机测试，则要修改内存配置，分别修改如下两个文件

runserver.sh和runbroker.sh

客户端

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

安装方式参考官网

启动客户端，指定本地端口和MQ端口

java -jar rocketmq-dashboard-2.0.0.jar --server.port=10003 --rocketmq.config.namesrvAddr=localhost:9876  > rocketmq-dashboard.log 2>&1 &

END