如何在服务流程中使用消息集成

栏目：云苍穹知识作者：金蝶来源：金蝶云社区发布：2024-09-23浏览：1

如何在服务流程中使用消息集成

服务流程是集成云推出的面向复杂集成场景的低代码服务编排工具，能够把已有的集成对象、集成方案、消息服务、API接口等集成资源，通过流程化设计编排成全新的应用服务，以支持更加复杂的业务场景。

例如基础数据分发到多个系统、数据消费需要从多源取数、基于某个数据参数处理不同的集成过程等等。

为了帮助大家快速掌握服务流程的使用方法，我们推出了系列文章，通过11个典型案例向大家介绍服务流程的高级技巧。

在上期集成云服务流程经典案例系列文章“如何在服务流程中进行API集成”中，我们为大家介绍了在服务流程中进行API集成的方法。

本期，小编继续为大家介绍第2个案例：如何在服务流程中使用消息集成，包括以下3个要点：

整体业务实现流程
如何配置消息队列服务器
如何配置消息集成节点

1 整体业务流程说明

第三方系统将数据推送到某个消息队列，集成云通过监听该消息队列，并将数据传送到微服务接口进行消费。

业务需求背景

2 操作流程解析

2.1 配置消息队列服务器

首先，提前准备消息服务器，可以是RabbitMQ/RocketMQ/Kafka等，此处使用的是RocketMQ。配置消息服务器IP、服务器端口、用户、密码、虚拟主机等，此处命名消息队列服务的编码为“industrial”。

更多关于消息服务的使用指南，可参考下方资料：

集成服务云-消息集成

配置消息队列服务器

2.2 配置消息订阅主题

消息订阅主题，指用于接收消息的队列，其编码为队列名。选择上一步配置的消息队列服务“industrial”，编码与需要接收的消息队列名一致，此处以“LOGISTIS-AT-SALE_TRANSPORT_ACTUAL_DATA”为例，如图所示。

同理，如果要使用消息队列发送消息，需配置消息发布主题。

配置消息订阅主题

2.3 配置服务流程属性

配置服务流程的【启动方式】为“消息启动”，并引入“消息订阅主题”和 “集成对象”，定义合适的变量用于接收过程中的数据。

基本信息配置

流程变量和依赖资源配置

2.4 配置服务流程消息集成节点

该流程整体比较简单，即接收消息队列的数据，当dataIn.status=='3'时，调用微服务，完成后续业务；否则，直接结束流程。

整体服务流程

2.5 配置消息启动节点

【消息订阅主题】选择依赖资源里的消息主题，并选择【赋值变量】。当收到消息时，数据将被赋值到【赋值变量】中并启动整个流程。

消息启动节点

2.6 脚本调用节点

根据上一步接收到的数据dataIn，在脚本节点调用微服务以完成后续逻辑。如图所示，为了保证该微服务具有执行权限，使用WithContext并以指定userId的身份执行该脚本片段。

脚本调用微服务节点

具体脚本如下：

 var loadNo = dataIn.fowardCode;
   var begintime = dataIn.startTime;
   var endtime = dataIn.finshTime;
   var map = {"waybillNo":loadNo,"begintime":begintime,"endtime":endtime, "company": 2};
   WithContext (userId : 1133976285819706368) { 
       // 脚本调用二开微服务
       var re= invokeMicroService("kd.ktms.operation.mservice@isv", "moya_operation", "WayBillCarTimeService", "save", map);
       if(re ?.outResult != '0') {
          throw re;// 如果re不为空，且outResult不为0，抛异常
         }
   }