全部产品

链上信息发布到消息队列

前置条件

  1. 您需要在区块链实例中安装云服务集成, 并开通RocketMQ集成功能。
  2. 创建一个 RocketMQ消息队列 实例,文中以实例“fabric-instance”,消息主题“event”为例。
  3. 下载云服务集成示例代码
  4. 本地安装 Node.js v8 环境(>=8.17.0)

使用方法

  1. 在控制台创建云服务集成消息队列触发器,更多可以参考配置消息队列触发器
    1. 配置触发器的事件类型为 Tx。
    2. 根据帮助,填写RocketMQ实例的相关信息。
  2. 按照文档部署链码将示例链码 taskmgr 部署到通道中。
  3. 进入 blockchain2sms 目录,按照注释修改 main.js 中的配置参数,填入REST API地址、Refresh Token、通道名和智能合约名称。更多信息请参考文档使用REST API
  4. 执行 npm install 安装依赖包,通过 node main.js 发起示例交易。
  5. 进入RocketMQ控制台,便可查询到已经推送到消息队列的消息。RocketMQ集成

成功示例输出

  1. Data pushed to blockchain with transaction 701c7006f26aed8457273a00bbfcc8cea4d75eac958996e07837036ea7e2fdac
  2. { id: '701c7006f26aed8457273a00bbfcc8cea4d75eac958996e07837036ea7e2fdac',
  3. status: '200',
  4. events:
  5. [ { type: 'Contract',
  6. platform: 'Fabric',
  7. instance_id: 'csi-e2ehmfqasth-bcw7tzao2dzeo',
  8. network: '',
  9. id: '',
  10. name: 'event-create-task',
  11. content: 'eyJuY...TAz' }
  12. Data pushed to blockchain with transaction 60a06a189415db587b49cbf91b46467bce1ea16490b19f6dfc8d520aa31240bc
  13. { id: '60a06a189415db587b49cbf91b46467bce1ea16490b19f6dfc8d520aa31240bc',
  14. status: '200',
  15. events:
  16. [ { type: 'Contract',
  17. platform: 'Fabric',
  18. instance_id: 'csi-e2ehmfqasth-bcw7tzao2dzeo',
  19. network: '',
  20. id: '',
  21. name: 'event-task-finished',
  22. content: 'eyJuY...p7In0=' } ],
  23. data: 'eyJu...In0=' }
  24. Data pushed to blockchain with transaction 7810e0496a1c91a16102736b00a6f26da0baa42874a907fff26bff1b7eb3bf27
  25. { id: '7810e0496a1c91a16102736b00a6f26da0baa42874a907fff26bff1b7eb3bf27',
  26. status: '200',
  27. events: [],
  28. data: 'eyJu...nIn0=' }