一、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