分布式消息服務RocketMQ事件目標
更新時間 2025-06-18 17:55:19
最近更新時間: 2025-06-18 17:55:19
分享文章
您可以通過事件規則過濾事件,將事件路由到分布式消息服務RocketMQ。本文以自定義事件為例介紹將事件路由到分布式消息服務RocketMQ的前提條件、操作步驟和結果驗證。
前提條件
開通分布式消息服務RocketMQ,創建實例實例并創建好相應的主題
操作步驟
登錄事件總線EventBridge控制臺,在左側導航欄,單擊事件總線。
選擇目標總線,點擊事件源按鈕,點擊添加事件源按鈕,創建一個自定義事件源;填寫事件源名,事件提供方可選擇自定義應用。
在左側導航欄,單擊事件規則,然后單擊創建規則。
在創建規則頁面,完成以下操作,如圖1所示。
在配置基本信息配置向導頁面中,在名稱文本框輸入規則名稱,在描述文本框輸入規則的描述,然后單擊下一步。
在配置事件模式配置向導頁面中,事件源類型選擇自定義事件源,事件源選擇對應的自定義事件源,在事件模式內容代碼框輸入事件模式,這里可選擇匹配全部事件,然后單擊下一步。
在配置事件目標配置向導頁面中,配置事件目標,分布式消息服務RocketMQ目標參數描述如下,然后單擊創建。
圖1 創建事件規則時選擇服務類型為分布式消息服務RocketMQ
參數說明
| 參數 | 說明 | 示例 |
|---|---|---|
| 實例 | 選擇分布式消息RocketMQ實例。 | instance-xxx |
| Topic | 選擇RocketMQ實例的Topic。 | topic1 |
| 消息體 | 選擇消息體(Body)的內容,更多內容請參考事件內容轉換。 | 全部事件 |
| 自定義屬性 | 選擇自定義屬性(Properties)的內容,更多內容請參考事件內容轉換。 | 空 |
| 索引 | 選擇索引(Keys)的內容,更多內容請參考事件內容轉換。 | 空 |
| 標簽 | 選擇標簽(Tags)的內容,更多內容請參考事件內容轉換。 | 空 |
結果驗證
使用事件總線發布消息功能,發送一個自定義事件。
您可以在分布式消息服務RocketMQ控制臺確認是否接收到事件。
登錄分布式消息服務RocketMQ控制臺,然后在左側導航欄選擇實例列表。
在實例列表頁面單擊目標實例名稱。
在消息查詢頁面,按時間查詢即可查看消息內容,如圖2所示。
圖2 在分布式消息服務RocketMQ管理控制臺中查看消息詳情