消息堆积查询场景该如何做到？

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

查询思路

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

调用流程如下图所示:

msg-accumulation

相关 API

当前消息查询: OnsTopicStatus
消费进度查询: OnsConsumerAccumulate
消费者状态查询: OnsConsumerStatus
清除堆积: OnsConsumerResetOffset