閱讀769 返回首頁    go windows


消息堆積查詢場景__場景示例_Open API_消息隊列 MQ-阿裏雲

本文主要介紹如何使用 Open API 來完成運行過程中 MQ 消息狀態的查詢,一般用於定位消息發送狀況、消息消費狀況,是否有堆積,如何處理堆積等。

查詢思路

  1. 查看 Topic 消息發送狀態: 即查看目標 Topic 當前服務器上存在的有效消息總數以及最新狀態。
  2. 查看訂閱組的消費進度: 即查看指定的訂閱組的消費是否有堆積。
  3. 客戶端消費狀態查詢: 如果存在堆積,可以查看消費組內各個客戶端的連接狀態,是否有客戶端消費線程阻塞。
  4. 消費位點重置: 根據業務需求對消費方的消費進度位點進行更新,該功能包含兩個場景。
    • 場景 A:如果消息可以丟棄,則選擇清除所有消息。
    • 場景 B:如果堆積的消息需要回收或者更新到指定時刻,可以選擇根據指定時刻進行位點重置。

主要流程

調用流程如下圖所示:

msg-accumulation

相關 API

  • 當前消息查詢: OnsTopicStatus
  • 消費進度查詢: OnsConsumerAccumulate
  • 消費者狀態查詢: OnsConsumerStatus
  • 清除堆積: OnsConsumerResetOffset

最後更新:2016-11-23 18:54:55

  上一篇:go 資源查詢場景__場景示例_Open API_消息隊列 MQ-阿裏雲
  下一篇:go 資源授權場景__場景示例_Open API_消息隊列 MQ-阿裏雲