全球消息路由
全球消息路由功能可用于跨地域間的消息同步,通過路由規(guī)則將消息從源實例的Topic中同步到目標實例的Topic,并支持過濾規(guī)則,按照指定的Tag將消息過濾后再進行同步。在容災(zāi)備份或異地多活場景下,您可以創(chuàng)建全球消息路由任務(wù),確保跨地域間實例數(shù)據(jù)的一致性與完整性。
什么是全球消息路由
云消息隊列 RocketMQ 版的全球消息路由功能依托阿里云優(yōu)質(zhì)基礎(chǔ)設(shè)施實現(xiàn)的高速通道專線(高速通道無需另行開通),高效地實現(xiàn)不同地域之間的消息同步復(fù)制。具體實現(xiàn)如下圖所示。
計費影響
全球消息路由為云消息隊列 RocketMQ 版的高級功能,使用該功能會帶來額外的費用,包含消息傳輸費用和任務(wù)資源占用費用。更多信息,請參見全球消息路由定價詳情。
地域限制
目前僅公網(wǎng)地域不支持全球消息路由功能,其他地域均支持。
全球消息路由功能不支持傳遞路由,例如地域A到地域B再到地域C,地域A的消息不會經(jīng)過地域B再路由到地域C,如有需要請直接創(chuàng)建地域A到地域C的路由。
為加強網(wǎng)絡(luò)信息安全管理,提高數(shù)據(jù)安全性,全球消息路由功能不支持跨境及跨國傳輸,具體規(guī)則如下:
中國內(nèi)地的各地域之間可以同步消息,中國內(nèi)地不支持和中國香港及海外地區(qū)的所有地域同步消息。
中國香港地域僅支持在本地域內(nèi)同步消息,不支持和中國內(nèi)地及海外地區(qū)所有地域同步消息。
海外地區(qū)僅支持在同一國家內(nèi)不同地域間同步消息,各國家之間的地域不支持同步消息。
注意事項
源Topic和目標Topic的消息類型需保持一致,如果源Topic是普通消息,則同步到的目標Topic也應(yīng)是普通消息。
考慮到需要同步的消息量以及網(wǎng)絡(luò)帶寬瓶頸,消息同步可能會產(chǎn)生一定的時間延遲,即消息到達目標Topic的時間會晚于該消息進入源Topic的時間。
處于全球消息路由任務(wù)中的源實例和目標實例,將無法從標準版實例升級到鉑金版實例。
創(chuàng)建全球消息路由任務(wù)
- 登錄云消息隊列 RocketMQ 版控制臺。
在左側(cè)導(dǎo)航欄,單擊全球消息路由。
在全球消息路由頁面的左上方,單擊創(chuàng)建消息路由任務(wù)。
在創(chuàng)建全球消息路由任務(wù)面板,填寫以下信息后,單擊確定。
參數(shù)
說明
消息源
源地域:選擇需要同步的源Topic所屬實例的地域。
源實例:選擇需要同步的源Topic所屬實例。
源 Topic:選擇需要同步消息的源Topic。
消息目標
目標地域:選擇消息同步的目標Topic所屬實例的地域。
目標實例:選擇消息同步的目標Topic所屬實例。
目標 Topic:選擇消息同步的目標Topic。
過濾規(guī)則
輸入過濾規(guī)則,按照該規(guī)則過濾后的消息才會被同步。您可直接輸入Tag名按Tag過濾,例如您的消息Tag屬性為CartService,則直接輸入CartService;如果需要過濾多個Tag屬性,則用雙豎線(||)隔開,例如CartService||Inventory||Payment。具體過濾方法請參見消息過濾。
描述
輸入對該同步任務(wù)的具體描述或備注,以作區(qū)分和記錄。
立即啟用
是,創(chuàng)建后立即啟用路由任務(wù):表示全球消息路由任務(wù)創(chuàng)建成功后系統(tǒng)立即執(zhí)行該任務(wù),任務(wù)狀態(tài)為已啟用。
否,稍后手動啟用路由任務(wù):表示路由任務(wù)創(chuàng)完成后,任務(wù)狀態(tài)為未啟用,您需要手動啟用該任務(wù)系統(tǒng)才會開始執(zhí)行。
其他操作
您可以在全球消息路由頁面搜索、啟停、查看、刪除任務(wù),也可在任務(wù)詳情頁為任務(wù)編輯過濾規(guī)則。
搜索任務(wù)
在全球消息路由頁面,您可根據(jù)源地域、源實例ID、源Topic、目標地域、目標實例ID、目標Topic查詢?nèi)蝿?wù)。
啟停單項任務(wù)
在全球消息路由頁面的任務(wù)列表中,找到需要啟停的任務(wù),在其操作列選擇
或 來啟用或停用規(guī)則。任務(wù)啟動后,該任務(wù)的狀態(tài)會切換至已啟用。
任務(wù)停止后,該任務(wù)的狀態(tài)會切換至已停用。
批量啟停任務(wù)
云消息隊列 RocketMQ 版支持批量啟停任務(wù),當(dāng)您的業(yè)務(wù)使用了多個消息路由任務(wù),為了提高維護操作效率,您可以使用批量啟停功能一鍵啟停多個任務(wù)。
在全球消息路由頁面的任務(wù)列表中,選中需要批量啟停的多個任務(wù),單擊列表上方的批量啟用規(guī)則或批量停用規(guī)則,然后在彈出的提示對話框中的單擊確認。
批量啟用規(guī)則后,所有被選中的任務(wù)的狀態(tài)會切換至已啟用。
批量停用任務(wù)后,所有被選中的任務(wù)的狀態(tài)會切換至已停用。
刪除任務(wù)
刪除任務(wù)前需要先停止任務(wù)。
在全球消息路由頁面的任務(wù)列表中,找到需要刪除的任務(wù),在其操作列選擇
,即可刪除該任務(wù)。查看任務(wù)詳情
在全球消息路由頁面的任務(wù)列表中,找到需要查看的任務(wù),在其操作列單擊詳情,即可查看該任務(wù)的任務(wù)詳情和消息詳情,以及編輯過濾規(guī)則。
全球消息路由詳情頁面的關(guān)鍵字段的說明如下表所示。
參數(shù) | 說明 |
任務(wù)狀態(tài) | 任務(wù)狀態(tài)可以是未啟用、已啟用、已停用。 |
消息同步TPS | 每分鐘統(tǒng)計一次消息同步的TPS值;TPS即平均每秒傳輸?shù)南?shù)量。 |
消息延遲 | 當(dāng)前同步到的位點和最新消息位點之間的時間差。 |
消息堆積量 | 當(dāng)前還沒有來得及同步的消息數(shù)量。 |
最新同步時間 | 最近一次消息同步發(fā)生的時間。 |
編輯過濾規(guī)則
編輯過濾規(guī)則,需先停止任務(wù)。
在基礎(chǔ)信息區(qū)域的過濾規(guī)則一欄,單擊編輯圖標,即可對過濾規(guī)則進行修改。
您可直接輸入Tag名按Tag過濾,例如您的消息Tag屬性為CartService,則直接輸入CartService;如果需要過濾多個Tag屬性,則用雙豎線(||)隔開,例如CartService||Inventory||Payment。具體過濾方法,請參見消息過濾。
相關(guān)參考
使用全球消息路由功能需要收費,具體費用,請參見全球消息路由定價詳情。