全部產品
Search
文件中心

ApsaraMQ for RocketMQ:Group管理

更新時間:Dec 27, 2024

Group表示一類Producer或Consumer,這類Producer或Consumer通常生產或消費同一類訊息,且訊息發布或訂閱的邏輯一致。使用雲訊息佇列 RocketMQ 版進行訊息收發,您需要建立Group ID用於標識同一類生產者執行個體或者同一類消費者執行個體。本文介紹如何在雲訊息佇列 RocketMQ 版控制台上建立、刪除和查詢Group。

使用限制

  • 單一實例下最多建立1000個Group,建議您盡量複用或及時刪除不需要的Group。若您對Group數量有特殊需求,請聯絡雲訊息佇列 RocketMQ 版支援人員申請。

  • Group ID不能跨執行個體使用,例如執行個體A中建立的Group ID不能在執行個體B中使用。

  • 雲訊息佇列 RocketMQ 版支援HTTP協議和TCP協議的Group,不同的消費Group ID可以使用不同類型的協議消費訊息,建議您分別為兩種協議建立對應類型的Group ID。

    • 若多個消費者使用同一個Group ID消費訊息,其中部分消費者使用TCP協議,部分消費者使用HTTP協議,可能會導致消費失敗、部分訊息重複或丟失。

    • 同一Group ID不能平滑地從一個消費協議切換到另一個協議,切換過渡時間大概需要1~2小時。

    • 如果Group ID實際消費使用的協議和控制台上展示的協議不一致,會導致控制台上展示的相關資料不準確,但不會影響實際的訊息收發。您可以聯絡雲訊息佇列 RocketMQ 版支援人員申請將控制台上Group ID的協議類型訂正為您實際使用的協議類型。

  • 消費者必須有對應的Group ID,生產者不作強制要求。

Group ID命名規範

  • Group ID推薦以“GID_”或“GID-”開頭,長度限制為2~64個字元,只能包含英文、數字、短劃線(-)以及底線(_)。

  • 如果Group所在執行個體有命名空間,則Group ID需要保證執行個體內唯一,不能和本執行個體下已有的Group ID或Topic名稱重複;跨執行個體之間可以重名,例如執行個體A的Group ID可以和執行個體B的Group ID重複,也可以和執行個體B的Topic名稱重複。

  • 如果Group所在執行個體無命名空間,則Group ID需要保證跨執行個體和跨地區全域唯一,在全域範圍內不能和已有的Group ID或Topic名稱重複。

說明

執行個體是否有命名空間,可以在雲訊息佇列 RocketMQ 版控制台实例详情頁面的基础信息地區查看。

建立Group

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

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

  3. 在左側導覽列,單擊Group 管理

  4. Group 管理頁面選擇用戶端SDK的協議,然後單擊创建 Group

    雲訊息佇列 RocketMQ 版支援的用戶端SDK協議有TCP 协议HTTP 协议

  5. 在建立Group面板中,輸入該Group的Group ID描述,然後單擊確定

刪除Group

警告

刪除Group ID後,由該Group ID標識的消費者執行個體將立即停止接收訊息,Group的相關資源也同時被刪除且不可恢複,請您謹慎執行該操作。

  1. 執行個體列表頁面單擊目標執行個體名稱,然後在左側導覽列,單擊Group 管理

  2. 在Group列表中找到您需要刪除的Group,在其操作列單擊更多,然後在彈出的下拉式功能表中選擇删除

  3. 在彈出的對話方塊中單擊確認

查詢Group

  1. 執行個體列表頁面單擊目標執行個體名稱,然後在左側導覽列,單擊Group 管理

  2. 在Group列表中找到您需要查看的目標Group,單擊Group的ID或在其操作列單擊详情,進入Group詳情頁面。

更多操作

Group 管理頁面,您還可以執行其他相關操作。

  1. 在左側導覽列,單擊Group 管理

  2. 在Group列表中找到您需要操作的Group,在其操作列單擊更多,然後在彈出的下拉式功能表中選擇以下操作:

  • 快速接入:查看雲訊息佇列 RocketMQ 版提供的多語言SDK參考。

  • 重置消费位点:通過重設消費位點,按需清除堆積的或不想消費的這部分訊息再開始消費,或直接跳轉到某個時間點消費該時間點之後的訊息(不論是否消費過該時間點之前的訊息)。更多資訊,請參見重設消費位點

  • 云监控:查看當前Group下的訊息監控資料。

  • 仪表盘:查看當前Group的相關消費指標統計資料。

相關文檔

Group的相關操作也可以通過調用API完成。