RocketMQ 运维管理-常用快捷命令

谁借莪１个温暖的怀抱￠ 2023-01-02 03:29 382阅读 0赞

### **-------消息详情------------------------------------------------------------------------------------------------------------------------------------------------------** ###

**>>根据offsetMsgId查询msg，如果使用开源控制台，应使用offsetMsgId**

mqadmin queryMsgById -i C0A8380100002A9F00000000000A8117 -n localhost:9876

**>>根据topic 和key 查询msg**

mqadmin queryMsgByKey -n localhost:9876 -t msgTopic -k key1609750345214

**>>根据MsgId 和 topic 查询msg**

mqadmin queryMsgByUniqueKey -n localhost:9876 -i msgId -t msgTopic

### **-------消费组情况------------------------------------------------------------------------------------------------------------------------------------------------------** ###

**>>查看订阅组消费状态，可以查看具体的client IP的消息积累量**

mqadmin consumerProgress -n localhost:9876

![20210104173815110.png][]

**>>查看消费者状态，包括同一个分组订阅的消费者信息**

mqadmin consumerStatus -n localhost:9876 -g please_rename_unique_group_name11

![20210104174538524.png][]

**>> 查询 Consumer 的网络连接**

mqadmin consumerConnection -n localhost:9876 -g please_rename_unique_group_name

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW4xMDc4NzY_size_16_color_FFFFFF_t_70][]

### **-------生产者情况------------------------------------------------------------------------------------------------------------------------------------------------------** ###

**>>查询 Producer 的网络连接**

mqadmin producerConnection -n localhost:9876 -t WebSocketMsgTopic -g WebSocketMsgGroup

![2021010417565727.png][]

### **-------Topic相关------------------------------------------------------------------------------------------------------------------------------------------------------** ###

**>>查看 Topic 列表信息**

mqadmin topicList -n localhost:9876

**>>查看 Topic 路由信息**

mqadmin topicRoute -n localhost:9876  -t WebSocketMsgTopic

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW4xMDc4NzY_size_16_color_FFFFFF_t_70 1][]

**>>查看 Topic 消息队列offset**

mqadmin topicStatus -n localhost:9876 -t WebSocketMsgTopic

![20210104184123994.png][]

**>>打印Topic订阅关系、TPS、积累量、24h读写总量等信息**

mqadmin statsAll -n localhost:9876

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW4xMDc4NzY_size_16_color_FFFFFF_t_70 2][]

### **-------拓展------------------------------------------------------------------------------------------------------------------------------------------------------** ###

**>>在RocketMQ中msgId和offsetMsgId的含义与区别**

使用RocketMQ完成生产者客户端消息发送后，通常会看到如下日志打印信息：

SendResult [sendStatus=SEND_OK, msgId=0A42333A0DC818B4AAC246C290FD0000, offsetMsgId=0A42333A00002A9F000000000134F1F5, messageQueue=MessageQueue [topic=topicTest1, BrokerName=mac.local, queueId=3], queueOffset=4]

*  msgId，对于客户端来说msgId是由客户端producer实例端生成的，具体来说，调用方法`MessageClientIDSetter.createUniqIDBuffer()`生成唯一的Id；
 *  offsetMsgId，offsetMsgId是由Broker服务端在写入消息时生成的（采用”IP地址+Port端口”与“CommitLog的物理偏移量地址”做了一个字符串拼接），其中offsetMsgId就是在RocketMQ控制台直接输入查询的那个messageId。

[20210104173815110.png]: /images/20221120/1770dc7ae7834f019889b45046a1c956.png
[20210104174538524.png]: /images/20221120/206d1f550b084cf4903dad8fbd78cc44.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW4xMDc4NzY_size_16_color_FFFFFF_t_70]: /images/20221120/e8ffb2ca41f544deabc269871cedc598.png
[2021010417565727.png]: /images/20221120/3e588c76d13040f589d01b54031280b7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW4xMDc4NzY_size_16_color_FFFFFF_t_70 1]: /images/20221120/4a5ff7e6f3284d4383d5655845810ac1.png
[20210104184123994.png]: /images/20221120/926c5634e3374cd3817dc7dbb97811d6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3poYW4xMDc4NzY_size_16_color_FFFFFF_t_70 2]: /images/20221120/76544805e1894342ad70500d3305dc79.png