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

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

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

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

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

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

步骤二：主题配置

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

容器已经建好了，第三步就是定义如何向容器里发布/订阅消息了。单据消息发布与订阅是对单据的操作进行监听，一个单据生产数据，另一个单据对数据进行消费，从而达到单据之间数据同步的功能。单据的数据则通过MQ中间件进行传递。

注意：通常对于同一个消息队列主题，集成云只应作为其消费方或发布方之一，另一方则应在第三方系统；集成云不应同时作为同一个消息队列主题的消费方与发布方，除非是为方便演示消息集成功能。

消息队列发送/接收记录消息发布/订阅主题的相关日志，为消息集成提供运行轨迹、异常处理等全方面的监控服务。

集成服务云-消息集成专题

更多精彩内容，“码”上了解！↓