一個完善的消息中間件，監控是必不可少的功能。通過監控我們可以查看系統的運行情況，是否出現異常，是系統穩定性和運維的基礎。

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