全部产品

消息队列

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

集成消息队列 RocketMQ

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

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

配置消息队列 Rocket MQ触发器

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

  1. 在消息队列 RocketMQ集成页面,单击添加配置
  2. 在侧边栏中依次填写以下配置信息:

    • 名称:触发器的名称,便于识别。
    • 通道/网络:触发器需要监听并推送事件的Fabric通道。
    • 事件类型:选择推送哪种类型的事件到外部服务,类型描述请参考文档订阅事件
    • MQ域名:MQ实例的HTTP协议接入点。
    • MQ实例名称:MQ实例详情中显示的实例ID。
    • MQ Topic:推送到MQ的消息 Topic。
    • 消息Tag:可选,推送到MQ的消息Tag。
    • 失败阈值:高级选项,触发器操作失败的次数超过该值后,触发器进入失败状态并停止推送。-1 表示失败次数不限,触发器不会进入失败状态。
    • 过滤器:高级选项,可选,请参考文档使用过滤器

    配置MQ

  3. 单击添加,成功后列表会显示刚才创建的触发器。创建完成

    注意:

    • 当触发器推送区块链事件到集成的服务时,服务处理错误或参数配置错误会使触发器状态变为异常,鼠标悬停即可查看错误信息。
    • 触发器对应的服务返回异常时,触发器会自动重试,多次重试均失败后,会丢弃该事件,算一次失败。如果累计失败次数没有超过失败阈值,则继续推送其它事件。如果超过失败阈值,触发器进入失败状态并停止推送。用户可根据错误信息对触发器或相关服务进行修复后,再重新启用,启用后失败次数清零。
    • 块高字段表示当前触发器已处理到哪一个区块,也反应了事件处理进度。
  4. 创建成功后,您可以对触发器进行以下操作:

    • 删除:删除该触发器。
    • 禁用:停止推送事件到该触发器对应的服务。
    • 启用:重新开始推送事件到该触发器对应的服务。启用后,将从当前最新区块的事件开始推送,停止期间的事件会被丢弃。