一个完善的消息中间件，监控是必不可少的功能。通过监控我们可以查看系统的运行情况，是否出现异常，是系统稳定性和运维的基础。
1、监控平台搭建
下载地址：https://github.com/apache/rocketmq-externals
RocketMQ控制台需要自己去下载编译打包，可以在编译时设置其namesrvAddr和端口号，也可以在程序启动时指定这些参数（SpringBoot项目）
image
使用maven打包
mvn clean package -Dmaven.test.skip=true
启动程序
nohup java -jar rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=10.10.15.246:9876;10.10.15.246:9876 &
浏览器访问
image
管控台不仅有相关的系统监控数据，还有运维功能，如创建主题、修改主题、删除主题、主题列表信息、主题的配置信息、主题所有的消费组信息、每个消费组的每个队列中消费进度、Broker数节点信息、消息的查询等简单的看几个
最常用的消息的查询、可以查看其详细的发送的消息信息
image
消费进度查询
image
其他的功能可以自己查看。
2、运维命令
我们查看一下关于RocketMQ自己提供的控制台命令有哪些
image
我们分析下重点的常用命令
2.1、创建更新主题(updateTopic)
./mqadmin updateTopic -b 10.10.15.247:10911 -t TopicCmd
image
具体的参数详情可以查看提示
2.2、删除主题(deleteTopic)
./mqadmin deleteTopic -n 10.10.15.246:9876 -c 10.10.15.246:10911 -t TopicCmd
image
2.3、创建更新消费组(updateSubGroup)
./mqadmin updateSubGroup -n 10.10.15.246:9876 -b 10.10.15.247:10911 -g GroupTest
image
2.4、删除消费组(deleteSubGroup)
./mqadmin deleteSubGroup -n 10.10.15.246:9876 -b 10.10.15.246:10911 -g GroupTest
image
2.5、主题队列信息(topicStatus)
./mqadmin topicStatus -n 10.10.15.246:9876 -t TopicTest
image
2.6、主题路由信息(topicRoute)
./mqadmin topicRoute -n 10.10.15.246:9876 -t TopicTest
image
2.7、主题列表(topicList)
./mqadmin topicList -n 10.10.15.246:9876
image
2.8、Broker节点信息(brokerStatus)
./mqadmin brokerStatus -n 10.10.15.246:9876 -b 10.10.15.246:10911
image
2.9、通过KEY查询消息(queryMsgByKey)
./mqadmin queryMsgByKey -n 10.10.15.246:9876 -k 2000000 -t TopicTest
image
注意由于KEY是用户自己设置的所有查询时可能有多条消息
image
2.10、通过消息的ID查询消息(queryMsgById)
./mqadmin queryMsgById -i 0A0A0FF600002A9F000000000180DD31
image
我们看一下消息的offsetMsgId怎么找到的，发送的消息返回的信息中就有相关的信息
image
我们再查看一下查询到的消息体的路径
image
2.11、打印消息(printMsg)
./mqadmin printMsg -n 10.10.15.246:9876 -t TopicTest -b 2019-07-26#07:50:00:000 -e 2019-07-26#09:00:00:000
image
2.12、查看消费状态(brokerConsumeStats)
./mqadmin brokerConsumeStats -b 10.10.15.246:10911
image
2.13、集群的节点信息(clusterList)
./mqadmin clusterList -n 10.10.15.246:9876
image
2.14、总体的消费的状态信息(statsAll)
./mqadmin statsAll -n 10.10.15.246:9876
image
2.15、查看消费组下的消费者信息(consumerConnection)
./mqadmin consumerConnection -n 10.10.15.246:9876 -g group_name_1
image
2.16、消费进度信息(consumerProgress)
./mqadmin consumerProgress -n 10.10.15.246:9876
image
2.17、重置消费点位(resetOffsetByTime)
./mqadmin resetOffsetByTime -n 10.10.15.246:9876 -t TopicTest -g group_name_1 -s 2019-07-26#07:00:00:000
image
2.18、消息队列负载情况(allocateMQ)
./mqadmin allocateMQ -t TopicTest -i 192.168.1.104,10.10.14.163 -n 10.10.15.246:9876
image
2.19、测试Broker接收消息的性能(sendMsgStatus)
./mqadmin sendMsgStatus -n 10.10.15.246:9876 -b broker-a -c 3
image
2.20、测试集群消息发送的性能(clusterRT)
./mqadmin clusterRT -n 10.10.15.246:9876 -s 128
image
2.21、查看Broker配置信息(getBrokerConfig)
./mqadmin getBrokerConfig -b 10.10.15.246:10911
image
