苍穹消息集成其实很简单

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

苍穹消息集成其实很简单

01什么是消息集成



“RabbitMQ?”

“Kafka?”

“RocketMQ?” 

…… 



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

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




02为什么要用消息集成



生产者?消费者?All in One!


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

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


03如何使用苍穹消息集成


图|集成云消息集成方案


1.消息集成配置



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


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



2.主题配置



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


3.单据消息设计



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


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


4. 消息集成监控



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




04消息集成常见使用场景



内部RabbitMQ使用场景

一般用于苍穹内部应用之间的消息集成,需要标准业务产品或二开提前准备好队列。使用者需要将队列完整名注册到【消息发布主题】中。内部RabbitMQ只支持发送MQ消息,MQ的消费需要自行实现苍穹的相关接口。

外部MQ(Rabbit,Kafka等)使用场景

苍穹系统和外部系统均可作为消息集成的目标系统,集成云作为平台支持各个系统间消息的发布和订阅。





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

https://club.kdcloud.com/knowledge/specialDetail/136607226344865536

苍穹消息集成其实很简单

01什么是消息集成“RabbitMQ?”“Kafka?”“RocketMQ?” …… 在业务集成过程中,消息队列作为分布式系统的重要组件,在解决应用耦合、异步...
点击下载文档
确认删除?
回到顶部
客服QQ
  • 客服QQ点击这里给我发消息