分布式消息服务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管理控制台中查看消息详情