SpringCloud Stream--编码API和常用注解

痛定思痛。 2021-08-27 17:30 344阅读 0赞

### 标准流程套路 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 1]

*  Binder：方便连接中间件，屏蔽差异
 *  Channel：通道，是队列Queue的一种抽象，在消息通讯系统中就是实现存储和转发的媒介，通过Channel对队列进行配置
 *  Source、Sink：简单的可理解为参照对象是SpringCloud Stream自身，从Stream发布消息就是输出，接受消息就是输入。

#### 编码API和常用注解 ####

<table> 
 <thead> 
  <tr> 
   <th align="left">组成</th> 
   <th align="left">说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">Middleware</td> 
   <td align="left">中间件，目前只支持RabbitMQ和Kafka</td> 
  </tr> 
  <tr> 
   <td align="left">Binder</td> 
   <td align="left">Binder是应用于消息中间件之间的封装，目前实行了Kafka和RabbitMQ的Binder，通过Binder可以很方便的连接中间件，可以动态的改变消息类型（对应于Kafka的topic，RabbitMQ的exchange），这些都可以通过配置文件来实现</td> 
  </tr> 
  <tr> 
   <td align="left"><code>@Input</code></td> 
   <td align="left">注解标识输入通道，通过该输入通道接收到的消息进入应用程序</td> 
  </tr> 
  <tr> 
   <td align="left"><code>@Output</code></td> 
   <td align="left">注解标识输出通道，发布的消息将通过该通道离开应用程序</td> 
  </tr> 
  <tr> 
   <td align="left"><code>@StreamListener</code></td> 
   <td align="left">监听队列，用于消费者的队列的消息接收</td> 
  </tr> 
  <tr> 
   <td align="left"><code>@EnableBinding</code></td> 
   <td align="left">指信道channel和exchange绑定在一起</td> 
  </tr> 
 </tbody> 
</table>

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70]: /images/20210813/ca3cd1208ce54124a481c1fbfd063ce3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NvbGRfX19wbGF5_size_16_color_FFFFFF_t_70 1]: /images/20210813/d9c34c7a9c9447f1818dfe17e822a266.png