一种分布式的消息投放系统和方法

摘要

本发明实施例提供一种分布式的消息投放系统和方法，所述系统包括：消息调度系统和需要进行消息交互的多个业务组件，其中，将多个业务组件中作为消息发送方的至少一个业务组件设置为消息发布组件，用于向消息调度系统发布生产的消息；将多个业务组件中作为消息接收方的至少一个业务组件设置为对应的消息订阅组件，用于向消息调度系统订阅需要接收的消息；消息调度系统，用于当接收到某一消息发布组件发布的消息后，进行存储；然后将存储的消息向订阅消息的消息订阅组件进行异步推送。本发明上述技术方案具有如下有益效果：方便系统增加业务组件，由于消息都是定向的发送和接收，较以前完全通过RPC调用可以减少调用次数，从而提升系统的整体性能。

主权项

一种分布式的消息投放系统，其特征在于，所述系统包括：消息调度系统和需要进行消息交互的多个业务组件，其中，将所述多个业务组件中作为消息发送方的至少一个业务组件设置为消息发布组件，用于向所述消息调度系统发布生产的消息；将所述多个业务组件中作为消息接收方的至少一个业务组件设置为对应的消息订阅组件，用于向所述消息调度系统订阅需要接收的消息；所述消息调度系统，用于当接收到某一消息发布组件发布的消息后，进行存储；然后将存储的消息向订阅所述消息的消息订阅组件进行异步推送。