如果消息消费出现异常,您可以在云消息队列 RocketMQ 版控制台查看指定Group ID的消费状态,包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等,帮助您快速定位异常原因。
应用场景
消费者状态信息包括在线状态、订阅关系、消费TPS、消息堆积量和线程堆栈信息等,经常被应用于以下故障排查场景:
故障场景 | 现象 | 处理建议 |
订阅关系不一致 | 在Group 详情页面,看到Group ID的订阅关系显示订阅关系不一致,请尽快处理!。 | 请参见订阅关系不一致 |
消息堆积 | 在Group 详情页面,看到Group ID的处理中消息量、就绪消息量和排队时间的值高于预期。 | 请参见如何处理消息堆积 |
查看Group ID基本信息
查询入口
登录云消息队列 RocketMQ 版控制台,在左侧导航栏单击实例列表。
在顶部菜单栏选择地域,如华东1(杭州),然后在实例列表中,单击目标实例名称。
在左侧导航栏,单击Group 管理,然后在Group列表中单击目标Group的名称。
查询结果说明
查询结果如下图所示。
字段 | 说明 |
消费者状态 |
|
消费模式 | 消费者订阅消息时使用的消费模式。 云消息队列 RocketMQ 版支持集群消费模式和广播消费模式,默认使用集群消费模式,消费模式可在消费者客户端进行修改。 更多信息,请参见集群消费和广播消费。 |
实时消费速度 | 该Group ID下消费者实例群组接收消息的总TPS,单位为:条/秒。 |
处理中消息量 | 在消费者客户端正在处理,但客户端还未返回消费结果的消息。 |
就绪消息量 | 消息在云消息队列 RocketMQ 版服务端已就绪,对消费者可见可被消费的消息。 |
排队时间 | 最早一条就绪消息的就绪时间和当前时刻的时间差。 该时间反映消费者拉取消息的及时性。 |
订阅关系 | 显示该Group ID下消费者实例群组的订阅关系是否一致,以及每个消费者客户端所订阅的Tag。 订阅关系一致的概念请参见订阅关系一致。 云消息队列 RocketMQ 版仅支持查看在线客户端的订阅关系。 |
客户端连接信息 | 显示当前在线的消费者客户端信息,包括客户端的IP、客户端版本、客户端堆栈信息等。 |
查看Group ID消息堆积情况
查询入口
在Group 管理页面单击仪表盘。
您也可以通过仪表盘功能查看指定实例下所有的指标项。具体操作,请参见仪表盘。
查询结果说明
Group ID仪表盘主要展示当前Group在消费场景中涉及的相关指标,包括该Group在指定Topic中的消息堆积量、消费速率,以及指定Topic下消息堆积量和消息生产消费的变化趋势图表。
如遇消费异常情况,您可以参考以下思路进行排查:
在图1消费场景指标中找到消费处理滞后最严重即堆积量最多的Topic。
在图表上方的过滤条件中选择图1中找到的问题Topic。
结合图2和图3,查看该Topic中消息堆积量和消息生产消费速率的变化趋势,缩小异常出现的时间范围。
判断该时间范围内是否有进行后端操作或网络出现异常等原因。
相关文档
除了控制台,云消息队列 RocketMQ 版还支持通过API接口查询Group的消费状态和消费堆积情况。