2.5. 查看Topic统计信息
指令 参数 -t -h -n 举例 topicStatus 类路径 com.alibaba.rocketmq.tools.command.topic.TopicStatsSubCommand 是否必填 是 否 说明 topic名称 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;... 是 查看主题testTopic的统计信息 sh mqadmin topicStatus -n 127.0.0.1:9876 -t testTopic 打印内容： （统计信息里包括有offset、最后更新时间） #Broker Name #QID #Min Offset #Max Offset #Last Updated master.com 0 0 0 master.com 1 0 0 master.com 2 0 0 master.com 3 0 0 master.com 4 0 0 master.com 5 0 0 master.com 6 0 0 master.com 7 0 0 第6/20页
2.6. 创建（修订）订阅组
指令 updateSubGroup 类路径 com.alibaba.rocketmq.tools.command.consumer.UpdateSubGroupSubCommand 参数 -b -c 是否必填 如果–c为空，则必填 如果–b为空，则必填 说明 broker地址，表示订阅组建在该broker cluster名称，表示topic建在该集群（集群可通过clusterList查询） -d -g -i -m -q -r -s -w 否 是 否 否 否 否 否 否 是否容许广播方式消费 订阅组名 从哪个broker开始消费 从最小offset消费，默认为false 是否为消费失败的消息设置重试队列 重试最大次数，超过则投递到死信队列，并报警 消费功能是否开启，默认为true 如果消息堆积，将Consumer的消费请求重定向到另外一台Slave机器 -h -n 举例 否 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;... 是 创建订阅ID为testGroup的订阅组 sh mqadmin updateSubGroup -c DefaultCluster -g testGroup -s true -n 127.0.0.1:9876 打印内容: create subscription group to 127.0.0.1:10911 success. SubscriptionGroupConfig [groupName=testGroup, consumeEnable=true, consumeFromMinEnable=false, consumeBroadcastEnable=false,retryQueueNums=1,retryMaxTimes=16,brokerId=0, whichBrokerWhenConsumeSlowly=1]
第7/20页
2.7. 删除订阅组配置
指令 deleteSubGroup 类路径 com.alibaba.rocketmq.tools.command.consumer.DeleteSubscriptionGroupCommand 参数 -b -c 是否必填 如果–c为空，则必填 如果–b为空，则必填 说明 broker地址，表示订阅组建在该broker cluster名称，表示topic建在该集群（集群可通过clusterList查询） -g -h -n 举例 是 否 订阅组名 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;... 是 删除testGroup订阅组 sh mqadmin deleteSubGroup -c DefaultCluster -g testGroup -n 127.0.0.1:9876 2.8. 克隆订阅组配置 指令 cloneGroupOffset 类路径 com.alibaba.rocketmq.tools.command.offset.CloneGroupOffsetCommand 参数 -d -h -o -n -s -t 举例 是否必填 是 否 否 是 是 说明 目标订阅组名称 打印帮助 订阅组或主题是否offline nameserve服务地址列表，格式ip:port;ip:port;... 源订阅组名称 Topic名 是 克隆testGroup在testTopic的offset到destGroup sh mqadmin cloneGroupOffset -d destGroup -s testGroup –t testTopic -n 127.0.0.1:9876
第8/20页
2.9. 更新Broker配置文件
指令 updateBrokerConfig 类路径 com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand 参数 -b -c 是否必填 说明 如果–c为空，则必填 broker地址，表示订阅组建在该broker 如果–b为空，则必填 cluster名称，表示topic建在该集群（集群可通过clusterList查询） -k -v -h -n 举例 是 key值 value值 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;... 是 否 是 2.10. 查看Broker统计信息 指令 brokerStatus 类路径 com.alibaba.rocketmq.tools.command.broker.BrokerStatsSubCommand 参数 -b -h -n 举例 是否必填 是 否 说明 broker地址 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;... 是 查看broker的统计信息，broker地址为127.0.0.1:10911,nameserve地址为127.0.0.1:9876 sh mqadmin brokerStatus -b 127.0.0.1:10911 -n 127.0.0.1:9876 打印内容： bootTimestamp : 1467954121891 第9/20页
brokerVersion : 79 brokerVersionDesc : V3_2_6 commitLogDiskRatio : 0.22073348815557767 commitLogMaxOffset : 396647377842 commitLogMinOffset : 396210733056 consumeQueueDiskRatio : 0.22073348815557767 dispatchMaxBuffer : 116 getFoundTps : 0.0 0.0 0.10165497634438707 getMessageEntireTimeMax : 3672 getMissTps : 10.997800439912016 11.998600163314281 11.635328603877221 getTotalTps : 10.997800439912016 11.998600163314281 11.736983580221608 getTransferedTps : 0.0 0.0 0.10165497634438707 msgGetTotalTodayMorning : 172482921 msgGetTotalTodayNow : 172489262 msgGetTotalYesterdayMorning : 172471291 msgPutTotalTodayMorning : 55824427 msgPutTotalTodayNow : 55824473 msgPutTotalYesterdayMorning : 55823918 putMessageAverageSize : 249.72349424597346 putMessageDistributeTime : 53470869(95.783920790439%) 2353266(4.215473740343236%) 34(6.0905187586813406E-5%) 298(5.338160559079527E-4%) 2(3.5826580933419645E-6%) 4(7.165316186683929E-6%) 0(0.0%) putMessageEntireTimeMax : 1715 putMessageSizeTotal : 13940682462 第10/20页