如果訊息消費出現異常,您可以在雲訊息佇列 RocketMQ 版控制台查看指定Group ID的消費狀態,包括消費者線上狀態、訂閱關係一致性結果、消費堆積相關指標、消費者用戶端資訊等,協助您快速定位異常原因。
應用情境
消費者狀態資訊包括線上狀態、訂閱關係、消費TPS、訊息堆積量和線程堆棧資訊等,經常被應用於以下故障排查情境:
故障情境 | 現象 | 處理建議 |
訂閱關係不一致 | 在Group 详情頁面,看到Group ID的订阅关系顯示订阅关系不一致,请尽快处理!。 | 請參見訂閱關係不一致 |
訊息堆積 | 在Group 详情頁面,看到Group ID的处理中消息量、就绪消息量和排队时间的值高於預期。 | 請參見如何處理訊息堆積 |
查看Group ID基本資料
查詢入口
登入雲訊息佇列 RocketMQ 版控制台,在左側導覽列單擊執行個體列表。
在頂部功能表列選擇地區,如華東1(杭州),然後在執行個體列表中,單擊目標執行個體名稱。
在左側導覽列,單擊Group 管理,然後在Group列表中單擊目標Group的名稱。
查詢結果說明
查詢結果如下圖所示。
欄位 | 說明 |
消费者状态 |
|
消费模式 | 消費者訂閱訊息時使用的消費模式。 雲訊息佇列 RocketMQ 版支援叢集消費模式和廣播消費模式,預設使用叢集消費模式,消費模式可在消費者用戶端進行修改。 更多資訊,請參見叢集消費和廣播消費。 |
实时消费速度 | 該Group ID下消費者執行個體群組接收訊息的總TPS,單位為:條/秒。 |
处理中消息量 | 在消費者用戶端正在處理,但用戶端還未返回消費結果的訊息。 |
就绪消息量 | 訊息在雲訊息佇列 RocketMQ 版服務端已就緒,對消費者可見可被消費的訊息。 |
排队时间 | 最早一條就緒訊息的就緒時間和當前時刻的時間差。 該時間反映消費者拉取訊息的及時性。 |
订阅关系 | 顯示該Group ID下消費者執行個體群組的訂閱關係是否一致,以及每個消費者用戶端所訂閱的Tag。 訂閱關係一致的概念請參見訂閱關係一致。 雲訊息佇列 RocketMQ 版僅支援查看線上用戶端的訂閱關係。 |
客户端连接信息 | 顯示當前線上的消費者用戶端資訊,包括用戶端的IP、用戶端版本、用戶端堆棧資訊等。 |
查看Group ID訊息堆積情況
查詢入口
在Group 管理頁面單擊仪表盘。
您也可以通過儀錶盤功能查看指定執行個體下所有的指標項。具體操作,請參見儀錶盤。
查詢結果說明
Group ID儀錶盤主要展示當前Group在消費情境中涉及的相關指標,包括該Group在指定Topic中的訊息堆積量、消費速率,以及指定Topic下訊息堆積量和訊息生產消費的變化趨勢圖表。
如遇消費異常情況,您可以參考以下思路進行排查:
在圖1消費情境指標中找到消費處理滯後最嚴重即堆積量最多的Topic。
在圖表上方的過濾條件中選擇圖1中找到的問題Topic。
結合圖2和圖3,查看該Topic中訊息堆積量和訊息生產消費速率的變化趨勢,縮小異常出現的時間範圍。
判斷該時間範圍內是否有進行後端操作或網路出現異常等原因。
相關文檔
除了控制台,雲訊息佇列 RocketMQ 版還支援通過API介面查詢Group的消費狀態和消費堆積情況。