Spring Cloud Stream简介

Spring Cloud Stream是一个构建消息驱动微服务的框架，它是Spring Cloud对于消息中间件的进一步封装，通过使用Spring Cloud Stream，可以忽略消息中间件之间的差异，有效降低开发人员对消息中间件的使用复杂度。目前Spring Cloud Stream支持的消息中间件仅有RabbitMQ和Kafka。

为了大家更好地理解Spring Cloud Stream与消息中间件是如何交互的，下面通过Spring Cloud Stream的应用模型进行介绍，具体如图1所示。

图1 Spring Cloud Stream应用模型

在图1中，使用Stream构建的应用程序与消息中间件之间是通过绑定器Binder相关联的，可以说， Binder对于应用程序而言起到了隔离作用，它使得不同消息中间件的实现细节对Stream应用程序来说是透明的。

对于每一个Stream的应用程序来说，它无需知晓消息中间件的通信细节，而是通过向应用程序暴露统一的通道(Channel)来进行通信。例如图8-1中，应用程序和Binder之间定义了两条输入通道（inputs）和三条输出通道（outputs）传递消息，Binder则是作为这些通道和消息中间件之间的桥梁进行消息通信。