查看消费者状态

如果消息消费出现异常,您可以在云消息队列 RocketMQ 版控制台查看指定Group ID的消费状态,包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等,帮助您快速定位异常原因。

应用场景

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

故障场景

现象

处理建议

订阅关系不一致

Group 详情页面,看到Group ID的订阅关系显示订阅关系不一致,请尽快处理!

请参见订阅关系不一致

消息堆积

Group 详情页面,看到Group ID的处理中消息量就绪消息量排队时间的值高于预期。

请参见如何处理消息堆积

查看Group ID基本信息

查询入口

  1. 登录云消息队列 RocketMQ 版控制台,在左侧导航栏单击实例列表

  2. 在顶部菜单栏选择地域,如华东1(杭州),然后在实例列表中,单击目标实例名称。

  3. 在左侧导航栏,单击Group 管理,然后在Group列表中单击目标Group的名称。

查询结果说明

查询结果如下图所示。

image.png

字段

说明

消费者状态

  • 只要该Group ID下有一个消费者实例在线,就显示在线,此时您可以看到页面下方的客户端连接信息区域显示了在线的消费者实例信息;

  • 若该Group ID下所有消费者实例都不在线,则显示离线,且客户端连接信息区域无信息显示。

消费模式

消费者订阅消息时使用的消费模式。

云消息队列 RocketMQ 版支持集群消费模式和广播消费模式,默认使用集群消费模式,消费模式可在消费者客户端进行修改。

更多信息,请参见集群消费和广播消费

实时消费速度

该Group ID下消费者实例群组接收消息的总TPS,单位为:条/秒。

处理中消息量

在消费者客户端正在处理,但客户端还未返回消费结果的消息。

就绪消息量

消息在云消息队列 RocketMQ 版服务端已就绪,对消费者可见可被消费的消息。

排队时间

最早一条就绪消息的就绪时间和当前时刻的时间差。

该时间反映消费者拉取消息的及时性。

订阅关系

显示该Group ID下消费者实例群组的订阅关系是否一致,以及每个消费者客户端所订阅的Tag。

订阅关系一致的概念请参见订阅关系一致

云消息队列 RocketMQ 版仅支持查看在线客户端的订阅关系。

客户端连接信息

显示当前在线的消费者客户端信息,包括客户端的IP、客户端版本、客户端堆栈信息等。

查看Group ID消息堆积情况

查询入口

Group 管理页面单击仪表盘

说明

您也可以通过仪表盘功能查看指定实例下所有的指标项。具体操作,请参见仪表盘

查询结果说明

Group ID仪表盘主要展示当前Group在消费场景中涉及的相关指标,包括该Group在指定Topic中的消息堆积量、消费速率,以及指定Topic下消息堆积量和消息生产消费的变化趋势图表。

image.png

如遇消费异常情况,您可以参考以下思路进行排查:

  1. 在图1消费场景指标中找到消费处理滞后最严重即堆积量最多的Topic。

  2. 在图表上方的过滤条件中选择图1中找到的问题Topic。

  3. 结合图2和图3,查看该Topic中消息堆积量和消息生产消费速率的变化趋势,缩小异常出现的时间范围。

  4. 判断该时间范围内是否有进行后端操作或网络出现异常等原因。

相关文档

除了控制台,云消息队列 RocketMQ 版还支持通过API接口查询Group的消费状态和消费堆积情况。