2 rocketmq mqadmin 的用法詳解

參考文檔

http://jameswxx.iteye.com/blog/2091971

1.1. 控制台使用

RocketMQ 提供有控制台及一系列控制台指令，用于管理者對主題，叢集，broker 等資訊的管理；

登入控制台

首先進入RocketMQ 工程，進入/RocketMQ/bin

在該目錄下有個mqadmin 腳本

檢視幫助

在mqadmin 下可以檢視有哪些指令

sh mqadmin

檢視具體指令的使用

sh mqadmin help 指令名稱

例如，檢視updateTopic 的使用

sh mqadmin help updateTopic

1.2. 詳細指令

指令 

updateTopic 

類路徑 

com.alibaba.rocketmq.tools.command.topic.UpdateTopicSubCommand

參數

是否必填

說明

-b

如果-c為空，則必填

broker 位址，表示topic 建在該broker

-c

如果-b為空，則必填

cluster 名稱，表示topic 建在該叢集（叢集可通過clusterList 查詢）

-h

否

列印幫助

-n

是

nameserve 服務位址清單，格式ip:port;ip:port;...

-p

否 

指定新topic 的權限限制( W|R|WR )

-r 

可讀隊列數（預設為8）

-w

可寫隊列數（預設為8）

-t

opic 名稱（名稱隻能使用字元 ^[a-zA-Z0-9_-]+$ ）

deleteTopic 

com.alibaba.rocketmq.tools.command.topic.DeleteTopicSubCommand

參數 

 說明

cluster 名稱，表示删除某叢集下的某個topic （叢集可通過clusterList 查詢）

nameserve 服務位址清單，格式ip:port;ip:port;…

topic 名稱（名稱隻能使用字元 ^[a-zA-Z0-9_-]+$ ）

updateSubGroup 

com.alibaba.rocketmq.tools.command.consumer.UpdateSubGroupSubCommand

如果 –c 為空，則必填

broker 位址，表示訂閱組建在該broker

如果 –b 為空，則必填

cluster名稱，表示topic 建在該叢集（叢集可通過clusterList查詢）

-d

是否容許廣播方式消費

-g

是 

訂閱組名

-i

從哪個broker 開始消費

-m

是否容許從隊列的最小位置開始消費，預設會設定為false

-q

消費失敗的消息放到一個重試隊列，每個訂閱組配置幾個重試隊列

重試消費最大次數，超過則投遞到死信隊列，不再投遞，并報警

-s

消費功能是否開啟

-w 

發現消息堆積後，将Consumer 的消費請求重定向到另外一台Slave 機器

deleteSubGroup 

com.alibaba.rocketmq.tools.command.consumer.DeleteSubscriptionGroupCommand

-b 

如果–c 為空，則必填

-c 

如果–b 為空，則必填

cluster 名稱，表示topic建在該叢集（叢集可通過clusterList查詢）

-n 

updateBrokerConfig

類路徑

com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand

如果–c為空，則必填

-k 

 key 值

-v

value 值

topicList 

topicRoute 

com.alibaba.rocketmq.tools.command.topic.TopicRouteSubCommand

topic 名稱

topicStats 

com.alibaba.rocketmq.tools.command.topic.TopicStatsSubCommand

brokerStats 

com.alibaba.rocketmq.tools.command.broker.BrokerStatsSubCommanD

 broker 位址

queryMsgById 

com.alibaba.rocketmq.tools.command.message.QueryMsgByIdSubCommand

 消息id

queryMsgByKey 

com.alibaba.rocketmq.tools.command.message.QueryMsgByKeySubCommand

-f

被查詢消息的截止時間

-k

msgKey

queryMsgByOffset

com.alibaba.rocketmq.tools.command.message.QueryMsgByOffsetSubCommand

Broker 名稱，表示訂閱組建在該broker（這裡需要注意填寫的是broker 的名稱，不是broker 的位址，broker名稱可以在clusterList 查到

query 隊列id

-o

offset 值

該指令隻列印目前與cluster 連接配接的producer 網絡連接配接資訊

producerConnection

com.alibaba.rocketmq.tools.command.connection.ProducerConnectionSubCommand

生産者所屬組名

該指令隻列印目前與cluster 連接配接的consumer 網絡連接配接資訊

consumerConnection

com.alibaba.rocketmq.tools.command.connection.ConsumerConnectionSubCommand

消費者所屬組名

consumerProgress

com.alibaba.rocketmq.tools.command.consumer.ConsumerProgressSubCommand

clusterList 

com.alibaba.rocketmq.tools.command.cluster.ClusterListSubCommand

列印更多資訊

updateKvConfig 

com.alibaba.rocketmq.tools.command.namesrv.UpdateKvConfigCommand

key 值

Namespace 值

deleteKvConfig 

com.alibaba.rocketmq.tools.command.namesrv.DeleteKvConfigCommand

指令 updateProjectGroup 

類路徑 com.alibaba.rocketmq.tools.command.namesrv.UpdateProjectGroupCommand

project group 名

伺服器ip

deleteProjectGroup

com.alibaba.rocketmq.tools.command.namesrv.DeleteProjectGroupCommand

getProjectGroup

com.alibaba.rocketmq.tools.command.namesrv.GetProjectGroupCommand

根據時間來設定消費進度，設定之前要關閉這個訂閱組的所有consumer，設定完再啟動，方可生效

resetOffsetByTime

com.alibaba.rocketmq.tools.command.offset.ResetOffsetByTimeSubCommand

通過時間戳強制復原（true|false），預設為true

時間戳

wipeWritePerm 

com.alibaba.rocketmq.tools.command.namesrv.WipeWritePermSubCommand

broker 位址

該指令隻列印目前與cluster 連接配接的consumer 的消費進度

getConsumerStatus

com.alibaba.rocketmq.tools.command.offset.GetConsumerStatusCommand

查詢主題

Consumer 用戶端ip

分類: 專題__rocketmq