RocketMQ命令整理
为什么80%的码农都做不了架构师?>>>
原创文章,转载请注明出处: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;... |
转载于:https://my.oschina.net/boltwu/blog/473024
RocketMQ命令整理相关推荐
- Redis 命令整理
Redis 命令整理 一.从大而全的方向看,完整的命令查看文档地址: http://doc.redisfans.com/ 二.Redis 键(key) 常用 案例 三.Redis 字符串(Stri ...
- linux的网络命令整理 更新中
linux的网络命令整理 更新中 1.安装包: net-tools 主要命令: netstat , ifconfig , route , iptunnel iproute 主要命令: ss , ip ...
- 最详细的SQL注入相关的命令整理
最详细的SQL注入相关的命令整理 QUOTE: 1. 用^转义字符来写ASP(一句话***)文件的方法: ? http://192.168.1.5/display.asp?keyno=18 ...
- python常用命令汇总-python数据分析之pandas常用命令整理
原标题:python数据分析之pandas常用命令整理 pandas 是基于NumPy 的一种工具,该工具是为了解决数据分析任务而创建的.Pandas 纳入了大量库和一些标准的数据模型 ,提供了高效地 ...
- Emacs基础命令整理 - Unplugged - 博客频道 - CSDN.NET
Emacs基础命令整理 - Unplugged - 博客频道 - CSDN.NET Emacs基础命令整理 分类: Unix /GNU Linux 2005-06-03 23:45 1649人阅读 评 ...
- linux命令老是忘记,Linux可能会忘记的命令整理
Linux可能会忘记的命令整理 因为太常见的大家都会,太不常见的碰上的也少,所以来整理一下一般般常见或者由于过于常见而忘记细节的命令好啦. 时间充足的话可以再过一遍这个,突然发现之前笔记做得还是很认真 ...
- docker常用命令_docker常用命令整理
docker常用命令整理 代码狂魔 • 5 天前 • 技术积累 • 14 • 0 前面已经把docker是什么和 docker怎么安装已经写了,现在我将常用命令做一个整理,方便日后查阅 常用命令 do ...
- android 常用命令,Android开发常用命令整理
一些命令,不常用就忘记了,特整理在这里,忘了就查查.. · alias 用于定义和查询别名,但不保存.修改home目录下.bashrc保存定义别名格式,不加参数即查询别名:alias c ...
- CMake常用命令整理
CMake常用命令整理 转自:https://zhuanlan.zhihu.com/p/315768216 CMake 是什么我就不用再多说什么了,相信大家都有接触才会看一篇文章.对于不太熟悉的开发人 ...
最新文章
- matlab中调用cplex 以及使用 Yalmip 工具箱
- @hdu - 3746@ Cyclic Nacklace
- Flink 在唯品会的实践
- 悲观锁和乐观锁和gap锁
- 蓝桥杯 每周一练 第一周(3n+1问题)
- C#面向对象--命名空间
- YIi2 對接 支付寶Alipay支付接口
- 项目中最困难的部分_微服务最难的部分是什么? 您的资料
- SAP License:SAP与中国电子技术标准化研究院开展交流活动
- Nginx 在 Linux 下安装与搭建 Tomcat 集群
- 将百度地图下载为图片-自定义尺寸
- CentOS8下安装snort2.9.18.1
- 科隆OPTIFLUX2100W/4100C分体式电磁流量计维修
- 关于推广个人博客的经验_博客推广
- 丹尼带你入坑无人机3 - 四轴飞行原理
- 携手强化「内容审核」能力,融云与数美科技达成战略合作!
- ubuntu19.04下VirtualBox与虚拟机win7共享文件夹
- C++判断两个链表是否相交算法
- arcgis js 4 风场可视化
- Ext js 下拉框模糊匹配查询,并支持反复输入检索
热门文章
- 如何优雅的转换 Bean 对象?
- Spring Cloud第十二篇:断路器监控(Hystrix Dashboard)
- 机器学习中的优化算法!
- 研究生失联19天,父母焦急求助!最后竟然是在写博士研究计划......
- 被放养导致申博论文难产,该不该硬gang导师?
- 蛰伏7年!他一天发表两篇Nature,还曾是曹原的师弟!
- 最大民科组织被取缔,鸡蛋返生、推翻相对论、量子速读都是他们干的
- 为了杀蚊子,这位博士用树莓派DIY了一把激光枪!网友:伤到人怎么办?
- 怎么才能优雅地向导师表达「这周科研没什么进展」?
- Nginx 之父被拘留,时隔15年后,前老板提起了版权侵权诉讼!