RocketMQ运维指令
目录
1. 控制台使用 ....................................................................................................................... 2 2. 详细命令 ........................................................................................................................... 3
2.1. 2.2. 2.3. 2.4. 2.5. 2.6. 2.7. 2.8. 2.9. 2.10. 2.11. 2.12. 2.13. 2.14. 2.15. 2.16. 2.17. 2.18. 2.19. 2.20. 2.21. 2.22.
创建Topic ..................................................................................................................... 3 删除Topic ..................................................................................................................... 4 查看Topic列表信息 .................................................................................................... 4 查看Topic路由信息 .................................................................................................... 5 查看Topic统计信息 .................................................................................................... 6 创建（修订）订阅组 ................................................................................................... 7 删除订阅组配置 ........................................................................................................... 8 克隆订阅组配置 ........................................................................................................... 8 更新Broker配置文件 .................................................................................................. 9 查看Broker统计信息 .............................................................................................. 9 根据消息ID查询消息 ........................................................................................... 12 根据消息Key查询消息 ........................................................................................ 13 根据Offset查询消息 ............................................................................................. 14 查询Producer的网络连接 .................................................................................... 15 查询Consumer的网络连接 .................................................................................. 15 查看订阅组消费状态 ............................................................................................. 16 查看集群消息 ......................................................................................................... 17 添加（更新）KV配置信息 .................................................................................. 18 删除KV配置信息 ................................................................................................. 18 设置消费进度 ......................................................................................................... 19 获取Consumer消费进度 ...................................................................................... 20 清除特定Broker权限 ............................................................................................ 20
第1/20页
1. 控制台使用
RocketMQ提供控制台命令，用于管理员对Topic，Cluster，Broker等信息的管理； ? 控制台：
进入RocketMQ安装目录下/bin目录，该目录下mqadmin脚本即为控制台； ? 查看指令集：
sh mqadmin
? 查看指令的使用方式
sh mqadmin help 指令名称 例如查看topicStatus的使用 sh mqadmin help topicStatus
usage: mqadmin topicStatus [-h] [-n ] -t -h,--help
Print help
Name server address list, 127.0.0.1:9876;127.0.0.2:9876 Topic name
-n,--namesrvAddr -t,--topic
第2/20页
2. 详细命令
2.1. 创建Topic
指令 updateTopic 类路径 com.alibaba.rocketmq.tools.command.topic.UpdateTopicSubCommand 参数 -b 是否必填 如果 -c为空，则必填 如果 -b为空，则必填 说明 broker地址，表示topic建在该broker cluster名称，表示topic建在该集群，cluster通过clusterList查询 -c -h -n -p -r -w -t -s -u 举例 否 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;... 指定权限(2|4|6), intro[2:R; 4:W; 6:RW] 可读队列数（默认为8） 可写队列数（默认为8） topic名称（名称只能使用字符 ^[a-zA-Z0-9_-]+$ ） Hasunitsub (true|false) Is unit topic (true|false) 是 否 否 否 是 否 否 在集群DefaultCluster上创建主题testTopic，nameserve地址为127.0.0.1:9876 sh mqadmin updateTopic -n 127.0.0.1:9876 -c DefaultCluster -t testTopic 打印内容: create topic to 127.0.0.1:9876:10911 success. TopicConfig[topicName=testTopic,readQueueNums=8,writeQueueNums=8,perm=RW-,topicFilterType=SINGLE_TAG, topicSysFlag=0, order=false]
第3/20页
2.2. 删除Topic
指令 deleteTopic 类路径 com.alibaba.rocketmq.tools.command.topic.DeleteTopicSubCommand 参数 -c -h -n -t 举例 是否必填 是 否 说明 cluster名称，集群可通过clusterList查询 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;… topic名称（名称只能使用字符 ^[a-zA-Z0-9_-]+$ ） 是 是 在集群DefaultCluster上删除主题testTopic sh mqadmin deleteTopic -n 127.0.0.1:9876 -c DefaultCluster -t testTopic 2.3. 查看Topic列表信息 指令 topicList 类路径 com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand 参数 -h -n 举例 是否必填 否 说明 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;... 是 nameserve地址为127.0.0.1:9876 sh mqadmin topicList -n 127.0.0.1:9876 打印内容： BenchmarkTest %RETRY%simple-consumer-test SELF_TEST_TOPIC TestTopic 注释：上述前三个主题是RocketMQ默认预先创建 第4/20页
2.4. 查看Topic路由信息
指令 参数 -t -h -n 举例 topicRoute 类路径 com.alibaba.rocketmq.tools.command.topic.TopicRouteSubCommand 是否必填 是 否 说明 topic名称 打印帮助 nameserve服务地址列表，格式ip:port;ip:port;... 是 查看主题testTopic的路由 sh mqadmin topicRoute -t testTopic -n 127.0.0.1:9876 打印内容： { \ ], \ \ ] } { } \\\\\{ } \}, \ 第5/20页