苍穹消息集成其实很简单

在业务集成过程中，消息队列作为分布式系统的重要组件，在解决应用耦合、异步处理、流量削峰等问题上具备天然优势。消息集成在应用集成的场景中使用越来越多，逐步成长为与数据集成、API集成齐头并进的三驾马车之一。

集成云作为苍穹系统的集成平台，为业务提供了消息集成的基础设施组件。目前支持的消息队列服务器包括：RabbitMQ、Kafka、RocketMQ、ROMA MQS，也支持客户定制其他类型的消息中间件。

苍穹支持在集成云中通过监听单据操作或主动调用发布接口的方式，向消息队列服务发布消息，供第三方系统进行消费。

集成云同样支持订阅MQ队列，外部系统作为生产者把消息发送到消息队列上，集成云订阅相关消息，启动关联的数据集成启动方案、服务流程、单据操作或者API（包括本地微服务或第三方API），来完成最终的数据消费。

集成的第一步永远是建立连接，消息集成也不例外。首先在苍穹新建包含服务器配置等信息的队列服务，建立苍穹与各类MQ服务器的连接。

注意：若与第三方系统集成，MQ服务器不建议使用苍穹内部的MQ组件，建议单独部署MQ服务器，避免环境干扰！

消息集成第二步就是根据实际生产者/消费者角色来创建发布/订阅主题，完成消息容器的建立。苍穹消息集成采用的是发布/订阅（Publish/Subscribe）模式，该模式下消息的发送者和接收者之间的耦合关系变得松散，只需要根据消息的主题进行消息的收发。