【RocketMQ】如何快速检查RocketMQ集群延迟情况

迷南。 2023-09-29 17:35 5阅读 0赞

#### 文章目录 ####

*  背景
 *  命令讲解
 *  命令实操
 *   *  checkMsgSendRT
     *  clusterRT

## 背景 ##

业务团队在排查系统耗时时，说是定位到MQ这里耗时比较严重，本着严谨负责的心态，用集群的实际的延迟数据说话，排除集群本身的问题。

## 命令讲解 ##

进入RocketMQ的安装目录，bin目录下有一个mqadmin命令，可以用来运维、管理、测试集群，直接不带参数执行该命令，会列出所有支持的子命令。

![f8d156ac27e613c5967f867577efe876.jpeg][]

![0d776ff1e05d19870c11df68154596a6.jpeg][]

发现有两个命令可以检查集群的RT情况：

*  checkMsgSendRT: 检查消息发送延迟情况（response time）
 *  clusterRT: 检查所有集群（可以理解为master-slave组，对应broker.conf中的brokerName）的延迟情况

checkMsgSendRT是以生产者的角度，检查发送消息的延迟情况，而clusterRT更关注的是集群中每组主从子集群的延迟情况，后面可以根据每个命令的参数来做了解。

## 命令实操 ##

### checkMsgSendRT ###

**参数**：

[root@mq01 bin]# ./mqadmin checkMsgSendRT -h
    usage: mqadmin checkMsgSendRT [-a <arg>] [-h] [-n <arg>] -s <arg> -t <arg>
     -a,--amount <arg>        message amount | default 100
     -h,--help                Print help
     -n,--namesrvAddr <arg>   Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
     -s,--size <arg>          message size | default 128 Byte
     -t,--topic <arg>         topic name
    [root@mq01 bin]#
    [root@mq01 bin]#

示例：

root@XXGL-T-TJSYZ-REDIS-01 bin]# ./mqadmin checkMsgSendRT -n 172.24.30.192:9876 -a 10 -s 64 -t zhurunhua
    RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
    RocketMQLog:WARN Please initialize the logger system properly.
    #Broker Name                      #QID  #Send Result            #RT
    broker-b                          0     true                    211
    broker-b                          1     true                    2
    broker-b                          2     true                    7
    broker-b                          3     true                    2
    broker-b                          4     true                    3
    broker-b                          5     true                    3
    broker-b                          6     true                    3
    broker-b                          7     true                    3
    broker-c                          0     true                    6
    broker-c                          1     true                    3
    Avg RT: 3.56
    [root@XXGL-T-TJSYZ-REDIS-01 bin]#

命令会输出每条消息的发送耗时和平均耗时，但是没有标明单位，经过查看源码，证实单位为ms：

![495433638bd9323ff411c3385753c82b.jpeg][]

### clusterRT ###

**参数**：

[root@mq01 bin]# ./mqadmin clusterRT -h
    usage: mqadmin clusterRT [-a <arg>] [-c <arg>] [-h] [-i <arg>] [-m <arg>] [-n <arg>] [-p <arg>] -s <arg>
     -a,--amount <arg>         message amount | default 100
     -c,--cluster <arg>        cluster name | default display all cluster
     -h,--help                 Print help
     -i,--interval <arg>       print interval | default 10 seconds
     -m,--machine room <arg>   machine room name | default noname
     -n,--namesrvAddr <arg>    Name server address list, eg: 192.168.0.1:9876;192.168.0.2:9876
     -p,--print log <arg>      print as tlog | default false
     -s,--size <arg>           message size | default 128 Byte
    [root@mq01 bin]#
    [root@mq01 bin]#

<table> 
 <thead> 
  <tr> 
   <th>参数</th> 
   <th>含义</th> 
   <th>备注</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>-h,–help</td> 
   <td>打印help信息</td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>-n,–namesrvAddr </td> 
   <td>nameserver服务地址列表</td> 
   <td>必填</td> 
  </tr> 
  <tr> 
   <td>-a,–amount </td> 
   <td>消息数量</td> 
   <td>默认：100</td> 
  </tr> 
  <tr> 
   <td>-c,–cluster </td> 
   <td>指定cluster名称</td> 
   <td>不指定则打印所有</td> 
  </tr> 
  <tr> 
   <td>-i,–interval </td> 
   <td>打印间隔</td> 
   <td>默认：10秒</td> 
  </tr> 
  <tr> 
   <td>-m,–machine room </td> 
   <td>机器room name</td> 
   <td>默认：noname</td> 
  </tr> 
  <tr> 
   <td>-p,–print log </td> 
   <td>以日志形式打印</td> 
   <td>true|false(默认)</td> 
  </tr> 
  <tr> 
   <td>-s,–size </td> 
   <td>消息大小</td> 
   <td>默认：128 Byte</td> 
  </tr> 
 </tbody> 
</table>

[root@XXGL-T-TJSYZ-REDIS-01 bin]# ./mqadmin clusterRT  -n 172.24.30.192:9876 -s 128 -i 3
    RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.PlatformDependent0).
    RocketMQLog:WARN Please initialize the logger system properly.
    #Cluster Name             #Broker Name              #RT   #successCount  #failCount
    xdf-test1                 broker-b                  1.82      50                0               
    xdf-test1                 broker-c                  1.53      50                0               
    xdf-test1                 broker-a                  1.27      50                0               
    xdf-test1                 broker-b                  1.78      50                0               
    xdf-test1                 broker-c                  1.49      50                0               
    xdf-test1                 broker-a                  0.88      50                0               
    xdf-test1                 broker-b                  0.90      50                0               
    xdf-test1                 broker-c                  1.08      50                0               
    xdf-test1                 broker-a                  0.94      50                0               
    xdf-test1                 broker-b                  0.86      50                0               
    xdf-test1                 broker-c                  0.92      50                0               
    xdf-test1                 broker-a                  0.49      50                0

值得注意的是，我们并没有指定topic，那消息发送到哪个topic了呢？继续看源码：

![1a23d4766a87de6da647950e3f44d8be.jpeg][]

Message的构造方法，第一个参数为topic：

![fa399451f60ef5695026c660e0a2c990.jpeg][]

也就是说命令使用的是内部自动创建好的topic，集群在创建时，会默认把集群名、每个broker的名称新建为topic。

经过一顿的操作，集群本身肯定是没问题的，其他方面的问题，诸如网络、业务代码的问题，那就需要进一步排查了。

想了解mqadmin其他子命令和用途的，可以查看我的另一篇文章：[官方运维管理命令mqadmin使用手册（讲解+实操)][mqadmin]

[f8d156ac27e613c5967f867577efe876.jpeg]: https://img-blog.csdnimg.cn/img_convert/f8d156ac27e613c5967f867577efe876.jpeg
[0d776ff1e05d19870c11df68154596a6.jpeg]: https://img-blog.csdnimg.cn/img_convert/0d776ff1e05d19870c11df68154596a6.jpeg
[495433638bd9323ff411c3385753c82b.jpeg]: https://img-blog.csdnimg.cn/img_convert/495433638bd9323ff411c3385753c82b.jpeg
[1a23d4766a87de6da647950e3f44d8be.jpeg]: https://img-blog.csdnimg.cn/img_convert/1a23d4766a87de6da647950e3f44d8be.jpeg
[fa399451f60ef5695026c660e0a2c990.jpeg]: https://img-blog.csdnimg.cn/img_convert/fa399451f60ef5695026c660e0a2c990.jpeg
[mqadmin]: http://t.csdn.cn/1JtTU