SpringCloud Stream--编码API和常用注解
标准流程套路
- Binder：方便连接中间件，屏蔽差异
- Channel：通道，是队列Queue的一种抽象，在消息通讯系统中就是实现存储和转发的媒介，通过Channel对队列进行配置
- Source、Sink：简单的可理解为参照对象是SpringCloud Stream自身，从Stream发布消息就是输出，接受消息就是输入。
编码API和常用注解
| 组成 | 说明 |
|---|---|
| Middleware | 中间件，目前只支持RabbitMQ和Kafka |
| Binder | Binder是应用于消息中间件之间的封装，目前实行了Kafka和RabbitMQ的Binder，通过Binder可以很方便的连接中间件，可以动态的改变消息类型（对应于Kafka的topic，RabbitMQ的exchange），这些都可以通过配置文件来实现 |
@Input |
注解标识输入通道，通过该输入通道接收到的消息进入应用程序 |
@Output |
注解标识输出通道，发布的消息将通过该通道离开应用程序 |
@StreamListener |
监听队列，用于消费者的队列的消息接收 |
@EnableBinding |
指信道channel和exchange绑定在一起 |