什么是Spring Cloud Stream

Spring Cloud Stream是一个用来为微服务应用构建消息驱动能力的框架。它可以基于Spring Boot来创建独立的、可用于生产的Spring应用程序。它通过使用Spring Integration来连接消息代理中间件以实现消息事件驱动的微服务应用。Spring Cloud Stream为一些供应商的消息中间件产品提供了个性化的自动化配置实现，并且引入了发布-订阅、消费组以及消息分区这三个核心概念。
简单的说，Spring Cloud Stream本质上就是整合了Spring Boot和Spring Integration，实现了一套轻量级的消息驱动的微服务框架。通过使用Spring Cloud Stream，可以有效地简化开发人员对消息中间件的使用复杂度，让系统开发人员可以有更多的精力关注于核心业务逻辑的处理。由于Spring Cloud Stream基于Spring Boot实现，所以它秉承了Spring Boot的优点，实现了自动化配置的功能帮忙我们可以快速的上手使用，但是目前为止Spring Cloud Stream只支持下面两个著名的消息中间件的自动化配置：

RabbitMQ
Kafka

快速入门

构建一个Spring Cloud Stream消费者
创建一个基础的Spring Boot工程，命名为：stream-hello
编辑pom.xml中的依赖关系，引入Spring Cloud Stream对RabbitMQ的支持

1
2
3
4
5
6
1 <dependency>

2        <groupId>org.springframework.cloud</groupId>

3        <artifactId>spring-cloud-starter-stream-rabbit</artifactId>     

4 </dependency>

5

6

创建用于接收来自RabbitMQ消息的消费者SinkReceiver

1
2
3
4
5
6
7
8
9
10
11
12
13
1@EnableBinding(Sink.class)

2public class SinkReceiver {

3

4    private static Logger logger = LoggerFactory.getLogger(SinkReceiver.class);

5

6    @StreamListener(Sink.INPUT)

7    public void receive(Object payload) {

8        logger.info("Received: " + payload);

9    }

10

11}

12

13

创建应用主类

1
2
3
4
5
6
7
8
9
10
1@SpringBootApplication

2public class SinkApplication {

3

4    public static void main(String[] args) {

5        SpringApplication.run(SinkApplication.class, args);

6    }

7

8}

9

10

完成

我们对Spring Boot应用做的就是引入spring-cloud-starter-stream-rabbit依赖，该依赖包是Spring Cloud Stream对RabbitMQ支持的封装，其中包含了对RabbitMQ的自动化配置等内容。从它定义的依赖关系中，我们还可以知道它等价于spring-cloud-stream-binder-rabbit依赖。

Spring Cloud Stream的核心注解，它们都被定义在SinkReceiver中：
@EnableBinding，该注解用来指定一个或多个定义了@Input或@Output注解的接口，以此实现对消息通道（Channel）的绑定。在上面的例子中，我们通过@EnableBinding(Sink.class)绑定了Sink接口，该接口是Spring Cloud Stream中默认实现的对输入消息通道绑定的定义。
@StreamListener：该注解主要定义在方法上，作用是将被修饰的方法注册为消息中间件上数据流的事件监听器，注解中的属性值对应了监听的消息通道名。

核心概念

Spring Cloud Stream应用模型的结构图：

绑定器
Binder绑定器是Spring Cloud Stream中一个非常重要的概念。
通过定义绑定器作为中间层，完美地实现了应用程序与消息中间件细节之间的隔离。通过向应用程序暴露统一的Channel通道，使得应用程序不需要再考虑各种不同的消息中间件实现。当我们需要升级消息中间件，或是更换其他消息中间件产品时，我们要做的就是更换它们对应的Binder绑定器而不需要修改任何Spring Boot的应用逻辑。

发布-订阅模式
在Spring Cloud Stream中的消息通信方式遵循了发布-订阅模式，当一条消息被投递到消息中间件之后，它会通过共享的Topic主题进行广播，消息消费者在订阅的主题中收到它并触发自身的业务逻辑处理。
Topic在RabbitMQ中的它对应了Exchange、而在Kakfa中则对应了Kafka中的Topic。

启动的两个应用程序分别是“订阅者-1”和“订阅者-2”，他们都建立了一条输入通道绑定到同一个Topic（RabbitMQ的Exchange）上。当该Topic中有消息发布进来后，连接到该Topic上的所有订阅者可以收到该消息并根据自身的需求进行消费操作。

相对于点对点队列实现的消息通信来说，Spring Cloud Stream采用的发布-订阅模式可以有效的降低消息生产者与消费者之间的耦合，当我们需要对同一类消息增加一种处理方式时，只需要增加一个应用程序并将输入通道绑定到既有的Topic中就可以实现功能的扩展，而不需要改变原来已经实现的任何内容。

消费组
如果在同一个主题上的应用需要启动多个实例的时候，我们可以通过spring.cloud.stream.bindings.input.group属性为应用指定一个组名，这样这个应用的多个实例在接收到消息的时候，只会有一个成员真正的收到消息并进行处理。

消息分区
分区概念的引入就是为了解决这样的问题：当生产者将消息数据发送给多个消费者实例时，保证拥有共同特征的消息数据始终是由同一个消费者实例接收和处理。