1、解决方案架构

1、基于ROMA融合集成平台，实现企业应用、数据、API 、OT设备、云服务、合作伙伴应用之间的集成连接。

2、ROMA主要包含四个组件：数据集成（Fast Data Integration，简称FDI）、服务集成（API Connect，简称APIC）、消息集成（Message Queue Service，简称MQS）、设备集成（LINK）。

FDI

1、数据集成组件，支持数据库（如Oracle、MySQL、MongoDB）、大数据（如FI HIVE、FI HDFS）、消息（如Kafka、MQS）、文本（如FTP）等多种数据源之间的灵活、快速、无侵入式的数据集成，并能自助实施、运维、监控集成数据。

2、例如园区场景中，校园物联系统与教研系统使用的数据源不一样，难以形成园区间有效的信息传输。FDI提供了多种数据源之间转换的方式，支持MySQL、Kafka、API等主流格式之间的转换。

API Connect

1、服务集成组件，涵盖API网关、LiveData和API Market三个子组件。实现从API设计、开发、测试到发布的全生命周期管理和端到端集成。

2、例如集团与各地区子公司的IT系统集成，直接访问对方各类数据库方式过于复杂，且容易发生信息泄露风险，如果以API方式互相开放访问，同时加强API调用安全防护，就能实现跨网络跨地域协同办公。

MQS

1、消息集成组件，基于高可用分布式集群技术，搭建了包括发布订阅、消息轨迹、消息统计等一套完整的消息云服务。

2、例如企业与合作伙伴使用的消息系统不一样，消息系统对接成本较高，而且难以保证对接之后消息传输的可靠性和安全性。MQS可以作为消息中转站，提供安全、可靠的消息传输通道。企业创建多个topic，设置每个合作伙伴订阅topic的权限，然后将消息发布到多个topic中。合作伙伴通过订阅topic，实时获取topic内的消息。

LINK

1、设备集成组件，将物接入业务，帮助用户快速建立安全可靠的设备连接与通信，实现物（如传感器、嵌入式设备、工控设备或智能家电等等）和ROMA平台及IT应用的双向通信。

2、例如工业场景中，设备的信息和生产过程中的参数比较分散。生产线出现故障时，如果靠人工采集每一台设备的信息与参数，定位问题的过程缓慢。LINK能够连接设备和IT系统、大数据平台，将设备的运行状态等信息上传到IT系统或大数据平台中，实现所有设备的信息可视化，一旦生产线出现故障，企业能够快速定位问题。通过配置LINK的规则引擎，把设备参数的极限值输入到设备引擎里面，如果设备的实时参数一直在向极限值接近，就发出告警信息，提醒用户停止设备，对设备进行维护和保养。

2、功能架构

ROMA基于数据、服务、消息、设备划分子产品，各模块既能够单独运行也能组合成套件，统一运维为核心组件提供可视化的系统级通用运维能力，子产品间共享相同的技术底座（Foundation）。

FDI功能视图

FDI主要包含管理控制台和读写插件。

1、管理控制台：FDI的业务管理入口，提供任务管理、数据源管理、任务报告、系统管理等相关功能。

2、读插件：负责源数据获取、打包、读入数据通道。

3、写插件： 负责获取通道数据、解包、写入目标数据源。

API Connect功能视图

API Connect包含API网关、LiveData和API Market三个子组件。

1、API网关作为服务网关，支持服务注册以及服务管控。

2、LiveData支持服务编排、关系型数据库数据开放。

3、API Market支持公共服务发布、服务订阅。

MQS功能视图

1、管理控制台：MQS的业务管理入口，提供Topic创建、订阅、发布，提供链路查询和消息查询。

2、Connector：消息统一接入管控模块，作为RocketMQ的客户端发送和接受消息，并提供鉴权认证，运维消息推送等能力。

3、Rocket MQ：消息队列服务，接受Producer的消息，处理Consumer的消费请求，进行消息持久化，并进行主备机数据备份同步。

4、router：路由配置，通过路由配置，可将一个ROMA环境中的MQS消息搬移到另一个ROMA环境的MQS中，实现MQS消息跨区域搬移。

LINK功能架构

1、管理控制台：LINK的业务管理入口，提供产品管理、设备管理、规则引擎、运维可视等基础服务。

2、Connector：帮助ROMA接入真实设备，提供安全通信的数据通道。Connector支持MQTT通信方式，基于Topic进行的消息路由。

3、IOT Agent：提供网关子设备注册、网关子设备上线/下线、网关子设备删除、数据上报、命令下发能力。