如果消息消費出現異常,您可以在云消息隊列 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的消費狀態和消費堆積情況。