15 RocketMQ 常用命令实战¶

本篇整理 RocketMQ 集群运维中常用的管理命令，并说明各参数和输出字段的含义。示例命令基于 RocketMQ 4.7.0，实际输出可能因版本和集群配置而有所不同。

集群命令汇总¶

集群列表¶

使用 clusterList 查看集群节点、主从角色以及各节点的写入和读取 TPS：

命令示例：

bin/mqadmin clusterList -n x.x.x.x:9876
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
#Cluster Name     #Broker Name            #BID  #Addr                  #Version                #InTPS(LOAD)       #OutTPS(LOAD) #PCWait(ms) #Hour #SPACE
fat_mq            fat_mq_c                0     x.x.x.x:10911    V4_7_0                 262.95(0,0ms)       259.85(0,0ms)          0 55.09 0.3130

字段含义：

名称	含义
`-n`	NameServer 地址
`Cluster Name`	集群名称
`Broker Name`	节点 Broker 名称
`BID`	Broker ID （0 为主节点，从节点非 0 表示）
`Addr`	节点地址（ip:port）
`Version`	RocketMQ 的版本号
`InTPS`	节点每秒写入的消息数量
`OutTPS`	节点每秒读出的消息数量
`PCWait`	pageCacheLockTimeMills（消息落盘时的加锁耗时）
`Hour`	磁盘存储多久的有效消息（当前时间与磁盘存储最早的一条消息时间戳的差值）
`SPACE`	磁盘已使用的占比

集群中资源吞吐¶

使用 statsAll 查看集群中各主题和消费组的实时吞吐情况：

bin/mqadmin statsAll -n x.x.x.x:9876
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
#Topic                            #Consumer Group                  #Accumulation      #InTPS     #OutTPS   #InMsg24Hour  #OutMsg24Hour
trade_eticket_created_topic       trade_eticket_created_consumer              0        0.00        0.00              0              0

字段含义：

名称	含义
`-n`	NameServer 地址
`-a`	只打印活动的主题
`-t`	只打印指定的主题
`Topic`	主题名称
`Consumer Group`	消费组名称
`Accumulation`	消息堆积数量
`InTPS`	该主题每秒写入的消息数量
`OutTPS`	该消费组每秒消费的消息数量
`InMsg24Hour`	该主题 24 小时写入的消息总数
`OutMsg24Hour`	该消费组 24 小时消费的消息总数

主题命令汇总¶

主题列表¶

使用 topicList 列出集群中的所有主题：

命令示例：

bin/mqadmin topicList -n x.x.x.x:9876
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
mq_demo1_topic
mq_demo1_topic
mq_demo2_topic
...

字段含义：

名称	含义
`-n`	NameServer 地址

主题创建/修改¶

使用 updateTopic 创建主题，也可以修改主题的队列数量、权限等配置：

命令示例：

bin/mqadmin updateTopic -n x.x.x.x:9876 -c fat_mq -t mq_demo_topic
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
create topic to x.x.x.x:10911 success.
TopicConfig [topicName=mq_demo_topic, readQueueNums=8, writeQueueNums=8, perm=RW-, topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]

字段含义：

名称	含义
`-n`	NameServer 地址
`-c`	集群名称
`-t`	要创建的 Topic 名称
`topicName`	主题名称
`readQueueNums`	读队列数量
`writeQueueNums`	写队列数量
`perm`	主题权限 RW 表示该主题拥有读写权限
`topicFilterType`	消息过滤类型
`topicSysFlag`	主题系统标记
`order`	是否有序主题

主题路由¶

使用 topicRoute 查看 Topic 的路由信息，包括队列所在的 Broker 及其所属集群：

命令示例：

bin/mqadmin topicRoute -n x.x.x.x:9876 -t mq_demo_topic
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
{
  "brokerDatas": [
    {
      "brokerAddrs": { "0": "x.x.x.x:10911" },
      "brokerName": "fat_mq_c",
      "cluster": "fat_mq"
    }
  ],
  "filterServerTable": {},
  "queueDatas": [
    {
      "brokerName": "fat_mq_c",
      "perm": 6,
      "readQueueNums": 8,
      "topicSynFlag": 0,
      "writeQueueNums": 8
    }
  ]
}

字段含义：

名称	含义
`-n`	NameServer 地址
`-t`	主题名称
`brokerDatas`	broker 信息地址、节点名称、所在集群
`queueDatas`	队列数量、队列所在的 broker、权限等

主题状态¶

使用 topicStatus 查看主题状态，包括最小偏移量、最大偏移量和最新更新时间：

命令示例：

bin/mqadmin topicStatus -n x.x.x.x:9876 -t mq_demo_topic
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
# Broker Name                      #QID  #Min Offset           #Max Offset             #Last Updated
fat_mq_c                          0     6                     10                      2020-07-24 14:29:57,707
fat_mq_c                          1     4                     8                       2020-07-24 14:31:32,213
fat_mq_c                          2     20                    22                      2020-07-24 14:35:52,752
fat_mq_c                          3     14                    20                      2020-07-24 14:28:34,287

字段含义：

名称	含义
`-n`	NameServer 地址
`-t`	主题名称
`Broker Name`	节点名称
`QID`	Queue ID 队列编号
`Min Offset`	该队列最小偏移量
`Max Offset`	该队列最大偏移量
`Last Updated`	最新写入消息的时间戳

主题权限¶

使用 updateTopicPerm 修改主题权限：写权限为 2、读权限为 4、读写权限为 6。下面将主题从读写权限改为写权限：

命令示例：

bin/mqadmin updateTopicPerm -c fat_mq -t mq_demo_topic -p 2 -n x.x.x.x:9876
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
update topic perm from 6 to 2 in x.x.x.x:10911 success.

字段含义：

名称	含义
`-c`	集群名称
`-t`	主题名称
`-p`	权限（2:W，4:R，6:WR）
`-n`	NameServer 地址

主题删除¶

使用 deleteTopic 删除不再使用的主题：

命令示例：

bin/mqadmin deleteTopic -n x.x.x.x:9876 -t mq_demo_topic -c fat_mq
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
delete topic [mq_demo_topic] from cluster [fat_mq] success.
delete topic [mq_demo_topic] from NameServer success.

字段含义：

名称	含义
`-n`	NameServer 地址
`-t`	主题名称
`-c`	集群名称

消费组命令汇总¶

消费组创建¶

使用 updateSubGroup 创建消费组，成功后会返回消费组配置：

命令示例：

bin/mqadmin updateSubGroup -n x.x.x.x:9876 -c fat_mq -g mq_demo_consumer
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
create subscription group to x.x.x.x:10911 success.
SubscriptionGroupConfig [groupName=mq_demo_consumer, consumeEnable=true, consumeFromMinEnable=false, consumeBroadcastEnable=false, retryQueueNums=1, retryMaxTimes=16, brokerId=0, whichBrokerWhenConsumeSlowly=1, notifyConsumerIdsChangedEnable=true]

字段含义：

名称	含义
`-n`	NameServer 地址
`-c`	集群名称
`-g`	消费组名称
`groupName`	消费组名称
`consumeEnable`	是否开启消费，默认开启
`consumeFromMinEnable`	是否从最小位点消费，默认 false
`consumeBroadcastEnable`	是否开启广播消费，默认 false
`retryQueueNums`	重试队列数量，默认为 1
`retryMaxTimes`	消费重试次数，默认 16 次
`brokerId`	消费组所在的 brokerId
`whichBrokerWhenConsumeSlowly`	当 Master 节点消费慢时，默认在从节点 ID 为 1 的 broker 消费

消费者状态¶

使用 consumerStatus 查看消费者状态，包括客户端版本和消费组名称：

命令示例：

bin/mqadmin consumerStatus -g mq_demo_consumer -n x.x.x.x:9876
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
001  root@ V4_7_0               1595768036031/root@
002  root@ V4_7_0               1595768036031/root@

字段含义：

名称	含义
`-g`	消费组名称
`-n`	NameServer 地址
`输出第一列`	第几个消费者
`输出第二列`	clientId
`输出第三列`	该消费者使用的客户端 RocketMQ 版本
`输出第四列`	文件路径（filePath），该文件记录了消费者详细信息

消费组进度¶

使用 consumerProgress 查看消费组在各订阅 Queue 上的消费进度：

命令示例：

bin/mqadmin consumerProgress -g pglog_rmq_t_biz_extend_synchbase_consumer -n x.x.x.x:9876
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
# Topic                            #Broker Name                      #QID  #Broker Offset        #Consumer Offset      #Client IP           #Diff                 #LastTime
pglog_rmq_t_biz_extend            disaster_mq_a                     0     17227343              17227343              N/A                  0                     2020-07-26 21:09:30
pglog_rmq_t_biz_extend            disaster_mq_a                     1     16588873              16588873              N/A                  0                     2020-07-26 21:09:30
pglog_rmq_t_biz_extend            disaster_mq_a                     2     12053429              12053429              N/A                  0                     2020-07-26 21:09:35
...
Consume TPS: 3.98
Diff Total: 6

字段含义：

名称	含义
`-g`	消费组名称
`-n`	NameServer 地址
`Topic`	订阅的主题
`Broker Name`	订阅主题所在的 Broker
`QID`	订阅主题的 Queue ID
`Broker Offset`	该 Queue 存储的消息偏移量
`Consumer Offset`	该 Queue 消费的消息偏移量
`Diff`	消息堆积情况
`LastTime`	上次消费消息的时间
`Consume TPS`	每秒钟消费消息的数量
`Diff Total`	消息堆积总数

消息回溯¶

使用 resetOffsetByTime 将消费组位点重置到指定时间，从该时间点重新消费：

命令示例：

bin/mqadmin resetOffsetByTime -n x.x.x.x:9876 -g melon_consumer_0010 -t melon_test_0010 -s now
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
rollback consumer offset by specified group[melon_consumer_0010], topic[melon_test_0010], force[true], timestamp[string](now), timestamp[long](1595900214141)
# brokerName                               #queueId                                  #offset
dev_mq_b                                  5                                         281499
dev_mq_b                                  3                                         285922
dev_mq_d                                  5                                         12335
dev_mq_b                                  4                                         286157
dev_mq_b                                  1                                         279566
dev_mq_d                                  3                                         12336
dev_mq_b                                  2                                         281142
dev_mq_d                                  4                                         12333
dev_mq_d                                  1                                         12335
dev_mq_b                                  0                                         282808
dev_mq_d                                  2                                         12338
dev_mq_d                                  0                                         12343

字段含义：

名称	含义
`-n`	NameServer 地址
`-g`	消费组名称
`-t`	消费组订阅的主题名称
`-s`	回溯的时间戳（例如：1595815028792，now 表示当前时间）
`brokerName`	节点名称
`queueId`	队列 ID
`offset`	回溯后该队列消费的偏移量

Broker 命令汇总¶

Broker 状态¶

使用 brokerStatus 查看 Broker 的启动时间、版本、吞吐和磁盘等运行信息：

命令示例：

bin/mqadmin brokerStatus -b x.x.x.x:10911 -n x.x.x.x:9876
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
EndTransactionQueueSize         : 0
EndTransactionThreadPoolQueueCapacity: 100000
bootTimestamp                   : 1591673160936
brokerVersion                   : 353
brokerVersionDesc               : V4_7_0
commitLogDirCapacity            : Total : 98.3 GiB, Free : 93.5 GiB.
commitLogDiskRatio              : 0.04929098258492175
commitLogMaxOffset              : 3473383494
commitLogMinOffset              : 2147483648
consumeQueueDiskRatio           : 0.04929098258492175
dispatchBehindBytes             : 0
dispatchMaxBuffer               : 0
earliestMessageTimeStamp        : 1595621861014
getFoundTps                     : 0.0 0.0 0.0
getMessageEntireTimeMax         : 290
getMissTps                      : 786.5213478652134 783.8549478385495 783.5753864100321
getTotalTps                     : 786.5213478652134 783.8549478385495 783.5753864100321
getTransferedTps                : 0.0 0.0 0.0
msgGetTotalTodayMorning         : 2713099
msgGetTotalTodayNow             : 2713131
msgGetTotalYesterdayMorning     : 1478152
msgPutTotalTodayMorning         : 9303513
msgPutTotalTodayNow             : 9336203
msgPutTotalYesterdayMorning     : 6247199
pageCacheLockTimeMills          : 0
pullThreadPoolQueueCapacity     : 100000
pullThreadPoolQueueHeadWaitTimeMills: 0
pullThreadPoolQueueSize         : 0
putMessageAverageSize           : 326.0440501347282
putMessageDistributeTime        : [<=0ms]:11 [0~10ms]:0 [10~50ms]:0 [50~100ms]:0 [100~200ms]:0 [200~500ms]:0 [500ms~1s]:0 [1~2s]:0 [2~3s]:0 [3~4s]:0 [4~5s]:0 [5~10s]:0 [10s~]:0
putMessageEntireTimeMax         : 930
putMessageSizeTotal             : 3044013439
putMessageTimesTotal            : 9336203
putTps                          : 0.9999000099990001 0.9999000099990001 0.999875015623047
queryThreadPoolQueueCapacity    : 20000
queryThreadPoolQueueHeadWaitTimeMills: 0
queryThreadPoolQueueSize        : 0
remainHowManyDataToCommit       : 0 B
remainHowManyDataToFlush        : 1.1 KiB
remainTransientStoreBufferNumbs : 3
runtime                         : [ 49 days, 21 hours, 38 minutes, 12 seconds ]
scheduleMessageOffset_1         : 2024,2024
scheduleMessageOffset_10        : 1035,1035
scheduleMessageOffset_11        : 885,885
scheduleMessageOffset_12        : 879,879
scheduleMessageOffset_13        : 889,889
scheduleMessageOffset_14        : 640349,640349
scheduleMessageOffset_15        : 848,848
scheduleMessageOffset_16        : 851,851
scheduleMessageOffset_17        : 870,870
scheduleMessageOffset_18        : 1288,1288
scheduleMessageOffset_2         : 1243954,1243954
scheduleMessageOffset_3         : 13682,13682
scheduleMessageOffset_4         : 5965,5965
scheduleMessageOffset_5         : 5134,5134
scheduleMessageOffset_6         : 4741,4741
scheduleMessageOffset_7         : 13475,13475
scheduleMessageOffset_8         : 2530,2530
scheduleMessageOffset_9         : 2270,2270
sendThreadPoolQueueCapacity     : 10000
sendThreadPoolQueueHeadWaitTimeMills: 0
sendThreadPoolQueueSize         : 0
startAcceptSendRequestTimeStamp : 0

字段含义：

名称	含义
`-b`	Broker 的 IP 地址
`-n`	NameServer 地址
`EndTransactionQueueSize`	END_TRANSACTION 的线程池请求数
`EndTransactionThreadPoolQueueCapacity`	END_TRANSACTION 线程池大小，默认 100000
`bootTimestamp`	Broker 启动时间
`brokerVersion`	Broker 版本
`brokerVersionDesc`	Broker 版本描述
`commitLogDirCapacity`	commitLog 目录磁盘使用情况
`commitLogDiskRatio`	commitLog 目录磁盘使用百分比
`commitLogMaxOffset`	commitLog 最大偏移量
`commitLogMinOffset`	commitLog 最小偏移量
`dispatchBehindBytes`	已在 commit log 中存储未转发到 consume queue 的数据（单位字节）
`dispatchMaxBuffer`	可忽略未被使用
`earliestMessageTimeStamp`	存储最早消息的时间戳
`getFoundTps`	拉取时被找到的消息 TPS 统计，分别表示前 10s、1 分钟、10 分钟平均 TPS
`getMessageEntireTimeMax`	查找单条消息的最大耗时
`getMissTps`	拉取时未被找到的消息 TPS 统计，分别表示前 10s、1 分钟、10 分钟平均 TPS
`getTotalTps`	拉取时总的消息 TPS 统计，分别表示前 10s、1 分钟、10 分钟平均 TPS
`getTransferedTps`	向拉取方传输消息 TPS 统计，分别表示前 10s、1 分钟、10 分钟平均 TPS
`msgGetTotalTodayMorning`	截止今天凌晨 12 点从该 broker 拉取的消息总数
`msgGetTotalTodayNow`	截止当前时间从该 broker 拉取的消息总数
`msgGetTotalYesterdayMorning`	截止昨天凌晨 12 点从该 broker 拉取的消息总数
`msgPutTotalTodayMorning`	截止今天凌晨 12 点从该 broker 写入的消息总数
`msgPutTotalTodayNow`	截止当前时间从该 broker 写入的消息总数
`msgPutTotalYesterdayMorning`	截止昨天凌晨 12 点从该 broker 写入的消息总数
`pageCacheLockTimeMills`	消息存储时的加锁耗时
`pullThreadPoolQueueCapacity`	拉取线程池队列初始容量，默认为 100000
`pullThreadPoolQueueHeadWaitTimeMills`	队列头部第一个任务从创建到现在一直未被执行的时间，即：队列第一个任务等待时间
`pullThreadPoolQueueSize`	拉取线程池队列当前任务数量
`putMessageAverageSize`	写入消息的平均大小
`putMessageDistributeTime`	消息存储的耗时分布情况。例如：[<=0ms]:11 指存储时小于等于 0ms 的有 11 条消息
`putMessageEntireTimeMax`	消息存储的最大耗时
`putMessageSizeTotal`	存储消息的总大小
`putMessageTimesTotal`	存储消息的总条数
`putTps`	统计 10 秒、1 分钟、10 分钟写入平均 TPS
`queryThreadPoolQueueCapacity`	查询线程池队列初始容量，默认为 20000
`queryThreadPoolQueueHeadWaitTimeMills`	队列头部第一个任务从创建到现在一直未被执行的时间，即：队列第一个任务等待时间
`queryThreadPoolQueueSize`	查询线程池队列当前任务数量
`remainHowManyDataToCommit`	剩余多少数据未被写入到 fileChannel
`remainHowManyDataToFlush`	剩余多少数据未被刷到磁盘
`remainTransientStoreBufferNumbs`	堆外可用缓存区数量，初始大小为 5，每个大小 1G，为在开启堆外内存传输时有效
`runtime`	该 broker 运行了多久了
`scheduleMessageOffset_1`	SCHEDULE_TOPIC_XXXX 第 1 个 Queue 的最大偏移量（注：延迟消息存储在名字为 SCHEDULE_TOPIC_XXXX 的 topic 中）
`scheduleMessageOffset_10`	SCHEDULE_TOPIC_XXXX 第 10 个 Queue 的最大偏移量
`scheduleMessageOffset_11`	SCHEDULE_TOPIC_XXXX 第 11 个 Queue 的最大偏移量
`scheduleMessageOffset_12`	SCHEDULE_TOPIC_XXXX 第 12 个 Queue 的最大偏移量
`scheduleMessageOffset_13`	SCHEDULE_TOPIC_XXXX 第 13 个 Queue 的最大偏移量
`scheduleMessageOffset_14`	SCHEDULE_TOPIC_XXXX 第 14 个 Queue 的最大偏移量
`scheduleMessageOffset_15`	SCHEDULE_TOPIC_XXXX 第 15 个 Queue 的最大偏移量
`scheduleMessageOffset_16`	SCHEDULE_TOPIC_XXXX 第 16 个 Queue 的最大偏移量
`scheduleMessageOffset_17`	SCHEDULE_TOPIC_XXXX 第 17 个 Queue 的最大偏移量
`scheduleMessageOffset_18`	SCHEDULE_TOPIC_XXXX 第 18 个 Queue 的最大偏移量
`scheduleMessageOffset_2`	SCHEDULE_TOPIC_XXXX 第 2 个 Queue 的最大偏移量
`scheduleMessageOffset_3`	SCHEDULE_TOPIC_XXXX 第 3 个 Queue 的最大偏移量
`scheduleMessageOffset_4`	SCHEDULE_TOPIC_XXXX 第 4 个 Queue 的最大偏移量
`scheduleMessageOffset_5`	SCHEDULE_TOPIC_XXXX 第 5 个 Queue 的最大偏移量
`scheduleMessageOffset_6`	SCHEDULE_TOPIC_XXXX 第 6 个 Queue 的最大偏移量
`scheduleMessageOffset_7`	SCHEDULE_TOPIC_XXXX 第 7 个 Queue 的最大偏移量
`scheduleMessageOffset_8`	SCHEDULE_TOPIC_XXXX 第 8 个 Queue 的最大偏移量
`scheduleMessageOffset_9`	SCHEDULE_TOPIC_XXXX 第 9 个 Queue 的最大偏移量
`sendThreadPoolQueueCapacity`	发送线程池队列初始容量，默认为 10000
`sendThreadPoolQueueHeadWaitTimeMills`	队列头部第一个任务从创建到现在一直未被执行的时间，即：队列第一个任务等待时间
`sendThreadPoolQueueSize`	发送线程池队列当前任务数量
`startAcceptSendRequestTimeStamp`	可以配置在指定的时间 broker 接受客户端发送请求，默认启动后则接受发送请求

Broker 配置查询¶

使用 getBrokerConfig 获取 Broker 配置，下面仅展示命令和部分输出：

命令示例：

bin/mqadmin getBrokerConfig -b  x.x.x.x:10911 -n x.x.x.x:9876
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
============x.x.x.x:10911============
serverSelectorThreads                             =  3
brokerRole                                        =  ASYNC_MASTER
serverSocketRcvBufSize                            =  131072
osPageCacheBusyTimeOutMills                       =  1000
shortPollingTimeMills                             =  1000
clientSocketRcvBufSize                            =  131072
clusterTopicEnable                                =  true
brokerTopicEnable                                 =  true
autoCreateTopicEnable                             =  true
maxErrorRateOfBloomFilter                         =  20
maxMsgsNumBatch                                   =  64
cleanResourceInterval                             =  10000
...

Broker 配置更新¶

使用 updateBrokerConfig 热更新 Broker 配置，通常即时生效，无需重启 Broker 节点：

命令示例：

bin/mqadmin updateBrokerConfig -b x.x.x.x:10911 -n dev-mq1.ttbike.com.cn:9876 -k slaveReadEnable -v true
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
update broker config success, x.x.x.x:10911

字段含义：

名称	含义
`-b`	Broker 地址
`-n`	NameServer 地址
`-k`	需更新的配置的 key
`-v`	需更新配置 key 对应的值

Broker 发送消息¶

使用 sendMsgStatus 向指定 Broker 发送测试消息，检查 Broker 是否正常：

命令示例：

bin/mqadmin sendMsgStatus -b dev_mq_d -n x.x.x.x:9876
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
rt:2ms, SendResult=SendResult [sendStatus=SEND_OK, msgId=0A6F4B60457D5ACF98009C90AD2C0001, offsetMsgId=0A6F4B6000002AC100000000D0B7A942, messageQueue=MessageQueue [topic=dev_mq_d, brokerName=dev_mq_d, queueId=0], queueOffset=4486548]rt:2ms,...

字段含义：

名称	含义
`-b`	Broker 名称
`-n`	NameServer 地址
`-c`	指定发送消息数量，默认 50 条
`-s`	指定发送消息体大小，默认 128k

消息命令汇总¶

打印主题消息¶

使用 printMsg 打印主题中的消息：

命令示例：

$ bin/mqadmin printMsg -d true -n x.x.x.x:9876 -t melon_dev_test
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_b, queueId=2]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_d, queueId=4]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_b, queueId=4]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_d, queueId=6]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_b, queueId=6]minOffset=0, maxOffset=1, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_d, queueId=8]MessageQueue [topic=melon_dev_test, brokerName=dev_mq_d, queueId=8] no matched msg. status=NO_MATCHED_MSG, offset=1minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_b, queueId=8]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_d, queueId=10]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_d, queueId=0]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_b, queueId=0]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_d, queueId=2]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_b, queueId=10]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_d, queueId=12]minOffset=0, maxOffset=0, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_b, queueId=12]minOffset=0, maxOffset=1, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_d, queueId=14]MessageQueue [topic=melon_dev_test, brokerName=dev_mq_d, queueId=14] no matched msg. status=NO_MATCHED_MSG, offset=1minOffset=0, maxOffset=2, MessageQueue [topic=melon_dev_test, brokerName=dev_mq_b, queueId=14]MSGID: 0A6F4BA1743E7BA18F1B9F54E2210028 MessageExt [brokerName=dev_mq_b, queueId=14, storeSize=225, queueOffset=1, sysFlag=0, bornTimestamp=1596205940257, bornHost=/10.111.75.161:42806, storeTimestamp=1596205940257, storeHost=/10.111.75.95:10911, msgId=0A6F4B5F00002A9F000000138873E059, commitLogOffset=83893674073, bodyCRC=1649915861, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message{topic='melon_dev_test', flag=0, properties={MIN_OFFSET=0, uber-trace-id=7617a5ff2fa5bf68%3A7617a5ff2fa5bf68%3A0%3A0, MAX_OFFSET=2, UNIQ_KEY=0A6F4BA1743E7BA18F1B9F54E2210028, WAIT=true}, body=[104, 101, 108, 108, 111, 32, 98, 97, 98, 121], transactionId='null'}] BODY: hello baby

字段含义：

名称	含义
`-d`	是否打印消息体，默认 false
`-n`	NameServer 地址
`-t`	主题名称
`-b`	开始时间戳，格式为 currentTimeMillis\|yyyy-MM-dd#HHss:SSS
`-c`	字符编码，默认 UTF-8
`-e`	结束时间戳，格式为 currentTimeMillis\|yyyy-MM-dd#HHss:SSS
`-s`	订阅的 tag，默认为全部（*），格式 TagA \|\| TagB

通过 MsgId 检索消息¶

使用 queryMsgById 根据消息 ID 检索集群中的消息：

命令示例：

bin/mqadmin queryMsgById -n x.x.x.x:9876 -i 0A6F4B5F00002A9F000000138873E059
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
OffsetID:            0A6F4B5F00002A9F000000138873E059
Topic:               melon_dev_test
Tags:                [null]
Keys:                [null]
Queue ID:            14
Queue Offset:        1
CommitLog Offset:    83893674073
Reconsume Times:     0
Born Timestamp:      2020-07-31 22:32:20,257
Store Timestamp:     2020-07-31 22:32:20,257
Born Host:           x.x.x.x:42806
Store Host:          x.x.x.x:10911
System Flag:         0
Properties:          {uber-trace-id=7617a5ff2fa5bf68%3A7617a5ff2fa5bf68%3A0%3A0, UNIQ_KEY=0A6F4BA1743E7BA18F1B9F54E2210028, WAIT=true}
Message Body Path:   /tmp/rocketmq/msgbodys/0A6F4BA1743E7BA18F1B9F54E2210028
MessageTrack [consumerGroup=melon_dev_consumer, trackType=NOT_ONLINE, exceptionDesc=CODE:206 DESC:the consumer group[melon_dev_consumer] not online]

字段含义：

名称	含义
`-n`	NameServer 地址
`-i`	消息 ID
`OffsetID`	消息 ID
`Topic`	主题名称
`Tags`	消息的 TAG
`Keys`	发送消息的 key
`Queue ID`	消息存储的 Queue
`Queue Offset`	消息在 Queue 中的偏移量
`CommitLog Offset`	消息在 commitLog 文件中的偏移量
`Reconsume Times`	重新消费的次数
`Born Timestamp`	消息诞生的时间戳
`Store Timestamp`	消息存储的时间戳
`Born Host`	发送消息的 IP 地址
`Store Host`	消息存储的 IP 地址
`System Flag`	标志信息
`Properties`	属性信息
`Message Body Path`	消息体存储路径
`MessageTrack`	消费情况

通过 Key 检索消息¶

使用 queryMsgByKey 根据消息 Key 检索消息：

命令示例：

bin/mqadmin queryMsgByKey -n x.x.x.x:9876 -t melon_dev_test -k orderNo1
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
# Message ID                                        #QID                                  #Offset
0A6F4BA1743E7BA18F1B022183DA002B                      2                                        0

字段含义：

名称	含义
`-n`	NameServer 地址
`-t`	主题名称
`-k`	消息 key
`Message ID`	消息 ID
`QID`	消息存储的 Queue
`Offset`	消息在 Queue 的偏移量

根据 Offset 检索消息¶

消息存储在 Broker 的 Queue 中，也可以通过 offset 检索消息：

命令示例：

bin/mqadmin queryMsgByOffset -n x.x.x.x:9876 -t melon_dev_test -b dev_mq_b -i 2 -o 0
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
OffsetID:            0A6F4B5F00002A9F00000013A37FED85
Topic:               melon_dev_test
Tags:                [null]
Keys:                [orderNo1]
Queue ID:            2
Queue Offset:        0
CommitLog Offset:    84347448709
Reconsume Times:     0
Born Timestamp:      2020-08-01 09:55:50,874
Store Timestamp:     2020-08-01 09:55:50,875
Born Host:           x.x.x.x:42806
Store Host:          x.x.x.x:10911
System Flag:         0
Properties:          {MIN_OFFSET=0, uber-trace-id=74e72c15f101da93%3A74e72c15f101da93%3A0%3A0, MAX_OFFSET=1, KEYS=orderNo1, UNIQ_KEY=0A6F4BA1743E7BA18F1B022183DA002B, WAIT=true}
Message Body Path:   /tmp/rocketmq/msgbodys/0A6F4BA1743E7BA18F1B022183DA002B

字段含义：

名称	含义
`-n`	NameServer 地址
`-t`	主题
`-b`	Broker 名字
`-i`	Queue ID
`-o`	偏移量 offset
`OffsetID`	消息 ID
`Topic`	主题名称
`Tags`	消息的 TAG
`Keys`	消息 KEY
`Queue ID`	消息存储的 Queue
`Queue Offset`	消息在 Queue 中的偏移量
`CommitLog Offset`	消息在 commitLog 文件中的偏移量
`Reconsume Times`	重新消费的次数
`Born Timestamp`	消息诞生的时间戳
`Store Timestamp`	消息存储的时间戳
`Born Host`	发送消息的 IP 地址
`System Flag`	标志信息
`Properties`	属性信息
`Message Body Path`	消息体存储路径
`MessageTrack`	消费情况

根据 UniqueKey 检索消息¶

使用 queryMsgByUniqueKey 根据 UniqueKey 检索消息：

命令示例：

$ bin/mqadmin queryMsgByUniqueKey -n dev-mq1.ttbike.com.cn:9876  -t melon_dev_test -i 0A6F4BA1743E7BA18F1B022183DA002B
RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
RocketMQLog:WARN Please initialize the logger system properly.
Topic:               melon_dev_test
Tags:                [null]
Keys:                [orderNo1]
Queue ID:            2
Queue Offset:        0
CommitLog Offset:    84347448709
Reconsume Times:     0
Born Timestamp:      2020-08-01 09:55:50,874
Store Timestamp:     2020-08-01 09:55:50,875
Born Host:           x.x.x.x:42806
Store Host:          x.x.x.x:10911
System Flag:         0
Properties:          {uber-trace-id=74e72c15f101da93%3A74e72c15f101da93%3A0%3A0, KEYS=orderNo1, UNIQ_KEY=0A6F4BA1743E7BA18F1B022183DA002B, WAIT=true}
Message Body Path:   /tmp/rocketmq/msgbodys/0A6F4BA1743E7BA18F1B022183DA002B

UniqueKey 命令的输出字段与前述消息查询命令相同。