全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 钉钉智能硬件
消息队列 MQ

消息堆积查询场景

更新时间:2017-06-07 13:26:11

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

查询思路

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

主要流程

调用流程如下图所示:

msg-accumulation

相关 API

  • 当前消息查询: OnsTopicStatus
  • 消费进度查询: OnsConsumerAccumulate
  • 消费者状态查询: OnsConsumerStatus
  • 清除堆积: OnsConsumerResetOffset
本文导读目录