一业务

二需求

多个微服务之间需要通过消息中间件互相传递消息。
在面对不同的MQ产品（RabbitMQ、Kafka、RocketMQ）时，做到消息中间件和微服务的代码之间耦合性降到最低，甚至任意切换消息中间件而不用动微服务的代码。

按照官方的定义，Spring Cloud Stream 是一个构建消息驱动微服务的框架
1. ???????Spring Cloud Stream解决了开发人员无感知的使用消息中间件的问题。Spring Cloud Stream对消息中间件的进一步封装，可以做到代码层面对消息中间件的无感知，甚至于动态的切换中间件(rabbitmq切换为rocketmq或者kafka)，使得微服务开发的高度解耦，服务可以关注更多自己的业务流程；
  1. String cloud stream对各个MQ产品（RabbitMQ、Kafka、RocketMQ）的连接和各种操作，做了一层高度的抽象。在String cloud stream的加持下，我们可任意选用某一种消息中间件而不用修改微服务的代码。
  2. 相当于ORM框架（hibernate、mybatis），对底层的多种数据库产品的连接和各种操作做了一层高度的抽象。在ORM框架的加持下，我们可任意选用某一种数据库而不用修改代码。? ?
Spring Cloud Stream官方只支持rabbitmq 和 kafka，spring cloud alibaba新写了一个starter可以使Spring Cloud Stream支持RocketMQ； ??

spring cloud stream是spring cloud提供的一个子项目（或称? ?框架）。
application core是我们写的微服务的代码，可以有多个application core，即有多个微服务。
1. output：微服务发消息到消息中间件
2. input：微服务接收消息中间件的消息。
binder：绑定器
1. spring cloud stream子项目（框架）给我们封装的东西叫binder。
2. spring cloud stream封装的binder对微服务和消息中间件之间发消息和接消息的操作做了高度的抽象、封装。
3. binder用于创建binding，从而绑定具体的消息中间件。
4. 消息中间件都有自己的Binder实现；比如Kafka?的实现KafkaMessageChannelBinder，RabbitMQ的实现RabbitMessageChannelBinder以及RocketMQ?的实现?RocketMQMessageChannelBinder；
binding
1. 包括 Input Binding 和 Output Binding；
2. Binding 在消息中间件与应用程序提供的 Provider 和 Consumer 之间提供了一个桥梁，实现了开发者只需使用应用程序的 Provider 或 Consumer 生产或消费数据即可，屏蔽了开发者与底层消息中间件的接触；
常用的消息中间件：kafka、rabbimq、rokectmq

开发过程中使用到的类、注解：

组成	说明
Binder 绑定器（各个消息中间件的绑定器不同）	Binder是应用与消息中间件之间的封装，目前实现了Kafka和RabbitMQ的Binder，通过Binder可以很方便的连接中间件，可以动态的改变消息类型(对应于Kafka的topic，RabbitMQ的exchange)，这些都可以通过配置文件来实现；
@Input 注解，表明是一个输入管道	该注解标识输入通道，通过该输入通道接收消息进入应用程序
@Output?注解，表明是一个输出管道	该注解标识输出通道，发布的消息将通过该通道离开应用程序
@StreamListener?注解	监听队列，用于消费者的队列的消息接收
@EnableBinding?注解，开启（Enable）绑定功能	将信道channel和exchange、topic绑定在一起