全球消息路由
全球消息路由的功能和使用方式和開源Shovel插件保持一致,支持不同實例和Vhost間的Queue到Queue、Queue到Exchange的消息轉發。在此基礎上,除了可以本地域間消息轉發,也可以支持跨地域消息轉發,以便您按需同步消息,實現不同實例、不同Vhost間的消息路由。
注意事項
前提條件
云消息隊列 RabbitMQ 版
源實例、源Vhost、源Exchange、源Queue以及目標實例、目標Vhost、目標Exchange、目標Queue已創建并可用。具體操作,請參見:
事件總線EventBridge
創建全球消息路由任務
登錄云消息隊列 RabbitMQ 版控制臺,然后在左側導航欄,單擊全球消息路由。
在全球消息路由頁面單擊創建任務。
(可選)在阿里云服務授權 - 從消息隊列RabbitMQ版讀取消息對話框,認真閱讀提示信息,單擊確認。
首次創建全球消息路由任務,將自動創建服務的關聯角色AliyunServiceRoleForEventBridgeSourceRabbitMQ與AliyunServiceRoleForEventBridgeSendToRabbitMQ。具體信息,請參見服務關聯角色。
說明AliyunServiceRoleForEventBridgeSourceRabbitMQ:事件總線EventBridge使用該角色接收源端實例發送的消息。
AliyunServiceRoleForEventBridgeSendToRabbitMQ:事件總線EventBridge使用該角色轉發消息給目標端實例。
在創建消息路由任務配置向導頁面,配置消息路由的源端和目標端信息。
在基本信息頁面,填寫任務名稱和描述,然后單擊下一步。
在源和目標頁面,配置消息路由的源端和目標端信息,然后單擊下一步。
參數
解釋
示例
同步源信息
產品類型
消息路由源端的產品類型,固定為云消息隊列 RabbitMQ 版。
云消息隊列 RabbitMQ 版
地域
源端產品的實例所在的地域。
華南1(深圳)
實例
源端產品的實例ID。
amqp-cn-i7m2a8bq****
Vhost
源端產品的實例所部署的Vhost。
test-001
Queue
源端產品實例的Queue。
test-001-q
同步目標信息
產品類型
消息路由目標端的產品類型,固定為云消息隊列 RabbitMQ 版。
云消息隊列 RabbitMQ 版
地域
目標端產品的實例所在的地域。
華南1(深圳)
實例
目標端產品的實例ID。
amqp-cn-7pp2a85q****
Vhost
目標端產品的實例所部署的Vhost。
test-routing
目標類型
消息路由的目標類型。取值如下:
Queue:消息路由至目標實例的Queue中。
Exchange:消息路由至目標實例的Exchange。
說明目標類型為Exchange時,請確保目標Exchange有對應綁定的Queue,否則將導致路由轉發到此Exchange的消息沒有存儲的Queue而丟失。
test-routing-ex
RoutingKey
消息路由的Routing Key。當目標類型為Exchange時,該參數生效,取值如下:
不設置:使用消息原有的Routing key發送到目標Exchange。
設置:使用當前設置的Routing key發送到目標Exchange。
test
在創建啟動頁面,確認消息路由的配置信息,單擊創建并啟動。
在全球消息路由頁面,可以看到已創建的任務。其狀態為運行中。
相關文檔
關于開源Shovel插件的更多信息,請參見Shovel Plugin。