RocketMQ命令行基本命令使用
点击上方「蓝字」关注我们
如果在没有RocketMQ管理控制台的情况下,可以使用RocketMQ HOME目录下的bin目录下的相关命令来操作和控制RocketMQ,懂得或者学会其中的一些简单命令,对排查问题至关重要。
0x01:启动和关闭
启动
#Start Name Server
nohup sh bin/mqnamesrv &
#Start Broker
nohup sh bin/mqbroker -n localhost:9876 &
如果需要自动创建主题
nohup sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &
关闭
#Shutdown Servers
sh bin/mqshutdown namesrv
sh bin/mqshutdown broker
0x02:使用mqadmin查看帮助文档
windows截图
sh mqadmin help 命令名称
例如
#查看 updateTopic 的使用
sh mqadmin help updateTopic
0x03: 主题(topic)相关命令
创建topic
sh mqadmin updateTopic –n 127.0.0.1:9876 –c DefaultCluster –t send_msg_topic
windows截图
查看所有topic
sh mqadmin topicList -n 127.0.0.1:9876
windows截图
查看topic信息列表详情统计
sh mqadmin topicstatus -n 127.0.0.1:9876 -t send_msg_topic
windows截图
删除topic
sh mqadmin deleteTopic –n 127.0.0.1:9876 –c DefaultCluster –t send_msg_topic
windows截图
0x03:订阅组相关
创建(修订)订阅组
sh mqadmin updateSubGroup -c DefaultCluster -n 127.0.0.1:9876 -g comsumer_group_send
windows截图
删除订阅组
sh mqadmin deleteSubGroup -c DefaultCluster -n 127.0.0.1:9876 -g comsumer_group_send
windows截图
查看所有消费组group
sh mqadmin consumerProgress -n 127.0.0.1:9876
查看某个订阅组消费状态
sh mqadmin consumerProgress -n 127.0.0.1:9876 -g comsumer_group_send
0x04:消息相关
根据消息ID查询消息
sh mqadmin queryMsgById -i 0A0158434F3473D16E938F000AEE0000 -n 127.0.0.1:9876
根据消息Key查询消息
sh mqadmin queryMsgByKey -k b4d83f23-36fe-4890-946c-a2dcccc67572 -t mq_message_send -n 127.0.0.1:9876
分享一个总结非常不错的:
https://www.iteye.com/blog/jameswxx-2091971
扫码二维码
获取更多精彩
Java乐园
评论