原创文章,转载请注明出处: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. 详细命令
1.2.1. 创建Topic
指令
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_-]+$ ) |
1.2.2. 删除Topic
指令
deleteTopic
类路径
com.alibaba.rocketmq.tools.command.topic.DeleteTopicSubCommand
参数 |
是否必填 |
说明 |
-c |
是 |
cluster 名称,表示删除某集群下的某个topic (集群可通过clusterList 查询) |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;… |
-t |
是 |
topic 名称(名称只能使用字符 ^[a-zA-Z0-9_-]+$ ) |
1.2.3. 创建(修订)订阅组
指令
updateSubGroup
类路径
com.alibaba.rocketmq.tools.command.consumer.UpdateSubGroupSubCommand
参数 |
是否必填 |
说明 |
-b |
如果 –c 为空,则必填 |
broker 地址,表示订阅组建在该broker |
-c |
如果 –b 为空,则必填 |
cluster名称,表示topic 建在该集群(集群可通过clusterList查询) |
-d |
否 |
是否容许广播方式消费 |
-g |
是 |
订阅组名 |
-i |
否 |
从哪个broker 开始消费 |
-m |
否 |
是否容许从队列的最小位置开始消费,默认会设置为false |
-q |
否 |
消费失败的消息放到一个重试队列,每个订阅组配置几个重试队列 |
-r |
否 |
重试消费最大次数,超过则投递到死信队列,不再投递,并报警 |
-s |
否 |
消费功能是否开启 |
-w |
否 |
发现消息堆积后,将Consumer 的消费请求重定向到另外一台Slave 机器 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.4. 删除订阅组配置
指令
deleteSubGroup
类路径
com.alibaba.rocketmq.tools.command.consumer.DeleteSubscriptionGroupCommand
参数 |
是否必填 |
说明 |
-b |
如果–c 为空,则必填 |
broker 地址,表示订阅组建在该broker |
-c |
如果–b 为空,则必填 |
cluster 名称,表示topic建在该集群(集群可通过clusterList查询) |
-g |
是 |
订阅组名 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.5. 更新Broker 配置文件
指令
updateBrokerConfig
类路径
com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand
参数 |
是否必填 |
说明 |
-b |
如果–c为空,则必填 |
broker 地址,表示订阅组建在该broker |
-c |
如果–b 为空,则必填 |
cluster名称,表示topic 建在该集群(集群可通过clusterList查询) |
-k |
是 |
key 值 |
-v |
否 |
value 值 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.6. 查看Topic 列表信息
指令
topicList
类路径
com.alibaba.rocketmq.tools.command.broker.UpdateBrokerConfigSubCommand
参数 |
是否必填 |
说明 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.7. 查看Topic 路由信息
指令
topicRoute
类路径
com.alibaba.rocketmq.tools.command.topic.TopicRouteSubCommand
参数 |
是否必填 |
说明 |
-t |
是 |
topic 名称 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.8. 查看Topic 统计信息
指令
topicStats
类路径
com.alibaba.rocketmq.tools.command.topic.TopicStatsSubCommand
参数 |
是否必填 |
说明 |
-t |
是 |
topic 名称 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.9. 查看Broker 统计信息
指令
brokerStats
类路径
com.alibaba.rocketmq.tools.command.broker.BrokerStatsSubCommanD
参数 |
是否必填 |
说明 |
-b |
是 |
broker 地址 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.10. 根据消息ID 查询消息
指令
queryMsgById
类路径
com.alibaba.rocketmq.tools.command.message.QueryMsgByIdSubCommand
参数 |
是否必填 |
说明 |
-i |
是 |
消息id |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.11. 根据消息Key 查询消息
指令
queryMsgByKey
类路径
com.alibaba.rocketmq.tools.command.message.QueryMsgByKeySubCommand
参数 |
是否必填 |
说明 |
-f |
否 |
被查询消息的截止时间 |
-k |
是 |
msgKey |
-t |
是 |
topic 名称 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.12. 根据Offset 查询消息
指令
queryMsgByOffset
类路径
com.alibaba.rocketmq.tools.command.message.QueryMsgByOffsetSubCommand
参数 |
是否必填 |
说明 |
-b |
是 |
Broker 名称,表示订阅组建在该broker(这里需要注意填写的是broker 的名称,不是broker 的地址,broker名称可以在clusterList 查到 |
-i |
是 |
query 队列id |
-o |
是 |
offset 值 |
-t |
是 |
topic 名称 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.13. 查询Producer 的网络连接
该命令只打印当前与cluster 连接的producer 网络连接信息
指令
producerConnection
类路径
com.alibaba.rocketmq.tools.command.connection.ProducerConnectionSubCommand
参数 |
是否必填 |
说明 |
-g |
是 |
生产者所属组名 |
-t |
是 |
topic 名称 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.14. 查询Consumer 的网络连接
该命令只打印当前与cluster 连接的consumer 网络连接信息
指令
consumerConnection
类路径
com.alibaba.rocketmq.tools.command.connection.ConsumerConnectionSubCommand
参数 |
是否必填 |
说明 |
-g |
是 |
消费者所属组名 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.15. 查看订阅组消费状态
指令
consumerProgress
类路径
com.alibaba.rocketmq.tools.command.consumer.ConsumerProgressSubCommand
参数 |
是否必填 |
说明 |
-g |
是 |
消费者所属组名 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.16. 查看集群消息
指令
clusterList
类路径
com.alibaba.rocketmq.tools.command.cluster.ClusterListSubCommand
参数 |
是否必填 |
说明 |
-m |
否 |
打印更多信息 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.17. 添加(更新)KV 配置信息
指令
updateKvConfig
类路径
com.alibaba.rocketmq.tools.command.namesrv.UpdateKvConfigCommand
参数 |
是否必填 |
说明 |
-k |
是 |
key 值 |
-v |
是 |
value 值 |
-s |
是 |
Namespace 值 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.18. 删除KV 配置信息
指令
deleteKvConfig
类路径
com.alibaba.rocketmq.tools.command.namesrv.DeleteKvConfigCommand
参数 |
是否必填 |
说明 |
-k |
是 |
key 值 |
-s |
是 |
Namespace 值 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.19. 添加(更新)Project group 配置信息
指令 updateProjectGroup
类路径 com.alibaba.rocketmq.tools.command.namesrv.UpdateProjectGroupCommand
参数 |
是否必填 |
说明 |
-p |
是 |
project group 名 |
-i |
否 |
服务器ip |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.20. 删除Project group 配置信息
指令
deleteProjectGroup
类路径
com.alibaba.rocketmq.tools.command.namesrv.DeleteProjectGroupCommand
参数 |
是否必填 |
说明 |
-p |
是 |
project group 名 |
-i |
否 |
服务器ip |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.21. 取得Project group 配置信息
指令
getProjectGroup
类路径
com.alibaba.rocketmq.tools.command.namesrv.GetProjectGroupCommand
参数 |
是否必填 |
说明 |
-p |
是 |
project group 名 |
-i |
否 |
服务器ip |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.22. 设置消费进度
根据时间来设置消费进度,设置之前要关闭这个订阅组的所有consumer,设置完再启动,方可生效
指令
resetOffsetByTime
类路径
com.alibaba.rocketmq.tools.command.offset.ResetOffsetByTimeSubCommand
参数 |
是否必填 |
说明 |
-f |
否 |
通过时间戳强制回滚(true|false),默认为true |
-s |
是 |
时间戳 |
-g |
是 |
消费者所属组名 |
-t |
是 |
topic 名称 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.23. 清除特定Broker权限
指令
wipeWritePerm
类路径
com.alibaba.rocketmq.tools.command.namesrv.WipeWritePermSubCommand
参数 |
是否必填 |
说明 |
-b |
是 |
broker 地址 |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
1.2.24. 获取Consumer消费进度
该命令只打印当前与cluster 连接的consumer 的消费进度
指令
getConsumerStatus
类路径
com.alibaba.rocketmq.tools.command.offset.GetConsumerStatusCommand
参数 |
是否必填 |
说明 |
-g |
是 |
消费者所属组名 |
-t |
是 |
查询主题 |
-i |
否 |
Consumer 客户端ip |
-h |
否 |
打印帮助 |
-n |
是 |
nameserve 服务地址列表,格式ip:port;ip:port;... |
相关推荐
阿里RocketMQ_用户指南_V3.2.4_最新版本.pdf benchmark.pdf Metaq在JDk 7下的异常及解决方案.docx mqvsmq.pdf RocketMQ_原理简介.pdf ...RocketMQ命令整理.doc RocketMQ群问题整理.docx RocketMQ运维指令整理.docx
启动 namesrv nohup sh mqnamesrv & 启动broker nohup sh mqbroker -c ../conf/eda_master1.properties &
RocketMQ群问题整理RocketMQ群问题整理RocketMQ群问题整理
尚硅谷完整的关于rocketmq的学习视频整理笔记,适合初学rocketmq的人
RocketMQ运维常用命令
rocketmq客户端,直接在浏览器中输入地址即可访问。这是个springboot项目,根据实际需要修改对应配置;主要是修改端口号及对应rocketMQ连接地址。
为了后续操作方便可以配置环境变量,之后在任意位置都可以执行rocketmq的操作命令。 vim /etc/profile # 在文件末尾添加以下内容: export ROCKETMQ_HOME=/usr/local/rocketmq export PATH=$ROCKETMQ_HOME/bin:
020-020_RocketMQ_管理员命令 二、rocketmq实战视频教程目录大纲 01_rocketmq_实战项目介绍 02_rocketMQ实战项目设计(一) 03_rocketMQ实战项目设计(二) 04_rocketMQ实战-环境搭建(一) 05_rocketMQ实战-环境搭建(二) ...
rocketmq控制台jar和启动指令,用来图形化查看mq队列和消息,启动指令:nohup java -jar rocketmq-console-ng-1.0.0.jar --server.port=12581 --rocketmq.config.namesrvAddr=192.168.100.62:28881 & 或者 nohup ...
rocketmq总结
SpringBoot整合RocketMq
020-020_RocketMQ_管理员命令 二、rocketmq实战视频教程目录大纲 01_rocketmq_实战项目介绍 02_rocketMQ实战项目设计(一) 03_rocketMQ实战项目设计(二) 04_rocketMQ实战-环境搭建(一) 05_rocketMQ实战-环境搭建(二) ...
个人整理的RocketMq的Spring示例。
1.此jar包是根据rocketmq-console-ng工程maven编译而来 ...3.启动命令(需要有jdk环境): nohup java -jar rocketmq-console-ng-1.0.0-gbk.jar --server.port=8888 --rocketmq.config.namesrvAddr=ip1:9876;ip2:9876 &
rocketmq设置开机启动脚本
RocketMQ-Connect 二次开发源码。RocketMQ-Connect 二次开发源码。RocketMQ-Connect 二次开发源码。RocketMQ-Connect 二次开发源码。RocketMQ-Connect 二次开发源码。RocketMQ-Connect 二次开发源码。RocketMQ-...
rocketmq学习 rocketmq深入
rocketmq-dashboard.zip
RocketMq操作手册:针对入门初中级别。 消息队列 RocketMQ 是阿里巴巴集团基于高可用分布式集群技术,自主研发的云正式商用的专业消息中间件,既可为分布式应用系统提供异步解耦 和削峰填谷的能力,同时也具备互联网...