分布式消息服务RocketMQ版

前提条件

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

创建RocketMQ事件源

1. 登录事件网格控制台。
2. 在左侧导航栏选择“事件源”，进入“事件源”页面。
3. 单击“自定义事件源”，弹出“创建自定义事件源”对话框。
4. 参考表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访问控制。

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

   创建成功后，在“自定义事件源”页签，查看创建的事件源。

   

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

事件格式查看

前提条件：

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

1. 创建事件通道。
   图2 创建事件通道
   

2. 创建rocketmq事件源。
   图3 rocketmq事件源
   

   

3. 创建rocketmq事件订阅。
   图4 创建rocketmq事件订阅
   
   图5 创建事件订阅成功后rocketmq事件源变为运行中

   

4. 发送事件。
   图6 发送事件
   

   

5. 查看事件消息格式。
   1. 查看事件轨迹的事件详情：
      图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"
      }

   2. 查看目标函数日志：
      图8 目标函数日志