mqadmin 操作指南
rocketmq的管理工具使用指南

mqadmin管理工具

RocketMQ 功能复杂,本篇只说明一些RocketMQ Connect常用命令,更多细节参考RocketMQ官网
{rocketmq目录}/bin中有mqadmin管理工具

注意:

    1.
    执行命令方法:./mqadmin {command} {args}
    2.
    几乎所有命令都需要配置-n表示NameServer地址,格式为ip:port
    3.
    几乎所有命令都可以通过-h获取帮助
    4.
    如果既有Broker地址(-b)配置项又有clusterName(-c)配置项,则优先以Broker地址执行命令,如果不配置Broker地址,则对集群中所有主机执行命令,只支持一个Broker地址。-b格式为ip:port,port默认是10911
    5.
    在tools下可以看到很多命令,但并不是所有命令都能使用,只有在MQAdminStartup中初始化的命令才能使用,你也可以修改这个类,增加或自定义命令
    6.
    由于版本更新问题,少部分命令可能未及时更新,遇到错误请直接阅读相关命令源码

Topic相关

名称
含义
命令选项
说明
updateTopic
创建更新Topic配置
-b
Broker 地址,表示 topic 所在 Broker,只支持单台Broker,地址为ip:port
-c
cluster 名称,表示 topic 所在集群(集群可通过 clusterList 查询)
-h-
打印帮助
-n
NameServer服务地址,格式 ip:port
-p
指定新topic的读写权限( W=2|R=4|WR=6 )
-r
可读队列数(默认为 8)
-w
可写队列数(默认为 8)
-t
topic 名称(名称只能使用字符 ^[a-zA-Z0-9_-]+$ )
deleteTopic
删除Topic
-c
cluster 名称,表示删除某集群下的某个 topic (集群 可通过 clusterList 查询)
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
-t
topic 名称(名称只能使用字符 ^[a-zA-Z0-9_-]+$ )
topicList
查看 Topic 列表信息
-h
打印帮助
-c
不配置-c只返回topic列表,增加-c返回clusterName, topic, consumerGroup信息,即topic的所属集群和订阅关系,没有参数
-n
NameServer 服务地址,格式 ip:port
topicRoute
查看 Topic 路由信息
-t
topic 名称
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
topicStatus
查看 Topic 消息队列offset
-t
topic 名称
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
topicClusterList
查看 Topic 所在集群列表
-t
topic 名称
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
updateTopicPerm
更新 Topic 读写权限
-t
topic 名称
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
-b
Broker 地址,表示 topic 所在 Broker,只支持单台Broker,地址为ip:port
-p
指定新 topic 的读写权限( W=2|R=4|WR=6 )
-c
cluster 名称,表示 topic 所在集群(集群可通过 clusterList 查询),-b优先,如果没有-b,则对集群中所有Broker执行命令
updateOrderConf
从NameServer上创建、删除、获取特定命名空间的kv配置,目前还未启用
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
-t
topic,键
-v
orderConf,值
-m
method,可选get、put、delete
allocateMQ
以平均负载算法计算消费者列表负载消息队列的负载结果
-t
topic 名称
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
-i
ipList,用逗号分隔,计算这些ip去负载Topic的消息队列
statsAll
打印Topic订阅关系、TPS、积累量、24h读写总量等信息
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
-a
是否只打印活跃topic
-t
指定topic

集群相关

名称
含义
命令选项
说明
clusterList
查看集群信息,集群、BrokerName、BrokerId、TPS等信息
-m
打印更多信息 (增加打印出如下信息 #InTotalYest, #OutTotalYest, #InTotalToday ,#OutTotalToday)
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
-i
打印间隔,单位秒
clusterRT
发送消息检测集群各Broker RT。消息发往${BrokerName} Topic。
-a
amount,每次探测的总数,RT = 总时间 / amount
-s
消息大小,单位B
-c
探测哪个集群
-p
是否打印格式化日志,以|分割,默认不打印
-h
打印帮助
-m
所属机房,打印使用
-i
发送间隔,单位秒
-n
NameServer 服务地址,格式 ip:port

Broker相关

名称
含义
命令选项
说明
updateBrokerConfig
更新 Broker 配置文件,会修改Broker.conf
-b
Broker 地址,格式为ip:port
-c
cluster 名称
-k
key 值
-v
value 值
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
brokerStatus
查看 Broker 统计信息、运行状态(你想要的信息几乎都在里面)
-b
Broker 地址,地址为ip:port
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
brokerConsumeStats
Broker中各个消费者的消费情况,按Message Queue维度返回Consume Offset,Broker Offset,Diff,TImestamp等信息
-b
Broker 地址,地址为ip:port
-t
请求超时时间
-l
diff阈值,超过阈值才打印
-o
是否为顺序topic,一般为false
-h
打印帮助
-n
NameServer 服务地址,格式 ip:port
getBrokerConfig
获取Broker配置
-b
Broker 地址,地址为ip:port
-n
NameServer 服务地址,格式 ip:port
wipeWritePerm
从NameServer上清除 Broker写权限
-b
Broker 地址,地址为ip:port
-n
NameServer 服务地址,格式 ip:port
-h
打印帮助
cleanExpiredCQ
清理Broker上过期的Consume Queue,如果手动减少对列数可能产生过期队列
-n
NameServer 服务地址,格式 ip:port
-h
打印帮助
-b
Broker 地址,地址为ip:port
-c
集群名称
cleanUnusedTopic
清理Broker上不使用的Topic,从内存中释放Topic的Consume Queue,如果手动删除Topic会产生不使用的Topic
-n
NameServer 服务地址,格式 ip:port
-h
打印帮助
-b
Broker 地址,地址为ip:port
-c
集群名称
sendMsgStatus
向Broker发消息,返回发送状态和RT
-n
NameServer 服务地址,格式 ip:port
-h
打印帮助
-b
BrokerName,注意不同于Broker地址
-s
消息大小,单位B
-c
发送次数

更多详细信息请参考

Last modified 1yr ago