769 windows windows

消息堆积查询场景__场景示例_Open API_消息队列 MQ-阿里云

本文主要介绍如何使用 Open API 来完成运行过程中 MQ 消息状态的查询，一般用于定位消息发送状况、消息消费状况，是否有堆积，如何处理堆积等。

查看 Topic 消息发送状态：即查看目标 Topic 当前服务器上存在的有效消息总数以及最新状态。
查看订阅组的消费进度：即查看指定的订阅组的消费是否有堆积。
客户端消费状态查询：如果存在堆积，可以查看消费组内各个客户端的连接状态，是否有客户端消费线程阻塞。
消费位点重置：根据业务需求对消费方的消费进度位点进行更新，该功能包含两个场景。
- 场景 A：如果消息可以丢弃，则选择清除所有消息。
- 场景 B：如果堆积的消息需要回收或者更新到指定时刻，可以选择根据指定时刻进行位点重置。

调用流程如下图所示:

msg-accumulation