背景信息
在實例創建完成后,需要創建主題和訂閱組來進行消息實例的日常功能運轉。
- 主題:在RocketMQ中,主題(Topic)是消息發布的邏輯分組。它類似于一個消息的分類或者標簽,幫助用戶將不同類型的消息進行歸類和管理。通常情況下,一個主題可以包含多個消息生產者和多個消息消費者。通過使用主題,RocketMQ能夠實現高效的消息發布和訂閱機制,幫助用戶更好地管理和組織消息。
- 訂閱組:訂閱組是 RocketMQ 中的一個重要概念,用于實現消息的發布與訂閱模式。一個訂閱組可以包含多個消費者實例,這些實例共同消費同一個主題下的消息。當消息被發送到主題時,訂閱組中的每個消費者實例會按照一定規則來均衡地接收消息,并進行相應的處理。訂閱組是 RocketMQ 提供的一種靈活且可擴展的方式,用于實現消息的發布與訂閱模式,并保證消息在消費者之間的均衡分配和可靠處理。
- 集群:RocketMQ集群是一種由多個節點(或者稱為Broker)組成的分布式消息中間件系統。每個節點都具有相同的功能并且可以處理和存儲消息。通過將消息分發到不同的節點,RocketMQ集群能夠實現高可用性和可伸縮性。通過使用RocketMQ集群,可以實現消息傳輸的并行處理、容錯性和高可用性,滿足高并發場景下的消息傳遞需求。
創建主題
1、 天翼云官網點擊控制中心,選擇產品分布式消息服務RocketMQ。
2、 登錄分布式消息服務RocketMQ控制臺,點擊右上角地域選擇對應資源池。
3、 進入實例列表,點擊【管理】按鈕進入管理菜單。

4、 進入主題管理菜單,點擊【新建主題】按鈕

5、 在彈出的新建主題頁面,填寫如下字段信息

1)默認展示當前集群名稱,不可修改。
2)選擇主題所在的Broker,按照實例創建時候選擇的主備節點對數列出每個broker,可復選。
3)填寫主題名稱,名字限制2到64個字符,超過限制會導致創建主題失敗,用戶創建主題只能包含大小寫字母數字以及_和-符號。
4)按照實際需求填寫主題備注。
5)填寫每個Broker分區數,分區數必須大于0,小于等于8,創建嚴格順序隊列時,設置分區數為1,且只能選擇一個broker。
6)選擇生產模式,RocketMQ是一個開源的分布式消息中間件,它支持兩種消息生產模式:有序和無序。
- 有序消息生產模式(Ordered Message)是指按照特定規則將消息發送到相同的Message Queue中,并且確保消息在消費者端按照相同的順序進行消費。這種模式適用于那些需要嚴格按照消息順序進行處理的場景,比如訂單處理、流程審批等。
- 無序消息生產模式(Unordered Message)是指消息發送到不同的Message Queue中,每個Queue都是獨立的。消費者可以并行地從多個Queue中消費消息,而無需關心消息的順序。這種模式適用于那些不需要嚴格按照消息順序處理的場景,比如日志收集、異步通知等。
需要注意的是,無論是有序還是無序消息生產模式,RocketMQ都提供了高可靠性的消息傳輸和存儲,并支持水平擴展和高吞吐量的特性。根據具體的業務需求,選擇適合的消息生產模式能夠更好地滿足應用的要求。
7)選擇主題的讀寫權限,支持讀寫、只讀、只寫3類權限。
6、 完成主題信息填寫后,保存確認即可新增主題。
7、 若希望批量創建主題,可點擊【批量創建】按鈕
- 批量創建
注意:輸入的主題名不要帶空格等特殊字符。
通過上傳csv文件,批量創建主題。格式:點擊【主題模板】按鈕下載。
- 主題模板
批量上傳主題的模板,必須使用模板,才能夠上傳成功,模板格式如下:

創建訂閱組
1、進入訂閱管理菜單,點擊【新建】按鈕

2、 在彈出的新建訂閱組窗口填寫相應字段。

1)默認展示當前集群名稱,不可修改。
2)填寫訂閱組名稱,名字限制2到64個字符,超過限制會導致創建訂閱組失敗,用戶創建訂閱組只能包含大小寫字母數字以及_和-符號。
3)按照實際需求填寫主題備注。
4)選擇訂閱組所在的Broker,按照實例創建時候選擇的主備節點對數列出每個broker,可復選。
5)選擇是否開啟消費,默認開啟消費。
3、 完成訂閱組信息填寫后,保存確認即可新增訂閱組。
4、 若希望批量創建訂閱組,可點擊【批量創建】按鈕
- 批量創建
注意:注意輸入的訂閱組名不要帶空格等特殊字符
通過csv格式模板上傳,批量創建訂閱組。格式:點擊【訂閱組模板】按鈕下載。
- 訂閱組模板
指批量上傳訂閱組的模板,必須使用模板,才能夠上傳成功,模板格式如下:
