linux查看mq是否启动的命令,rocketmq查看命令 -ag凯发k8国际
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;...
总结
以上是ag凯发k8国际为你收集整理的linux查看mq是否启动的命令,rocketmq查看命令的全部内容，希望文章能够帮你解决所遇到的问题。
- 上一篇：
- 下一篇：