監控rocketmq 常用方法


一、mqcloud(https://github.com/sohutv/mqcloud/)

sohu出的集客戶端SDK,運維,監控,預警等功能的RocketMQ企業級一站式服務平台

使用java開發,功能比較多,對集群數量較多的環境支持比較好

 

二、RocketmqExporter(https://github.com/apache/rocketmq-exporter.git)

官方源碼,使用java開發,支持集成到prometheus

 

三、rocketmq-6(https://github.com/hepyu/RocketmqExporter)

golang實現的生產可用rocketmq-exporter

個人比較喜歡這個,但因為作者偷了點懶,需要從rocketmq-console的http請求獲取數據。也就是說RocketmqExporter必須依賴rocketmq-console

 

四、rocketmq-console-ng(https://github.com/apache/rocketmq-externals)

一直有在用,沒想到還可以實現監控報警(參考https://blog.csdn.net/luanlouis/article/details/88078657)

 

 

 

mqadmin常用參數

#創建更新主題(updateTopic)
./mqadmin updateTopic -b 127.0.0.1:10911 -t TopicCmd
#刪除主題(deleteTopic)
./mqadmin deleteTopic -n 127.0.0.1:9876  -c 127.0.0.1:10911 -t TopicCmd
#創建更新消費組(updateSubGroup)
./mqadmin updateSubGroup -n 127.0.0.1:9876 -b 127.0.0.1:10911 -g GroupTest
#刪除消費組(deleteSubGroup)
./mqadmin deleteSubGroup -n 127.0.0.1:9876 -b 127.0.0.1:10911 -g GroupTest
#主題隊列信息(topicStatus)
./mqadmin topicStatus -n 127.0.0.1:9876 -t TopicTest
#主題路由信息(topicRoute)
./mqadmin topicRoute -n 127.0.0.1:9876 -t TopicTest
#主題列表(topicList)
./mqadmin topicList -n 127.0.0.1:9876
#Broker節點信息(brokerStatus)
./mqadmin brokerStatus -n 127.0.0.1:9876 -b 127.0.0.1:10911
#通過KEY查詢消息(queryMsgByKey)
./mqadmin queryMsgByKey -n 127.0.0.1:9876 -k 2000000 -t TopicTest
#通過KEY查詢消息(queryMsgByKey)
./mqadmin queryMsgByKey -n 127.0.0.1:9876 -k 2000000 -t TopicTest
#打印消息(printMsg)
./mqadmin printMsg -n 127.0.0.1:9876 -t TopicTest -b 2019-07-26#07:50:00:000 -e 2019-07-26#09:00:00:000
#查看消費狀態(brokerConsumeStats)
./mqadmin brokerConsumeStats -b 127.0.0.1:10911
#集群的節點信息(clusterList)
./mqadmin clusterList -n 127.0.0.1:9876
#總體的消費的狀態信息(statsAll)
./mqadmin statsAll -n 127.0.0.1:9876
#查看消費組下的消費者信息(consumerConnection)
./mqadmin consumerConnection -n 127.0.0.1:9876 -g group_name_1
#消費進度信息(consumerProgress)
./mqadmin consumerProgress -n 127.0.0.1:9876
#消費進度信息(consumerProgress)
./mqadmin consumerProgress -n 127.0.0.1:9876
#消息隊列負載情況(allocateMQ)
./mqadmin allocateMQ -t TopicTest -i 127.0.0.1 -n 127.0.0.1:9876
#測試Broker接收消息的性能(sendMsgStatus)
./mqadmin sendMsgStatus -n 127.0.0.1:9876 -b broker-a -c 3
#測試Broker接收消息的性能(sendMsgStatus)
./mqadmin sendMsgStatus -n 127.0.0.1:9876 -b broker-a -c 3
#查看Broker配置信息(getBrokerConfig)
./mqadmin getBrokerConfig -b 127.0.0.1:10911

 

引用:https://mp.weixin.qq.com/s/CyYdss6kFlo9qRuGfM_OlA

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM