通过引入Sping Cloud Stream实现应用和消息组件的解耦。应用和stream打交道,消息组件可以是kafka,也可以是rabbitMQ。
对分布式消息的各种需求进行了抽象,包括发布订阅、分组消费、消息分片等,实现微服务之间的异步通信。
SCS也集成了第三方的RabbitMQ和Kafka作为消息队列的实现。
而SCB基于SCS,主要提供服务之间的事件通信(比如刷新配置)。
SCS是构建消息驱动微服务的框架。
通过引入Sping Cloud Stream实现应用和消息组件的解耦。应用和stream打交道,消息组件可以是kafka,也可以是rabbitMQ。
对分布式消息的各种需求进行了抽象,包括发布订阅、分组消费、消息分片等,实现微服务之间的异步通信。
SCS也集成了第三方的RabbitMQ和Kafka作为消息队列的实现。
而SCB基于SCS,主要提供服务之间的事件通信(比如刷新配置)。
SCS是构建消息驱动微服务的框架。