您可以通过事件规则过滤事件,将事件路由到消息服务MNS的队列。本文以自定义事件为例介绍将事件路由到消息服务的前提条件、操作步骤和结果验证。
步骤一:添加自定义事件源
- 登录事件总线EventBridge控制台。
- 在左侧导航栏,单击事件总线。
- 在顶部菜单栏,选择地域。
- 在事件总线页面,单击目标总线名称。
- 在左侧导航栏,单击事件源。
- 在事件源页面,单击添加事件源。
- 在添加自定义事件源面板,输入名称和描述,事件提供方选择自定义应用,然后单击确定。
步骤二:创建事件规则
- 登录事件总线EventBridge控制台。
- 在左侧导航栏,单击事件总线。
- 在顶部菜单栏,选择地域。
- 在事件总线页面,单击目标总线名称。
- 在左侧导航栏,单击事件规则。
- 在事件规则页面,单击创建规则。
- 在创建规则页面,完成以下操作。
- 在配置基本信息配置向导,在名称文本框输入规则名称,在描述文本框输入规则的描述,然后单击下一步。
- 在配置事件模式配置向导,事件源类型选择自定义事件源,事件源选择步骤一添加的自定义事件源,在事件模式内容代码框输入事件模式,然后单击下一步。
- 在配置事件目标配置向导,配置事件目标,然后单击创建。
步骤三:发布事件
- 登录事件总线EventBridge控制台。
- 在左侧导航栏,单击事件总线。
- 在顶部菜单栏,选择地域。
- 在事件总线页面,找到目标总线,在其右侧操作列单击发布事件。
- 在发布事件至自定义事件总线面板,自定义事件源下拉列表选择已创建的自定义事件源,在事件体代码框输入事件内容,然后单击确定。
结果验证
您可以在消息服务MNS控制台确认是否接收到事件。
- 登录消息服务MNS控制台。
- 在左侧导航栏,单击队列列表。
- 在顶部菜单栏,选择地域。
- 在队列列表页面,找到目标队列,在其右侧操作列选择。
- 在队列收发消息快速体验页面的接收消息区域,单击接收消息。
注意 通过消息服务MNS的Java SDK接收投递过来的事件时,由于消息的Body没有经过Base64编码,会导致接收到的消息为乱码。因此,需要使用getMessageBodyAsRawBytes或者getMessageBodyAsRawString来获取事件的Body。
接收到的示例消息内容如下所示。
{
"id":"22h0iaji-8cf5-2iea-j4a6-i99a5j1a****",
"source":"acs.oss",
"specversion":"1.0",
"type":"oss:ObjectCreated:PostObject",
"datacontenttype":"application/json;charset=utf-8",
"dataschema":"http://example.com/item.json",
"subject":"acs:oss:cn-hangzhou:<yourAccountId>:xls-papk/game_apk/123.jpg",
"aliyunaccountid":"165228866041****",
"aliyunpublishtime":"2020-10-14T17:00:03.628Asia/Shanghai",
"aliyuneventbusname":"MyEventBus",
"aliyunpublishaddr":"10.0.XX.XX",
"data":{
"name":"Eventbridge",
"number":100
}
}