导语
之前分析了关于RocketMQ源码的东西，接下来的阶段就是进入到实战的相关系列操作中，在这个系列中也会继续从源码的角度入手，深入的分析，在RocketMQ中的编程思想。下面就来介绍一下在RocketMQ中使用到的相关命令。
文章目录
- RocketMQ命令详解
- Broker
- clusterList：查看集群
- updateBrokerConfig：更新Broker 配置文件
- brokerStatus：查看broker状态
- Topic
- updateTopic：创建Topic
- deleteTopic：删除Topic
- topicList：查看Topic 列表
- topicRoute：查看Topic 路由
- topicStatus：查看Topic统计信息
- Consumer：消费者
- updateSubGroup：修订、创建订阅组
- deleteSubGroup：删除订阅组
- consumerProgress：查看订阅组消费状态
- consumerConnection：查看Consumer的连接信息
- getConsumerStatus：获取Consumer消费进度
- queryMsgByKey ：根据消息Key 查询消息
- queryMsgById：根据消息ID 查询消息
- queryMsgByOffset：根据消息的偏移值来查询消息
- Producer
- producerConnection：查询Producer 的网络连接
- Console
- 总结
RocketMQ命令详解
RocketMQ安装后的bin目录下"mqadmin"执行命令，用来执行RocketMQ的命令集
Broker
clusterList：查看集群
|
参数
|
是否必填
|
说明
|
|
-m
|
否
|
打印更多信息
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/admin clusterList -n 192.168.3.236:9876
updateBrokerConfig：更新Broker 配置文件
|
参数
|
是否必填
|
说明
|
|
-b
|
如果–c为空，则必填
|
broker 地址，表示订阅组建在该broker
|
|
-c
|
如果–b 为空，则必填
|
cluster名称，表示topic 建在该集群（集群可通过clusterList查询）
|
|
-k
|
是
|
key 值
|
|
-v
|
否
|
value 值
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin updateBrokerConfig -n 192.168.3.236:9876 -c loyalRocketMQCluster -k brokerName -v test
brokerStatus：查看broker状态
|
参数
|
是否必填
|
说明
|
|
-b
|
是
|
broker 地址
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin brokerStatus -n 192.168.3.236:9876 -b rocketmq-nameserver-1:10911
Topic
updateTopic：创建Topic
|
参数
|
是否必填
|
说明
|
|
-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
|
是
|
topic 名称（名称只能使用字符 1+$ ）
|
# 示例：在RocketMQ安装目录下
./bin/mqadmin updateTopic -t loyalTopic -c loyalRocketMQCluster -n 192.168.3.236:9876
deleteTopic：删除Topic
|
参数
|
是否必填
|
说明
|
|
-c
|
是
|
cluster 名称，表示删除某集群下的某个topic （集群可通过clusterList 查询）
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
|
-t
|
是
|
topic 名称（名称只能使用字符 2+$ ）
|
./bin/mqadmin deleteTopic -t loyalTopic -c loyalRocketMQCluster -n 192.168.3.236:9876
topicList：查看Topic 列表
|
参数
|
是否必填
|
说明
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin topicList -n 192.168.3.236:9876
topicRoute：查看Topic 路由
|
参数
|
是否必填
|
说明
|
|
-t
|
是
|
topic 名称
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;
|
./bin/mqadmin topicRoute -n 192.168.3.236:9876 -t loyalTest
topicStatus：查看Topic统计信息
|
参数
|
是否必填
|
说明
|
|
-t
|
是
|
topic 名称
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin topicStatus -n 192.168.3.236:9876 -t loyalTest
Consumer：消费者
updateSubGroup：修订、创建订阅组
|
参数
|
是否必填
|
说明
|
|
-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;…
|
./bin/mqadmin updateSubGroup -n 192.168.3.236:9876 -g loyalTestConsumerGroup -c loyalRocketMQCluster
deleteSubGroup：删除订阅组
|
参数
|
是否必填
|
说明
|
|
-b
|
如果–c 为空，则必填
|
broker 地址，表示订阅组建在该broker
|
|
-c
|
如果–b 为空，则必填
|
cluster 名称，表示topic建在该集群（集群可通过clusterList查询）
|
|
-g
|
是
|
订阅组名
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin deleteSubGroup -n 192.168.3.236:9876 -g loyalTestConsumerGroup -c loyalRocketMQCluster
consumerProgress：查看订阅组消费状态
|
参数
|
是否必填
|
说明
|
|
-g
|
是
|
消费者所属组名
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;
|
./bin/mqadmin consumerProgress -n 192.168.3.236:9876 -g loyalTestConsumerGroup
consumerConnection：查看Consumer的连接信息
|
参数
|
是否必填
|
说明
|
|
-g
|
是
|
消费者所属组名
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin consumerConnection -n 192.168.3.236:9876 -g loyalTestConsumerGroup
getConsumerStatus：获取Consumer消费进度
|
参数
|
是否必填
|
说明
|
|
-g
|
是
|
消费者所属组名
|
|
-t
|
是
|
查询主题
|
|
-i
|
否
|
Consumer 客户端ip
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin getConsumerStatus -n 192.168.3.236:9876 -g loyalTestConsumerGroup -t
queryMsgByKey ：根据消息Key 查询消息
|
参数
|
是否必填
|
说明
|
|
-f
|
否
|
被查询消息的截止时间
|
|
-k
|
是
|
msgKey
|
|
-t
|
是
|
topic 名称
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin queryMsgByKey -n 192.168.3.236:9876 -t loyalTest -k testKey
queryMsgById：根据消息ID 查询消息
|
参数
|
是否必填
|
说明
|
|
-i
|
是
|
消息id
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin queryMsgById -n 192.168.3.236:9876 -i C0A803EC00002A9F00000000000136FD
queryMsgByOffset：根据消息的偏移值来查询消息
|
参数
|
是否必填
|
说明
|
|
-b
|
是
|
Broker 名称，表示订阅组建在该broker（这里需要注意填写的是broker 的名称，不是broker 的地址，broker名称可以在clusterList 查到
|
|
-i
|
是
|
query 队列id
|
|
-o
|
是
|
offset 值
|
|
-t
|
是
|
topic 名称
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin queryMsgByOffset -n 192.168.3.236:9876 -b rocketmq-nameserver-1 -i 10 -o 1 -t loyalTest
Producer
producerConnection：查询Producer 的网络连接
|
参数
|
是否必填
|
说明
|
|
-g
|
是
|
生产者所属组名
|
|
-t
|
是
|
topic 名称
|
|
-h
|
否
|
打印帮助
|
|
-n
|
是
|
nameserve 服务地址列表，格式ip:port;ip:port;…
|
./bin/mqadmin producerConnection -n 192.168.3.236:9876 -g testProducerGroup -t testTopic
Console
启动Console
# 运行jar包，指定端口及名称服务器集群地址
nohup java -jar ./rocketmq-console-ng-1.0.0.jar --server.port=8080 --rocketmq.config.namesrvAddr=10.16.13.90:9876,10.16.13.91:9876 &
总结
上面的内容介绍了关于在不同的地方使用RocketMQ 的命令，在之前分析源码的时候也看到过关于这些命令的操作。在后续的操作分析中也会继续为大家分析这些命令背后的隐藏的逻辑。从源码入手，从原理入手，深入的学习RocketMQ，要想更好的使用工具，首先要更好的了解工具，让工具变成自己的东西。
a-zA-Z0-9_- ↩︎
a-zA-Z0-9_- ↩︎
RocketMQ实战系列-RocketMQ命令详解相关推荐
- UICC 之 USIM 详解全系列——常用命令详解与实例说明
本人就职于国际知名终端厂商,负责modem芯片研发. 在5G早期负责终端数据业务层.核心网相关的开发工作,目前牵头6G算力网络技术标准研究. 文章目录 常用命令详解与实例说明 SELECT命令 REA ...
- FFMPEG进阶系列02-ffmpeg命令详解3
ffmpeg 的封装转换 FFmpeg的封装转换部分,主要是通过libavformat这部分来完成的功能,通过libavformat库进行mux和demux操作,多媒体文件的格式有很多种,但是还是有好 ...
- FFMPEG进阶系列02-ffmpeg命令详解2
帮助信息 查看ffmpeg版本 通过ffmpeg -version查看ffmpeg的版本,这里所查看的版本,是详细的版本,包含libavformat.libavcodec.libavutil.liba ...
- 音视频开发系列(65）-FFMPEG进阶系列01-ffplay命令详解
概述 ffplay是一个基于FFMPEG库和SDL库开发的多媒体播放器.它的主要目的是是用来测试FFMPEG的各种API,比如codec/format/filter等等库. 掌握ffplay的设计逻辑 ...
- FFMPEG进阶系列01-ffplay命令详解
概述 ffplay是一个基于FFMPEG库和SDL库开发的多媒体播放器.它的主要目的是是用来测试FFMPEG的各种API,比如codec/format/filter等等库. 掌握ffplay的设计逻辑 ...
- linux中的shell有printf吗,Linux Shell系列教程之（八）Shell printf命令详解
在上一篇:Linux Shell系列教程之(七)Shell输出这篇文章中,已经对Shell printf命令有了一个简略的介绍,本篇给大家详细介绍下Shell中的printf命令. 一.Shell p ...
- [老男孩笔记系列]-之linux定时任务crontab命令详解
linux定时任务crontab命令详解 1.1指令语法 crontab [ -u user ] file crontab [ -u user ] { -l | -r | -e } 1.2指令说明 通 ...
- linux sed p变量,Linux sed 命令详解系列教程之各种问题解决
本文目录: 1 sed中使用变量和变量替换的问题 2 反向引用失效问题 3 "-i"选项的文件保存问题 4 贪婪匹配问题 5 sed命令"a"和"N& ...
- Linux Shell脚本入门教程系列之（八）Shell printf命令详解
本文是Linux Shell脚本系列教程的第(八)篇,更多shell教程请看:Linux Shell脚本系列教程 在上一篇:Linux Shell系列教程之(七)Shell输出这篇文章中,已经对She ...
最新文章
- PCL点云配准（2）
- 机器学习漫谈：还有很长的路要走
- 浅谈通信编程(二）--如何分离通信物理接口和应用程序
- LINUX内核经典面试题30道及解答
- Java基础点：常用类
- android开发桌面源码,android launcher 源码 自己开发启动桌面
- oModel.create will also send to backend directly
- 「假期余额不足」安排用Python写个时间在线生成器 快夸我
- 软件项目经理必备素质(转载)
- Bailian1833 POJ1833 排列【全排列】
- 视频时代的下一幕 ABC Inspire：读懂视频
- 【CSS 书写模式 (Writing modes )】
- dns服务器 性能测试,dns服务器性能测试报告.docx
- 未能加载文件或程序集
- 【论文阅读】Stroke Controllable Fast Style Transfer with Adaptive Receptive Fields
- 探秘Hadoop生态6：Hive技术初探与实践入门
- 数据分析和数据挖掘的概念和理念
- 想天浏览器：推荐国内主流浏览器TOP10
- 阿里云1+X-云计算开发与运维-中级(判断题)
- linux音频驱动之ALSA框架
热门文章
- aop 获取方法入参出参_ASM字节码编程 | JavaAgent+ASM字节码插桩采集方法名称及入参和出参结果并记录方法耗时...
- Play framework logging设置
- 机器人三定律真有用？但AI可能并不会遵守
- 用 Anaconda 完美解决 Python2 和 python3 共存问题
- Log4j（二）—— Log4j基本使用方法
- ./wls1036_linux32.bin: /lib/ld-linux.so.2: bad ELF interpreter
- [Leetcode]-- Valid Number
- [跟我学中小企业架构部署]之八：备份服务器部署
- 今天看到一篇小册子上的话
- 迷你版Spring MVC 实现
