RocketMQ 提供一个命令行接口管理工具,查询、管理和诊断各种问题。
管理工具是非常友好的。
切换路径到${PACKAGE}/bin,输入命令 bash mqadmin。
| 命令 |
描述 |
| updateTopic |
更新或创建主题 |
| deleteTopic |
从broker和NameServer删除主题 |
| updateSubGroup |
更新或创建订阅组 |
| deleteSubGroup |
从broker删除订阅组 |
| updateBrokerConfig |
更新broker的配置 |
| updateTopicPerm |
更新主题权限 |
| topicRoute |
检查主题路由信息 |
| topicStatus |
检查主题状态信息 |
| topicClusterList |
获取主题集群信息 |
| brokerStatus |
broker运行状态数据 |
| queryMsgById |
通过id查询消息 |
| queryMsgByKey |
通过key查询消息 |
| queryMsgByUniqueKey |
通过唯一key查询消息 |
| queryMsgByOffset |
通过偏移量查询消息 |
| printMsg |
打印消息详情 |
| sendMsgStatus |
发送消息到broker的状态 |
| brokerConsumeStats |
获取broker消息数据状态 |
| producerConnection |
查询生产者的socket连接,客户端版本 |
| consumerConnection |
查询消费者的socket连接,客户端版本和订阅 |
| consumerProgress |
查询消费者的进度,速度 |
| consumerStatus |
查询消费者的内部数据结构 |
| cloneGroupOffset |
从其他组克隆偏移量 |
| clusterList |
集群列表 |
| topicList |
从name server获取主题列表 |
| updateKvConfig |
创建或更新KV配置 |
| deleteKvConfig |
删除KV 配置. |
| wipeWritePerm |
擦除所有name server中的broker写权限 |
| resetOffsetByTime |
通过(无客户端重启)重置消费者偏移量 |
| updateOrderConf |
创建或更新或删除顺序配置 |
| cleanExpiredCQ |
清理broker上过期的消费队列 |
| cleanUnusedTopic |
清理broker上未被使用的主题 |
| startMonitoring |
启动监控 |
| statsAll |
主题和消费者tps 状态 |
| syncDocs |
同步文档 |
| allocateMQ |
分配MQ |
| checkMsgSendRT |
检查消息的发送响应时间 |
| clusterRT |
集群内所有消息的发送响应时间列表 |
帮助文本列出可能的选项和每个选项的解释。
usage: mqadmin clusterList [-h] [-i <arg>] [-m] [-n <arg>]
-h,--help Print help
-i,--interval <arg> specify intervals numbers, it is in seconds
-m,--moreStats Print more stats
-n,--namesrvAddr <arg> Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876