rocketmq控制臺(tái)指令

1、1.1.  控制臺(tái)使用RocketMQ提供有控制臺(tái)及一系列控制臺(tái)命令，用于管理員對(duì)主題，集群，broker等信息的管理；l  登錄控制臺(tái)：首先進(jìn)入RocketMQ工程，進(jìn)入/RocketMQ/bin在該目錄下有個(gè)mqadmin腳本l  查看幫助：在mqadmin下可以查看有哪些命令              shmqadminl  查看具體命令的使用sh mqadmin help 命令名稱例如，查看updateTopic的使用

2、sh mqadmin helpupdateTopic1.2.  詳細(xì)命令1.2.1.          創(chuàng)建Topic指令updateTopic類路徑mand.topic.UpdateTopicSubCommand參數(shù)是否必填說(shuō)明-b如果 -c為空，則必填broker地址，表示topic建在該broker-c如果 -b為空，則必填cluster名稱，表示topic建在該集群（集群可通過(guò)clusterList查詢）-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;i

3、p:port;.-p否指定新topic的權(quán)限限制( W|R|WR )-r否可讀隊(duì)列數(shù)（默認(rèn)為8）-w否可寫(xiě)隊(duì)列數(shù)（默認(rèn)為8）-t是topic名稱（名稱只能使用字符 a-zA-Z0-9_-+$ ）舉例在集群DefaultCluster上創(chuàng)建主題ZTEExample，nameserve地址為68:9876sh mqadmin updateTopic n 68 c DefaultCluster t ZTEExample 1.2.2.          

4、刪除Topic指令deleteTopic類路徑mand.topic.DeleteTopicSubCommand參數(shù)是否必填說(shuō)明-c是cluster名稱，表示刪除某集群下的某個(gè)topic （集群可通過(guò)clusterList查詢）-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;-t是topic名稱（名稱只能使用字符 a-zA-Z0-9_-+$ ）舉例在集群DefaultCluster上刪除主題ZTEExample，nameserve地址為68:9876sh mqadmin deleteTopic n 68:9876 c

5、 DefaultCluster t ZTEExample 1.2.3.         創(chuàng)建（修訂）訂閱組指令updateSubGroup類路徑mand.consumer.UpdateSubGroupSubCommand參數(shù)是否必填說(shuō)明-b如果 c為空，則必填broker地址，表示訂閱組建在該broker-c如果 b為空，則必填cluster名稱，表示topic建在該集群（集群可通過(guò)clusterList查詢）-d否是否容許廣播方式消費(fèi)-g是訂閱組名-i否從哪個(gè)broker開(kāi)始消費(fèi)-m否是否容許

6、從隊(duì)列的最小位置開(kāi)始消費(fèi)，默認(rèn)會(huì)設(shè)置為false-q否消費(fèi)失敗的消息放到一個(gè)重試隊(duì)列，每個(gè)訂閱組配置幾個(gè)重試隊(duì)列-r否重試消費(fèi)最大次數(shù)，超過(guò)則投遞到死信隊(duì)列，不再投遞，并報(bào)警-s否消費(fèi)功能是否開(kāi)啟-w否發(fā)現(xiàn)消息堆積后，將Consumer的消費(fèi)請(qǐng)求重定向到另外一臺(tái)Slave機(jī)器-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例   1.2.4.         刪除訂閱組配置指令deleteSubGroup類路徑mand.consum

7、er.DeleteSubscriptionGroupCommand參數(shù)是否必填說(shuō)明-b如果 c為空，則必填broker地址，表示訂閱組建在該broker-c如果 b為空，則必填cluster名稱，表示topic建在該集群（集群可通過(guò)clusterList查詢）-g是訂閱組名-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例   1.2.5.         更新Broker配置文件指令updateBrokerConfig類路徑man

8、d.broker.UpdateBrokerConfigSubCommand參數(shù)是否必填說(shuō)明-b如果 c為空，則必填broker地址，表示訂閱組建在該broker-c如果 b為空，則必填cluster名稱，表示topic建在該集群（集群可通過(guò)clusterList查詢）-k是key值-v否value值-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例   1.2.6.         查看Topic列表信息指令topicList類路徑

9、mand.broker.UpdateBrokerConfigSubCommand參數(shù)是否必填說(shuō)明-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例nameserve地址為68:9876sh mqadmin topicList n 68:9876打印內(nèi)容：BenchmarkTest%RETRY%simple-consumer-testSELF_TEST_TOPICZTEExample注釋：上述頭三個(gè)主題是RocketMQ默認(rèn)預(yù)先創(chuàng)建 1.2.7.     

10、;    查看Topic路由信息指令topicRoute類路徑mand.topic.TopicRouteSubCommand參數(shù)是否必填說(shuō)明-t是topic名稱-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例查看主題ZTEExample的路由，nameserve地址為68:9876sh mqadmin topicRoute n 68:9876 t ZTEExample_Crm打印內(nèi)容：       

11、"brokerDatas":                "brokerAddrs":0:"68:10911"                ,      &

12、#160;         "brokerName":"crmdb"        ,        "queueDatas":                "

13、;brokerName":"crmdb",                "perm":6,                "readQueueNums":8,      

14、;          "writeQueueNums":8         1.2.8.         查看Topic統(tǒng)計(jì)信息指令topicStats類路徑mand.topic.TopicStatsSubCommand參數(shù)是否必填說(shuō)明-t是topic名稱-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:p

15、ort;ip:port;.舉例查看主題ZTEExample的統(tǒng)計(jì)信息，nameserve地址為68:9876sh mqadmin topicStats n 68:9876 t ZTEExample打印內(nèi)容：（統(tǒng)計(jì)信息里包括有offset、最后更新時(shí)間）#Broker Name  #QID  #Min Offset  #Max Offset   #Last Updatedcrmdb         0  &#

16、160;  0            1             2014-02-10 11:37:44,977crmdb         1     0       &

17、#160;    0            crmdb         2     0            0         

18、   crmdb         3     0            0            crmdb         4 

19、    0            0            crmdb         5     0          

20、;  0            crmdb         6     0            0           

21、0;crmdb         7     0            0       1.2.9.         查看Broker統(tǒng)計(jì)信息指令brokerStats類路徑mand.broker.BrokerS

22、tatsSubCommand參數(shù)是否必填說(shuō)明-b是broker地址-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例查看broker(crmdb)的統(tǒng)計(jì)信息，broker地址為68:10911,nameserve地址為68:9876sh mqadmin brokerStats n 68:9876 b 68:10911打印內(nèi)容：bootTimestamp          &

23、#160;        : 1392003367470brokerVersion                   : 29brokerVersionDesc               : V3_0_7c

24、ommitLogDiskRatio              : 0.32690830974763857commitLogMaxOffset              : 217commitLogMinOffset          

25、60;   : 0consumeQueueDiskRatio           : 0.32690830974763857dispatchMaxBuffer               : 1getFoundTps           &

26、#160;         : 0.0 0.0 0.0getMessageEntireTimeMax         : 4getMissTps                      : 0.0 0.0 0.0get

27、TotalTps                     : 0.0 0.0 0.0getTransferedTps                : 0.0 0.0 0.0msgGetTotalTodayMorning  

28、60;      : 0msgGetTotalTodayNow             : 1msgGetTotalYesterdayMorning     : 0msgPutTotalTodayMorning         : 0msgPutTotalTodayNow   &

29、#160;         : 1msgPutTotalYesterdayMorning     : 0putMessageAverageSize           : 217.0putMessageDistributeTime        :     &

30、#160;          0(0.0%)                1(100.0%)                0(0.0%)      

31、;          0(0.0%)                0(0.0%)                0(0.0%)       

32、;         0(0.0%)putMessageEntireTimeMax         : 6putMessageSizeTotal             : 217putMessageTimesTotal        

33、60;   : 1putTps                          : 0.0 0.0 0.0runtime                 &#

34、160;       : 0 days, 3 hours, 21 minutes, 1 seconds sendThreadPoolQueueCapacity     : 100000sendThreadPoolQueueSize         : 0  1.2.10.     根據(jù)消息ID查詢消息指令queryMsgById類路徑mand.me

35、ssage.QueryMsgByIdSubCommand參數(shù)是否必填說(shuō)明-i是msgId-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例查詢msgId= 0A2D2FA800002A9F0000000000000000的消息，nameserve地址為68:9876sh mqadmin queryMsgById n 68:9876 i 0A2D2FA800002A9F0000000000000000打印內(nèi)容:Topic:       

36、0;       ZTEExampleTags:                SimpleTestKeys:                SimpleTest-1Queue ID:    

37、0;       0Queue Offset:        0CommitLog Offset:    0Born Timestamp:      2014-02-26 14:49:10,875Store Timestamp:     2014-02-26 14:48:44,840Born Host:    

38、;       29:4231Store Host:          68:10911System Flag:         0Properties:          TAGS=SimpleTest, KEYS=SimpleTest-

39、1, WAIT=trueMessage Body Path:   /tmp/rocketmq/msgbodys/0A2D2FA800002A9F0000000000000000 1.2.11.     根據(jù)消息Key查詢消息指令queryMsgByKey類路徑mand.message.QueryMsgByKeySubCommand參數(shù)是否必填說(shuō)明-f否被查詢消息的截止時(shí)間-k是msgKey-t是Topic名稱-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例查詢Topic

40、= ZTEExample下key= SimpleTest-1的消息，nameserve地址為68:9876sh mqadmin queryMsgByKey -n 68:9876 -t ZTEExample -k SimpleTest-1打印內(nèi)容:#Message ID                        &#

41、160;               #QID  #Offset0A2D2FA800002A9F0000000000000000                   0    01.2.12.    

42、 根據(jù)Offset查詢消息指令queryMsgByOffset類路徑mand.message.QueryMsgByOffsetSubCommand參數(shù)是否必填說(shuō)明-b是Broker名稱，表示訂閱組建在該broker（這里需要注意填寫(xiě)的是broker的名稱，不是broker的地址，broker名稱可以在clusterList查到）-i是query隊(duì)列id-o是offset值-t是topic名稱-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例查詢brokerName=crm-168，Topic= ZTEExample的第1個(gè)隊(duì)列下offset

43、=0的消息，nameserve地址為68:9876sh mqadmin queryMsgByOffset -n 68:9876 -b crm-168 -i 0 -t ZTEExample -o 0打印內(nèi)容:Topic:               ZTEExampleTags:            

44、;    SimpleTestKeys:                SimpleTest-1Queue ID:            0Queue Offset:        0CommitLog Offset:  

45、;  0Born Timestamp:      2014-02-26 14:49:10,875Store Timestamp:     2014-02-26 14:48:44,840Born Host:           29:4231Store Host:          10.4

46、5.47.168:10911System Flag:         0Properties:          TAGS=SimpleTest, KEYS=SimpleTest-1, WAIT=trueMessage Body Path:   /tmp/rocketmq/msgbodys/0A2D2FA800002A9F0000000000000000 1.2.13.  &#

47、160;  查詢Producer的網(wǎng)絡(luò)連接l  該命令只打印當(dāng)前與cluster連接的producer網(wǎng)絡(luò)連接信息指令producerConnection類路徑mand.connection.ProducerConnectionSubCommand參數(shù)是否必填說(shuō)明-g是生產(chǎn)者所屬組名-t是topic名稱-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例查詢當(dāng)前屬于group（生產(chǎn)者組）=simple-producer-test的生產(chǎn)者到topic=ZTEExample的網(wǎng)絡(luò)連接，nameserve地址為10.45.47.

48、168:9876sh mqadmin producerConnection -n 68:9876 -g simple-producer-test -t ZTEExample打印內(nèi)容:0001 29simple-producer-test-99f09de2a20a4b6284bb949b452bee0c 29:4332   Java  V3_0_7 1.2.14.     查詢Consumer的網(wǎng)絡(luò)連接l  該命令只打印當(dāng)前與c

49、luster連接的consumer網(wǎng)絡(luò)連接信息指令consumerConnection類路徑mand.connection.ConsumerConnectionSubCommand參數(shù)是否必填說(shuō)明-g是消費(fèi)者所屬組名-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例查詢當(dāng)前屬于group（消費(fèi)者組）=simple-consumer-test的消費(fèi)者的網(wǎng)絡(luò)連接，nameserve地址為68:9876sh mqadmin consumerConnection -n 68:9876 -g simple-consume

50、r-test打印內(nèi)容:001  29simple-consumer-test-7babbb6021b040d29978494b16d559ae 29:4355      JAVA     V3_0_7 Below is subscription:001  Topic: ZTEExample            

51、60;                  SubExpression: * ConsumeType: CONSUME_ACTIVELYMessageModel: CLUSTERINGConsumeFromWhere: CONSUME_FROM_LAST_OFFSET 1.2.15.     查看訂閱組消費(fèi)狀態(tài)指令consumerProgress類路徑mand

52、.consumer.ConsumerProgressSubCommand參數(shù)是否必填說(shuō)明-g是消費(fèi)者所屬組名-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例查詢當(dāng)前屬于group（消費(fèi)者組）=simple-consumer-test的訂閱狀態(tài)，nameserve地址為68:9876sh mqadmin consumerProgress -n 68:9876 -g simple-consumer-test打印內(nèi)容:#Topic       &

53、#160; #Broker Name    #QID  #Broker Offset        #Consumer Offset      #DiffZTEExample     crm-168         0     2    &

54、#160;                2                     0ZTEExample     crm-168      

55、60;  1     0                     0                     0ZTEExample 

56、60;   crm-168         2     0                     0             &

57、#160;       0ZTEExample     crm-168         3     0                     0   

58、;                  0ZTEExample     crm-168         4     0             

59、;        0                     0ZTEExample     crm-168         5     0  

60、60;                  0                     0ZTEExample     crm-168     

61、;    6     0                     0                     0ZTEExampl

62、e     crm-168         7     0                     0           

63、60;         0 Consume TPS: 0Diff Total: 0 1.2.16.     查看集群消息指令clusterList類路徑mand.cluster.ClusterListSubCommand參數(shù)是否必填說(shuō)明-m否打印更多信息 (增加打印出如下信息 #InTotalYest,   #OutTotalYest, #InTotalToday ,#OutTotalToday)-h否打印幫助-n是names

64、erve服務(wù)地址列表，格式ip:port;ip:port;.舉例查詢當(dāng)前集群狀態(tài)，nameserve地址為68:9876sh mqadmin clusterList -n 68:9876打印內(nèi)容:#Cluster Name  #Broker Name  #BID  #Addr               #Version   #InTPS  

65、60;  #OutTPSCRM            crm-168       0     68:10911  V3_0_7       0.00        0.00CRM   

66、60;        crm-181       0     81:10911  V3_0_7       0.00        0.00 sh mqadmin clusterList -n 68:9876 m#Cluster Name

67、   #Broker Name  #InTotalYest  #OutTotalYest  #InTotalToday   #OutTotalTodayCRM           crm-168                 0  

68、60;          0              2              3CRM           crm-181 

69、0;               0             0              0         

70、0;    01.2.17.     添加（更新）KV配置信息指令updateKvConfig類路徑srv.UpdateKvConfigCommand參數(shù)是否必填說(shuō)明-k是key值-v是value值-s是Namespace值-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例   1.2.18.     刪除KV配置信息指令deleteKvConfig類路徑s

71、rv.DeleteKvConfigCommand參數(shù)是否必填說(shuō)明-k是key值-s是Namespace值-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例   1.2.19.     添加（更新）Project group配置信息指令updateProjectGroup類路徑srv.UpdateProjectGroupCommand參數(shù)是否必填說(shuō)明-i是服務(wù)器ip-p是project group名-h否打印幫助-n是nameserve服務(wù)地址列表，格式i

72、p:port;ip:port;.舉例   1.2.20.     刪除Projectgroup配置信息指令deleteProjectGroup類路徑srv.DeleteProjectGroupCommand參數(shù)是否必填說(shuō)明-i是服務(wù)器ip-p是project group名-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例  1.2.21.     取得Projectgroup配置信息指

73、令getProjectGroup類路徑srv.GetProjectGroupCommand參數(shù)是否必填說(shuō)明-i是服務(wù)器ip-p是project group名-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例   1.2.22.     設(shè)置消費(fèi)進(jìn)度l  根據(jù)時(shí)間來(lái)設(shè)置消費(fèi)進(jìn)度，設(shè)置之前要關(guān)閉這個(gè)訂閱組的所有consumer，設(shè)置完再啟動(dòng)，方可生效指令resetOffsetByTime類路徑mand.offset.ResetOffsetByTim

74、eSubCommand參數(shù)是否必填說(shuō)明-f否通過(guò)時(shí)間戳強(qiáng)制回滾（true|false），默認(rèn)為true-s是時(shí)間戳（currentTimeMillis|yyyy-MM-dd#HH:mm:ss:SSS）-g是消費(fèi)者所屬組名-t是topic名稱-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例   1.2.23.     清除特定Broker權(quán)限指令wipeWritePerm類路徑srv.WipeWritePermSubCommand參數(shù)是否必填說(shuō)明-b是b

75、roker地址-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip:port;.舉例   1.2.24.     獲取Consumer消費(fèi)進(jìn)度l  該命令只打印當(dāng)前與cluster連接的consumer的消費(fèi)進(jìn)度指令getConsumerStatus類路徑mand.offset.GetConsumerStatusCommand參數(shù)是否必填說(shuō)明-g是消費(fèi)者所屬組名-t是查詢主題-i否Consumer客戶端ip-h否打印幫助-n是nameserve服務(wù)地址列表，格式ip:port;ip

76、:port;.舉例查詢屬于group（消費(fèi)者組）=simple-consumer-test的消費(fèi)者在Topic=ZTEExample上的消費(fèi)狀態(tài)，nameserve地址為68:9876sh mqadmin getConsumerStatus -n 68:9876 -g simple-consumer-test -t ZTEExampleget consumer status from client. group=simple-consumer-test, topic=ZTEExample, originClientId=#clientId