国标解读（六） | 智能制造核心标准《智能制造应用互联 第1部分：集成技术要求》——融通互联引擎模型参考

通过采用协议适配单元、计算节点单元、入站队列单元、出站队列单元，并将各功能单元依次连接，根据业务需求，采用消息流可视化编排工具进行开发，首先将特征参数或功能参数等数据进行采集与融合，并通过相应协议接口将其映射至相应功能单元，具体为：规定消息流中各功能单元的操作逻辑，包括路由计算、协议适配、格式转换等，并记录各功能单元执行操作逻辑产生日志数据，消息流实现应有以下功能：

a)创建并执行消息流中节点的运算处理逻辑；

b)实现总线两端应用系统的信息交换通道；

c)根据协议包装器定义的行为信息，读取信息装配实例数据；

d)消息流中每个节点的执行操作逻辑（路由计算、协议适配、格式转换等）完成消息体的计算、传递；

e)记录消息体执行操作逻辑（路由计算、协议适配、格式转换等）产生日志数据。

▲ 消息流处理管道构建策略

消息流引擎应有以下功能：

a)按照消息流定义的逻辑顺序，对消息报文进行传输处理；

b)实现对报文数据实时地操作和处理；

c)根据业务需求进行计算分析；

d)保存上述数据的分析与处理结果，记录日志；

e)分发至所需的功能单元，最后消息流按所属功能单元进行规则化传输。

协议包装器的定义由接口、协议适配器和管理壳模型的组合而成，通过包装器注册管理器实现注册，预先定义接口协议类型、接口参数、接口数据模型、数据发布方式（请求响应、发布订阅、推送等）、路由通道模板、数据格式转换策略、安全鉴权机制，并生成协议包装器的唯一标识ID,作为公开服务的服务标识后缀，协议包装器的注册定义的参数在消息流引擎启动时进行初始化常驻内存，消息报文经过消息流管道时，对消息体的内容进行解析，并与注册的数据信息进行匹配计算获得报文的路由信息，从而将动态的路由的报文传输至目的地。

协议包装器模型的生成，如图所示“服务目录”，通过注册后形成虚拟数字资产，即服务目录。

▲ CPS融通互联引擎架构

源软件系统和物理设备是进行数据交换的原生的系统，这些原生系统需提供对外访问的协议接口，协议接口的协议类型包括Web Service、FTP、RPC、MQ、MQTT、OPC UA等，各个系统选择最优的协议方式提供接口。

将各个系统的信息注册进包装器注册管理平台，给予每个系统唯一的标识号，便于在进行数据采集和交换时给数据打标签，表明系统注册后，再将各个系统提供的协议接口通过接口参数的定义，绑定协议适配器模板，在包装器注册管理平台上进行注册，自动生成服务接口编号，从而形成服务目录，表明信息格式和交换信息所需的支撑协议、信息内容等信息。

在包装器注册管理平台服务目录上对已注册的每个服务赋予访问权限和服务订阅分配权限，通过服务管理平台提供服务的各种协议访问地址，对外进行发布，形成企业信息系统、物理设备的API开放接口资源池，供外部调用，形成虚拟化数据服务层。

被赋予服务访问权限的第三方系统、物理设备，通过浏览服务目录的虚拟数字资产，遵循服务的调用规约、报文标准、协议类型等，实现与具体服务条目绑定的系统或者设备进行通讯交换数据和指令，完成信息交换，达成异构系统和多个设备之间的松耦合协作，实现互联互通、互操作。