分布式消息服务RocketMQ版

本章节介绍在控制台添加分布式消息服务RocketMQ版自定义事件源的方法。

前提条件

（可选）创建自定义事件源前，需要先创建自定义事件通道。
已购买分布式消息服务RocketMQ版实例，实例中已创建Topic，且实例状态处于“运行中”。具体步骤，请参考购买实例。
已创建私网访问端点，其VPC及子网与RocketMQ实例相同。
已正确配置default安全组和RocketMQ实例所属的安全组规则，具体规则请参考创建事件源如何配置安全组。

创建RocketMQ事件源

登录事件网格控制台。
在左侧导航栏选择“事件源”，进入“事件源”页面。
单击“自定义事件源”，弹出“创建自定义事件源”对话框。

参考表1，填写自定义事件源的配置信息。

表1 RocketMQ事件源参数说明
参数名称	说明
配置类型	支持以下两种类型：选择：选择一个已创建的自定义事件通道。新建：创建一个新的自定义事件通道。
通道	“配置类型”为“选择”时，在下拉列表中选择一个已创建的自定义事件通道。 “配置类型”为“新建”时，输入事件通道名称和描述信息。事件源创建成功后，事件通道不支持修改。
事件源名称	您自定义的事件源名称，用于识别不同的事件源。事件源创建成功后，事件源名称不支持修改。
描述（可选）	事件源的描述信息。
事件源类型	事件源类型选择“分布式消息服务RocketMQ版”。说明：如之前未创建授权委托，事件源类型首次选择“分布式消息服务RocketMQ版”时，系统会自动弹出创建委托授权界面，需要您创建授权委托，详情请查看授权委托。
RocketMQ实例	选择消息队列RocketMQ版中的实例名称。若选择“无”，表示添加用户自建的消息队列RocketMQ版实例。
Topic	RocketMQ实例的Topic。
消费组	RocketMQ实例的消费组。
用户名	RocketMQ实例开启ACl访问控制的时候需要填写实例的用户名。
密钥	RocketMQ实例开启ACl访问控制的时候需要填写实例的密钥。
虚拟私有云	当“RocketMQ实例”选择“无”时参数可见，选择虚拟私有云。
子网	当“RocketMQ实例”选择“无”时参数可见，选择子网。
连接地址	当“RocketMQ实例”选择“无”时参数可见，输入自建RocketMQ版实例的连接地址。
SSL	当“RocketMQ实例”选择“无”时参数可见，配置是否开启SSL。说明：自建RocketMQ事件源处于“运行中”时，不支持修改SSL。如果涉及SSL变化，建议该事件源删除重建。
ACL访问控制	当“RocketMQ实例”选择“无”时参数可见，配置是否开启ACL访问控制。

单击“确定”，完成自定义事件源的创建。

创建成功后，在“自定义事件源”页签，查看创建的事件源。
- 如果需要修改自定义事件源的描述信息，单击待修改事件源后的“编辑”，在弹出的对话框中编辑描述及相关参数信息。
- 如果需要查看自定义事件源的信息，单击待查看信息的事件源名称，在弹出的对话框中查看自定义事件源信息。

事件格式查看

前提条件：

创建rocketmq实例。
图1 rocketmq实例
创建和rocketmq实例同一vpc、子网的访问端点。

创建事件通道。

图2 创建事件通道
创建rocketmq事件源。

图3 rocketmq事件源
创建rocketmq事件订阅。

图4 创建rocketmq事件订阅

图5 创建事件订阅成功后rocketmq事件源变为运行中
发送事件。

图6 发送事件

查看事件消息格式。

查看事件轨迹的事件详情：

图7 事件轨迹详情

消息体事件格式如下：

{
  "datacontenttype": "application/json",
  "data": {
    "context": "{\"hello\":\"world\"}",
    "topic": "topic-test"
  },
  "subject": "ROCKETMQ:cn-north-4:f003dc69-2fc3-4c44-9062-0b9a2c6cb8cc/0ef1e7a03280f3ed2f69c00c652a5744:ROCKETMQ:source-rocketmq",
  "specversion": "1.0",
  "id": "e6cc599b-0664-4078-87dd-5630087d5f7e",
  "source": "source-rocketmq",
  "time": "2024-02-05T14:20:31Z",
  "type": "ROCKETMQ:CloudTrace:RocketmqCall"
}