一个完善的消息中间件，监控是必不可少的功能。通过监控我们可以查看系统的运行情况，是否出现异常，是系统稳定性和运维的基础。

1、监控平台搭建

RocketMQ控制台需要自己去下载编译打包，可以在编译时设置其namesrvAddr和端口号，也可以在程序启动时指定这些参数(SpringBoot项目)

使用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 &

浏览器访问

管控台不仅有相关的系统监控数据，还有运维功能，如创建主题、修改主题、删除主题、主题列表信息、主题的配置信息、主题所有的消费组信息、每个消费组的每个队列中消费进度、Broker数节点信息、消息的查询等简单的看几个

最常用的消息的查询、可以查看其详细的发送的消息信息

消费进度查询

其他的功能可以自己查看。

2、运维命令

我们查看一下关于RocketMQ自己提供的控制台命令有哪些

我们分析下重点的常用命令

2.1、创建更新主题(updateTopic)

./mqadmin updateTopic -b 10.10.15.247:10911 -t TopicCmd

具体的参数详情可以查看提示

2.2、删除主题(deleteTopic)

./mqadmin deleteTopic -n 10.10.15.246:9876 -c 10.10.15.246:10911 -t TopicCmd

2.3、创建更新消费组(updateSubGroup)

./mqadmin updateSubGroup -n 10.10.15.246:9876 -b 10.10.15.247:10911 -g GroupTest

2.4、删除消费组(deleteSubGroup)

./mqadmin deleteSubGroup -n 10.10.15.246:9876 -b 10.10.15.246:10911 -g GroupTest

2.5、主题队列信息(topicStatus)

./mqadmin topicStatus -n 10.10.15.246:9876 -t TopicTest

2.6、主题路由信息(topicRoute)

./mqadmin topicRoute -n 10.10.15.246:9876 -t TopicTest

2.7、主题列表(topicList)

./mqadmin topicList -n 10.10.15.246:9876

2.8、Broker节点信息(brokerStatus)

./mqadmin brokerStatus -n 10.10.15.246:9876 -b 10.10.15.246:10911

2.9、通过KEY查询消息(queryMsgByKey)

./mqadmin queryMsgByKey -n 10.10.15.246:9876 -k 2000000 -t TopicTest

注意由于KEY是用户自己设置的所有查询时可能有多条消息

2.10、通过消息的ID查询消息(queryMsgById)

./mqadmin queryMsgById -i 0A0A0FF600002A9F000000000180DD31

我们看一下消息的offsetMsgId怎么找到的，发送的消息返回的信息中就有相关的信息

我们再查看一下查询到的消息体的路径

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

2.12、查看消费状态(brokerConsumeStats)

./mqadmin brokerConsumeStats -b 10.10.15.246:10911

2.13、集群的节点信息(clusterList)

./mqadmin clusterList -n 10.10.15.246:9876

2.14、总体的消费的状态信息(statsAll)

./mqadmin statsAll -n 10.10.15.246:9876

2.15、查看消费组下的消费者信息(consumerConnection)

./mqadmin consumerConnection -n 10.10.15.246:9876 -g group_name_1

2.16、消费进度信息(consumerProgress)

./mqadmin consumerProgress -n 10.10.15.246:9876

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

2.18、消息队列负载情况(allocateMQ)

./mqadmin allocateMQ -t TopicTest -i 192.168.1.104,10.10.14.163 -n 10.10.15.246:9876

2.19、测试Broker接收消息的性能(sendMsgStatus)

./mqadmin sendMsgStatus -n 10.10.15.246:9876 -b broker-a -c 3

2.20、测试集群消息发送的性能(clusterRT)

./mqadmin clusterRT -n 10.10.15.246:9876 -s 128

2.21、查看Broker配置信息(getBrokerConfig)

./mqadmin getBrokerConfig -b 10.10.15.246:10911