本篇內(nèi)容主要講解“RocketMQ運(yùn)維監(jiān)控的實(shí)現(xiàn)方法”,感興趣的朋友不妨來看看。本文介紹的方法操作簡(jiǎn)單快捷,實(shí)用性強(qiáng)。下面就讓小編來帶大家學(xué)習(xí)“RocketMQ運(yùn)維監(jiān)控的實(shí)現(xiàn)方法”吧!
信陽網(wǎng)站制作公司哪家好,找創(chuàng)新互聯(lián)!從網(wǎng)頁設(shè)計(jì)、網(wǎng)站建設(shè)、微信開發(fā)、APP開發(fā)、響應(yīng)式網(wǎng)站等網(wǎng)站項(xiàng)目制作,到程序開發(fā),運(yùn)營(yíng)維護(hù)。創(chuàng)新互聯(lián)于2013年創(chuàng)立到現(xiàn)在10年的時(shí)間,我們擁有了豐富的建站經(jīng)驗(yàn)和運(yùn)維經(jīng)驗(yàn),來保證我們的工作的順利進(jìn)行。專注于網(wǎng)站建設(shè)就選創(chuàng)新互聯(lián)。
一個(gè)完善的消息中間件,監(jiān)控是必不可少的功能。通過監(jiān)控我們可以查看系統(tǒng)的運(yùn)行情況,是否出現(xiàn)異常,是系統(tǒng)穩(wěn)定性和運(yùn)維的基礎(chǔ)。
下載地址:https://github.com/apache/rocketmq-externals
RocketMQ控制臺(tái)需要自己去下載編譯打包,可以在編譯時(shí)設(shè)置其namesrvAddr和端口號(hào),也可以在程序啟動(dòng)時(shí)指定這些參數(shù)(SpringBoot項(xiàng)目)
使用maven打包
mvn clean package -Dmaven.test.skip=true
啟動(dòng)程序
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 &
瀏覽器訪問
管控臺(tái)不僅有相關(guān)的系統(tǒng)監(jiān)控?cái)?shù)據(jù),還有運(yùn)維功能,如創(chuàng)建主題、修改主題、刪除主題、主題列表信息、主題的配置信息、主題所有的消費(fèi)組信息、每個(gè)消費(fèi)組的每個(gè)隊(duì)列中消費(fèi)進(jìn)度、Broker數(shù)節(jié)點(diǎn)信息、消息的查詢等簡(jiǎn)單的看幾個(gè)
最常用的消息的查詢、可以查看其詳細(xì)的發(fā)送的消息信息
消費(fèi)進(jìn)度查詢
其他的功能可以自己查看。
我們查看一下關(guān)于RocketMQ自己提供的控制臺(tái)命令有哪些
我們分析下重點(diǎn)的常用命令
./mqadmin updateTopic -b 10.10.15.247:10911 -t TopicCmd
具體的參數(shù)詳情可以查看提示
./mqadmin deleteTopic -n 10.10.15.246:9876 -c 10.10.15.246:10911 -t TopicCmd
./mqadmin updateSubGroup -n 10.10.15.246:9876 -b 10.10.15.247:10911 -g GroupTest
./mqadmin deleteSubGroup -n 10.10.15.246:9876 -b 10.10.15.246:10911 -g GroupTest
./mqadmin topicStatus -n 10.10.15.246:9876 -t TopicTest
./mqadmin topicRoute -n 10.10.15.246:9876 -t TopicTest
./mqadmin topicList -n 10.10.15.246:9876
./mqadmin brokerStatus -n 10.10.15.246:9876 -b 10.10.15.246:10911
./mqadmin queryMsgByKey -n 10.10.15.246:9876 -k 2000000 -t TopicTest
注意由于KEY是用戶自己設(shè)置的所有查詢時(shí)可能有多條消息
./mqadmin queryMsgById -i 0A0A0FF600002A9F000000000180DD31
我們看一下消息的offsetMsgId怎么找到的,發(fā)送的消息返回的信息中就有相關(guān)的信息
我們?cè)俨榭匆幌虏樵兊降南Ⅲw的路徑
./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
./mqadmin brokerConsumeStats -b 10.10.15.246:10911
./mqadmin clusterList -n 10.10.15.246:9876
./mqadmin statsAll -n 10.10.15.246:9876
./mqadmin consumerConnection -n 10.10.15.246:9876 -g group_name_1
./mqadmin consumerProgress -n 10.10.15.246:9876
./mqadmin resetOffsetByTime -n 10.10.15.246:9876 -t TopicTest -g group_name_1 -s 2019-07-26#07:00:00:000
./mqadmin allocateMQ -t TopicTest -i 192.168.1.104,10.10.14.163 -n 10.10.15.246:9876
./mqadmin sendMsgStatus -n 10.10.15.246:9876 -b broker-a -c 3
./mqadmin clusterRT -n 10.10.15.246:9876 -s 128
./mqadmin getBrokerConfig -b 10.10.15.246:10911
到此,相信大家對(duì)“RocketMQ運(yùn)維監(jiān)控的實(shí)現(xiàn)方法”有了更深的了解,不妨來實(shí)際操作一番吧!這里是創(chuàng)新互聯(lián)網(wǎng)站,更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢,關(guān)注我們,繼續(xù)學(xué)習(xí)!