Fabric如何让事件自动发布到消息队列_区块链服务(BaaS)-阿里云帮助中心

如果您希望区块链上的各种事件能自动发布到消息中间件，您可以将区块链事件和MQ做映射配置。当区块链服务监听到链上事件时，会自动生成MQ消息并发布到MQ的主题上，您可以订阅MQ中的这些事件消息做进一步处理。

集成消息队列 RocketMQ

说明

注意：集成阿里云消息队列Rocket MQ服务，需要您先参考安装云服务集成章节完成云服务集成的安装。

登录阿里云BaaS控制台。
在 我的组织 中找到目标组织，单击右侧的 云服务集成。
将云服务集成页面的标签切换到 消息队列 RocketMQ。
单击 条件检测 检查云服务集成状态。
如果您未开通阿里云消息队列 RocketMQ服务，请单击开通服务进行开通。
如果您未授权阿里云区块链服务访问您的消息队列 RocketMQ服务，请单击授权服务进行授权。
当您看到如下状态时，表示集成完成。您可以单击添加配置，并参考以下流程配置事件触发器。

配置消息队列 Rocket MQ触发器

说明

注意：配置消息队列Rocket MQ触发器，需要您先参考安装云服务集成章节完成云服务集成的安装，并参考集成消息队列Rocket MQ章节集成消息队列Rocket MQ。

在消息队列 RocketMQ集成页面，单击添加配置。
在侧边栏中依次填写以下配置信息：
- 名称：触发器的名称，便于识别。
- 通道/网络：触发器需要监听并推送事件的Fabric通道。
- 事件类型：选择推送哪种类型的事件到外部服务，类型描述请参考文档订阅事件。
- MQ域名：MQ实例的HTTP协议接入点。
- MQ实例名称：MQ实例详情中显示的实例ID。
- MQ Topic：推送到MQ的消息 Topic。
- 消息Tag：可选，推送到MQ的消息Tag。
- 失败阈值：高级选项，触发器操作失败的次数超过该值后，触发器进入失败状态并停止推送。-1 表示失败次数不限，触发器不会进入失败状态。
- 过滤器：高级选项，可选，请参考文档使用过滤器。
单击添加，成功后列表会显示刚才创建的触发器。
说明
注意：当触发器推送区块链事件到集成的服务时，服务处理错误或参数配置错误会使触发器状态变为异常，鼠标悬停即可查看错误信息。触发器对应的服务返回异常时，触发器会自动重试，多次重试均失败后，会丢弃该事件，算一次失败。如果累计失败次数没有超过失败阈值，则继续推送其它事件。如果超过失败阈值，触发器进入失败状态并停止推送。用户可根据错误信息对触发器或相关服务进行修复后，再重新启用，启用后失败次数清零。块高字段表示当前触发器已处理到哪一个区块，也反应了事件处理进度。
创建成功后，您可以对触发器进行以下操作：
- 删除：删除该触发器。
- 禁用：停止推送事件到该触发器对应的服务。
- 启用：重新开始推送事件到该触发器对应的服务。启用后，将从当前最新区块的事件开始推送，停止期间的事件会被丢弃。