消息層配置
更新時間 2025-10-16 16:22:53
最近更新時間: 2025-10-16 16:22:53
分享文章
本章節介紹應用容災多活的消息層配置。
概述
消息層配置主要包括消息隊列和消息同步,每個單元組可以單獨進行配置,不同單元的消息隊列之間通過消息路由服務進行同步。
應用容災多活通過控制面與數據面協同,對指定Topic消息進行打標與過濾。當某個單元發生故障時,可以通過切流任務將故障單元的消息在其他正常單元進行回溯接管,從而保障消息不丟失。
圖 消息層配置
前提條件
- 已開通消息層功能模塊。
- 已完成系統架構配置以及路由規則配置。
- 已為應用開通分布式消息服務RocketMQ實例。
- 已為不同站點的實例創建同名的Topic和Group。
配置消息隊列
- 登錄應用高可用服務控制臺。
- 單擊左側菜單欄應用容災多活,在應用容災多活菜單下單擊數據雙活/應用雙活,進入數據雙活/應用雙活管理頁面。
- 在應用系統列表中找到需要配置的應用系統,單擊應用系統名稱,進入應用系統概覽頁面。
- 單擊左側導航欄容災配置,在容災配置菜單下單擊消息層配置,進入容災配置-消息層配置頁面。
- 單擊消息隊列配置列表上方創建按鈕,彈出創建消息隊列配置頁面。
- 如下表示例,填寫配置信息,單擊確定按鈕,完成配置。
- 如需修改或刪除消息隊列配置,可單擊所選配置操作列修改或刪除按鈕,根據界面提示進行操作。
表 消息隊列配置
| 配置項 | 描述 | 示例 |
|---|---|---|
| 消息隊列名稱 | 消息隊列自定義標識。 | 商城北京消息隊列 |
| 站點 | 消息隊列部署所在站點。 | 北京站點 |
| 產品類型 | 消息隊列技術類型: - RocketMQ |
RocketMQ |
| 實例類型 | 消息隊列產品類型。 | 云實例 |
| 消息隊列實例 | 消息隊列對應的云實例ID。 | RocketMQ-***810 |
配置同步任務
- 登錄應用高可用服務控制臺。
- 單擊左側菜單欄應用容災多活,在應用容災多活菜單下單擊數據雙活/應用雙活,進入數據雙活/應用雙活管理頁面。
- 在應用系統列表中找到需要配置的應用系統,單擊應用系統名稱,進入應用系統概覽頁面。
- 單擊左側導航欄容災配置,在容災配置菜單下單擊消息層配置,進入容災配置-消息層配置頁面。
- 單擊消息同步任務列表上方創建按鈕,彈出創建消息同步任務配置頁面。
- 如下表示例,填寫配置信息,單擊確定按鈕,完成配置。
- 如需修改或刪除消息同步配置,可單擊所選配置操作列更多按鈕,在下拉列表中選擇編輯或刪除,根據界面提示進行操作。
表 消息同步任務配置
| 配置項 | 描述 | 示例 |
|---|---|---|
| 消息同步名稱 | 消息同步自定義標識。 | 商城消息同步任務 |
| 消息隊列實例 | 需要同步的消息隊列。 | 商城北京消息隊列 |
說明
每個消息同步任務必須關聯2個消息隊列,每個消息隊列只能關聯一個消息同步任務。
配置路由任務
- 登錄應用高可用服務控制臺。
- 單擊左側菜單欄應用容災多活,在應用容災多活菜單下單擊數據雙活/應用雙活,進入數據雙活/應用雙活管理頁面。
- 在應用系統列表中找到需要配置的應用系統,單擊應用系統名稱,進入應用系統概覽頁面。
- 單擊左側導航欄容災配置,在容災配置菜單下單擊消息層配置,進入容災配置-消息層配置頁面。
- 在消息同步任務列表,單擊所選配置操作列配置任務按鈕,進入配置消息路由任務頁面。
- 單擊右上方創建按鈕,彈出創建消息路由任務頁面。
- 如下表示例,填寫配置信息,單擊確定按鈕,完成消息路由任務創建。
- 在消息路由任務列表,單擊主題前面 > 圖標,展開不同方向消息路由任務。
- 在所選路由方向配置行,單擊操作列創建按鈕,根據界面提示開啟路由任務。
表 消息路由任務配置
| 配置項 | 描述 | 示例 |
|---|---|---|
| 主題 | 需要進行同步的Topic。 | order-topic |
| 所屬單元組 | 消息同步所屬業務分組,綁定其中路由規則。 | 訂單單元組 |
| 默認回退位點 | 相對于當前時間的回退間隔,重置位點等于當前時間-默認回退位點。 - 切流任務會按照配置回退邏輯消費點位,以便接管故障單元堆積消息。 |
05:56:16 |
表 路由任務狀態
| 狀態 | 描述 |
|---|---|
| 未創建 | 路由任務未創建。 |
| 已啟用 | 路由任務已開啟。 |
| 已停用 | 路由任務已關閉。 |
| 啟用中 | 路由任務正在啟動。 |
| 已刪除 | 路由任務已刪除。 |
注意
在刪除消息同步任務之前,您必須先刪除其管理的消息路由任務。
在刪除消息路由任務之前,您必須先停止該消息路由任務。
您需要保障消息處理的冪等性,明確消息回溯重放對業務的影響,并選擇合適的回退位點。