如遇消息消费异常,可在消息队列RocketMQ版控制台查看消费者状态初步诊断原因。您可查看每个Group ID代表的消费者实例群组的信息,也可查看该群组下单个消费者实例的信息。

应用场景

消费者状态信息包括在线状态、订阅关系、消费TPS、消息堆积量和线程堆栈信息等,经常被应用于以下故障排查场景:

  • 订阅关系不一致
  • 消息堆积
    • 现象:在消费者状态页面,看到Group ID的实时消息堆积量的值高于预期。
    • 处理:处理消息堆积的具体办法,请参见如何处理消息堆积

查看Group ID综合信息

请按以下步骤查看Group ID所代表的消费者实例集群的综合信息:

  1. 登录消息队列RocketMQ版控制台。在顶部菜单栏,选择地域(Region),如华东1(杭州)
  2. 实例列表页面,找到目标实例,在其操作列,单击详情
  3. 在左侧导航栏单击Group 管理
  4. Group 管理页面,找到要查看的Group ID,单击其右侧操作列中的消费者状态

    查看结果如下图所示。

    消费者状态
表 1. 字段说明
字段/图标 说明
在线状态图标
  • 只要该Group ID下有一个消费者实例在线,就显示在线,此时您可以看到页面下方的连接信息区域显示了在线的消费者实例信息;
  • 若该Group ID下所有消费者实例都不在线,则显示离线,且连接信息区域无信息显示。
订阅关系是否一致 显示该Group ID下消费者实例群组的订阅关系是否一致。订阅关系一致的概念请参见订阅关系一致
实时消费速度 该Group ID下消费者实例群组接收消息的总TPS,单位为“条/秒”。
实时消息堆积量 该Group ID下消费者实例群组的未消费消息的总量。
最近消费时间 该Group ID下消费者实例群组最近一次消费消息的时间。
消息延迟时间 该Group ID下消费者实例群组最早的一条未消费消息的生产时间与当前时间的差值。

查看Group ID下单个消费者实例的信息

若此时该Group ID的在线状态为在线,则在连接信息区域您可以查看此时在线的每个消费者实例的具体信息,包括客户端ID、宿主机IP/公网IP、当前进程ID和消息堆积量等。

查看更多详细信息

除上述信息,还可在某个消费者实例信息右侧的详细说明列,单击详细信息查看更多详细信息,包括消费线程数、消费启动时间、订阅关系和消费统计数据等,如下图所示。

连接详情查看线程堆栈信息
如需查看某消费者实例当前进程的堆栈信息,找到需查看堆栈信息的消费者实例,在其所在行右侧的堆栈信息列,单击堆栈信息,展现的信息如下图所示。JStack

更多信息

如果您设置过监控项,且接收到消息堆积告警通知,请参见使用消息队列RocketMQ版后收到消息堆积告警处理。