全部產品
Search
文件中心

ApsaraMQ for RocketMQ:查看消費者狀態

更新時間:Dec 27, 2024

如果訊息消費出現異常,您可以在雲訊息佇列 RocketMQ 版控制台查看指定Group ID的消費狀態,包括消費者線上狀態、訂閱關係一致性結果、消費堆積相關指標、消費者用戶端資訊等,協助您快速定位異常原因。

應用情境

消費者狀態資訊包括線上狀態、訂閱關係、消費TPS、訊息堆積量和線程堆棧資訊等,經常被應用於以下故障排查情境:

故障情境

現象

處理建議

訂閱關係不一致

Group 详情頁面,看到Group ID的订阅关系顯示订阅关系不一致,请尽快处理!

請參見訂閱關係不一致

訊息堆積

Group 详情頁面,看到Group ID的处理中消息量就绪消息量排队时间的值高於預期。

請參見如何處理訊息堆積

查看Group ID基本資料

查詢入口

  1. 登入雲訊息佇列 RocketMQ 版控制台,在左側導覽列單擊執行個體列表

  2. 在頂部功能表列選擇地區,如華東1(杭州),然後在執行個體列表中,單擊目標執行個體名稱。

  3. 在左側導覽列,單擊Group 管理,然後在Group列表中單擊目標Group的名稱。

查詢結果說明

查詢結果如下圖所示。

image.png

欄位

說明

消费者状态

  • 只要該Group ID下有一個消費者執行個體線上,就顯示在线,此時您可以看到頁面下方的客户端连接信息地區顯示了線上的消費者執行個體資訊;

  • 若該Group ID下所有消費者執行個體都不線上,則顯示离线,且客户端连接信息地區無資訊顯示。

消费模式

消費者訂閱訊息時使用的消費模式。

雲訊息佇列 RocketMQ 版支援叢集消費模式和廣播消費模式,預設使用叢集消費模式,消費模式可在消費者用戶端進行修改。

更多資訊,請參見叢集消費和廣播消費

实时消费速度

該Group ID下消費者執行個體群組接收訊息的總TPS,單位為:條/秒。

处理中消息量

在消費者用戶端正在處理,但用戶端還未返回消費結果的訊息。

就绪消息量

訊息在雲訊息佇列 RocketMQ 版服務端已就緒,對消費者可見可被消費的訊息。

排队时间

最早一條就緒訊息的就緒時間和當前時刻的時間差。

該時間反映消費者拉取訊息的及時性。

订阅关系

顯示該Group ID下消費者執行個體群組的訂閱關係是否一致,以及每個消費者用戶端所訂閱的Tag。

訂閱關係一致的概念請參見訂閱關係一致

雲訊息佇列 RocketMQ 版僅支援查看線上用戶端的訂閱關係。

客户端连接信息

顯示當前線上的消費者用戶端資訊,包括用戶端的IP、用戶端版本、用戶端堆棧資訊等。

查看Group ID訊息堆積情況

查詢入口

Group 管理頁面單擊仪表盘

說明

您也可以通過儀錶盤功能查看指定執行個體下所有的指標項。具體操作,請參見儀錶盤

查詢結果說明

Group ID儀錶盤主要展示當前Group在消費情境中涉及的相關指標,包括該Group在指定Topic中的訊息堆積量、消費速率,以及指定Topic下訊息堆積量和訊息生產消費的變化趨勢圖表。

image.png

如遇消費異常情況,您可以參考以下思路進行排查:

  1. 在圖1消費情境指標中找到消費處理滯後最嚴重即堆積量最多的Topic。

  2. 在圖表上方的過濾條件中選擇圖1中找到的問題Topic。

  3. 結合圖2和圖3,查看該Topic中訊息堆積量和訊息生產消費速率的變化趨勢,縮小異常出現的時間範圍。

  4. 判斷該時間範圍內是否有進行後端操作或網路出現異常等原因。

相關文檔

除了控制台,雲訊息佇列 RocketMQ 版還支援通過API介面查詢Group的消費狀態和消費堆積情況。