全部產品
Search
文件中心

:訊息消費常見問題

更新時間:Dec 24, 2025

用戶端首次接入串連不上服務端,收不到訊息如何排查?

請檢查以下配置是否填寫正確:

  • 檢查存取點是否填寫正確。存取點請從控制台实例详情頁面擷取。

  • 使用telnet 存取點網域名稱連接埠命令初步檢查網路連通性。

    • 若您的應用部署在本地、或需要跨地區訪問且無法使用CEN組網,您需要使用公網存取點訪問雲訊息佇列 RocketMQ 版執行個體。使用公網存取點會產生下行流量費用,具體資訊,請參見4.x系列公網訪問費用5.x系列公網訪問費用

    • 若您的應用部署在阿里雲ECS上,您可以使用VPC存取點通過VPC專用網路訪問雲訊息佇列 RocketMQ 版執行個體。該情境下,需要保證阿里雲ECS的地區和要訪問的雲訊息佇列 RocketMQ 版執行個體處於同一地區。

  • 5.0系列執行個體若開啟公網訪問,請確認是否有配置白名單。公網訪問預設全部地址允許存取,若配置了白名單則僅白名單中的IP地址允許訪問雲訊息佇列 RocketMQ 版

  • 檢查Topic名稱是否填寫正確,不要有多餘空格或特殊字元,並確保Topic已在控制台提前建立。

  • 檢查使用者名稱密碼是否設定正確。

    • 5.0系列執行個體:需要填寫執行個體的使用者名稱和密碼,在控制台執行個體詳情頁擷取。

    • 4.0系列執行個體:需要填寫阿里雲帳號或RAM使用者的AccessKey(AccessKey ID和AccessKey Secret)並正確授權。擷取方式,請參見建立AccessKey

訂閱關係不一致如何處理?

登入控制台,進入Group 管理頁面,查看指定Group的訂閱關係及消費者資訊,將不符合預期的消費者的訂閱代碼中的訂閱關係修改一致。

詳細排查步驟,請參見如何排查RocketMQ訂閱關係不一致的問題?

如何處理訊息堆積?

訊息出現堆積,可能原因如下:

  • 消費者訊息處理邏輯異常,導致訊息無法正常消費。

  • 訊息生產應用出現突發流量,訊息生產速度遠大於消費速度,訊息來不及消費出現堆積。

  • 消費者依賴的下遊服務耗時變長,消費線程阻塞等。

  • 消費線程不夠,消費並發度較小,消費速度跟不上生產速度。

您需要查看用戶端日誌或用戶端堆棧資訊,確定異常原因,具體操作,請參見如何處理訊息堆積

消費者消費不到訊息如何處理?

  1. 登入雲訊息佇列 RocketMQ 版控制台,進入Group 管理頁面,查看消費者是否線上,用戶端串連是否正常,若用戶端未串連,查看用戶端日誌根據報錯修改異常。

  2. 查看訂閱關係是否一致,若不一致根據訂閱關係的分布情況定位消費者用戶端,修改用戶端的訂閱訊息代碼。

若某個消費組下的機器宕機,機器重啟期間,訊息會不會丟失?

雲訊息佇列 RocketMQ 版的訂閱是持久化訂閱,ConsumerGroup下線或消費異常時,訊息不會丟失。當消費者用戶端重新上線後,直接從下線前的消費位點繼續消費訊息。

訂閱訊息時訊息Tag是否可以為空白?

訂閱訊息時Tag設定為空白會導致消費者消費不到任何訊息。若您希望訂閱Topic中的所有訊息,則需要將Tag設定為*。範例程式碼如下:

String topic = "Your Topic";
//使用Tag標籤過濾訊息,訂閱所有訊息。
FilterExpression filterExpression = new FilterExpression("*", FilterExpressionType.TAG);
pushConsumer.subscribe(topic, filterExpression);

更多資訊,請參見Tag標籤過濾

建立新的消費分組訂閱舊的Topic,如何設定消費起始位置?

消費者分組建立時不支援設定消費起始位置,不管是訂閱新的Topic還是舊的Topic,消費者第一次啟動時都會預設從Topic中的最早一條訊息開始消費。

消費者初次開機後,您可以在雲訊息佇列 RocketMQ 版控制台重設消費位點,具體操作,請參見重設消費位點

消費者線上無消費訊息,但Group有堆積

請檢查消費者使用Group對Topic的訂閱者式。如果消費者採用訊息過濾方式訂閱Topic,未命中過濾條件的訊息會被計算為堆積,符合設計預期。詳情參見訊息過濾

採用SQL/TAG消費過濾的方式,未消費到訊息但Group有訊息堆積,堆積量的計算如下所示。

  • SQL消費方式:堆積量 = 已就緒的訊息量 + 處理中的訊息量 - 未被SQL命中的訊息數量。

  • TAG消費方式:堆積量 =(已就緒的訊息量 + 處理中的訊息量)* TAG標籤訊息百分比。

說明

TAG標籤訊息百分比 = 採樣內TAG標籤訊息量 / 採樣訊息總量

儀錶盤訊息堆積量指標顯示訊息有大量堆積,但排查消費側,訊息已被消費

  1. 如果採用Remoting協議SDK,並在消費端將消費方式設定為廣播消費,則會產生這種現象。服務端依據訊息位點資訊判斷堆積情況,而廣播消費模式下消費位點是在用戶端維護的,因此會看到訊息堆積的情況。

  2. 消費端在採用TAG/SQL過濾方式進行消費時,未滿足過濾條件的訊息將被視為訊息堆積。