2 rocketmq mqadmin 的用法详解

参考文档

http://jameswxx.iteye.com/blog/2091971

1.1. 控制台使用

RocketMQ 提供有控制台及一系列控制台命令，用于管理员对主题，集群，broker 等信息的管理；

登录控制台

首先进入RocketMQ 工程，进入/RocketMQ/bin

在该目录下有个mqadmin 脚本

查看帮助

在mqadmin 下可以查看有哪些命令

sh mqadmin

查看具体命令的使用

sh mqadmin help 命令名称

例如，查看updateTopic 的使用

sh mqadmin help updateTopic

1.2. 详细命令

指令 

updateTopic 

类路径 

com.alibaba.rocketmq.tools.command.topic.UpdateTopicSubCommand

参数

是否必填

说明

-b

如果-c为空，则必填

broker 地址，表示topic 建在该broker

-c

如果-b为空，则必填

cluster 名称，表示topic 建在该集群（集群可通过clusterList 查询）

-h

否

打印帮助

-n

是

nameserve 服务地址列表，格式ip:port;ip:port;...

-p

否 

指定新topic 的权限限制( W|R|WR )

-r 

可读队列数（默认为8）

-w

可写队列数（默认为8）

-t

opic 名称（名称只能使用字符 ^[a-zA-Z0-9_-]+$ ）

deleteTopic 

com.alibaba.rocketmq.tools.command.topic.DeleteTopicSubCommand

参数 

 说明

cluster 名称，表示删除某集群下的某个topic （集群可通过clusterList 查询）

nameserve 服务地址列表，格式ip:port;ip:port;…

topic 名称（名称只能使用字符 ^[a-zA-Z0-9_-]+$ ）

updateSubGroup 

com.alibaba.rocketmq.tools.command.consumer.UpdateSubGroupSubCommand

如果 –c 为空，则必填

broker 地址，表示订阅组建在该broker

如果 –b 为空，则必填

cluster名称，表示topic 建在该集群（集群可通过clusterList查询）

-d

是否容许广播方式消费

-g

是 

订阅组名

-i

从哪个broker 开始消费

-m

是否容许从队列的最小位置开始消费，默认会设置为false

-q

消费失败的消息放到一个重试队列，每个订阅组配置几个重试队列

重试消费最大次数，超过则投递到死信队列，不再投递，并报警

-s

消费功能是否开启

-w 

发现消息堆积后，将Consumer 的消费请求重定向到另外一台Slave 机器

deleteSubGroup 

com.alibaba.rocketmq.tools.command.consumer.DeleteSubscriptionGroupCommand

-b 

如果–c 为空，则必填

-c 

如果–b 为空，则必填

cluster 名称，表示topic建在该集群（集群可通过clusterList查询）

-n 

updateBrokerConfig

类路径

com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand

如果–c为空，则必填

-k 

 key 值

-v

value 值

topicList 

topicRoute 

com.alibaba.rocketmq.tools.command.topic.TopicRouteSubCommand

topic 名称

topicStats 

com.alibaba.rocketmq.tools.command.topic.TopicStatsSubCommand

brokerStats 

com.alibaba.rocketmq.tools.command.broker.BrokerStatsSubCommanD

 broker 地址

queryMsgById 

com.alibaba.rocketmq.tools.command.message.QueryMsgByIdSubCommand

 消息id

queryMsgByKey 

com.alibaba.rocketmq.tools.command.message.QueryMsgByKeySubCommand

-f

被查询消息的截止时间

-k

msgKey

queryMsgByOffset

com.alibaba.rocketmq.tools.command.message.QueryMsgByOffsetSubCommand

Broker 名称，表示订阅组建在该broker（这里需要注意填写的是broker 的名称，不是broker 的地址，broker名称可以在clusterList 查到

query 队列id

-o

offset 值

该命令只打印当前与cluster 连接的producer 网络连接信息

producerConnection

com.alibaba.rocketmq.tools.command.connection.ProducerConnectionSubCommand

生产者所属组名

该命令只打印当前与cluster 连接的consumer 网络连接信息

consumerConnection

com.alibaba.rocketmq.tools.command.connection.ConsumerConnectionSubCommand

消费者所属组名

consumerProgress

com.alibaba.rocketmq.tools.command.consumer.ConsumerProgressSubCommand

clusterList 

com.alibaba.rocketmq.tools.command.cluster.ClusterListSubCommand

打印更多信息

updateKvConfig 

com.alibaba.rocketmq.tools.command.namesrv.UpdateKvConfigCommand

key 值

Namespace 值

deleteKvConfig 

com.alibaba.rocketmq.tools.command.namesrv.DeleteKvConfigCommand

指令 updateProjectGroup 

类路径 com.alibaba.rocketmq.tools.command.namesrv.UpdateProjectGroupCommand

project group 名

服务器ip

deleteProjectGroup

com.alibaba.rocketmq.tools.command.namesrv.DeleteProjectGroupCommand

getProjectGroup

com.alibaba.rocketmq.tools.command.namesrv.GetProjectGroupCommand

根据时间来设置消费进度，设置之前要关闭这个订阅组的所有consumer，设置完再启动，方可生效

resetOffsetByTime

com.alibaba.rocketmq.tools.command.offset.ResetOffsetByTimeSubCommand

通过时间戳强制回滚（true|false），默认为true

时间戳

wipeWritePerm 

com.alibaba.rocketmq.tools.command.namesrv.WipeWritePermSubCommand

broker 地址

该命令只打印当前与cluster 连接的consumer 的消费进度

getConsumerStatus

com.alibaba.rocketmq.tools.command.offset.GetConsumerStatusCommand

查询主题

Consumer 客户端ip

分类: 专题__rocketmq