基本知识点：
| 组成 | 说明 |
| Middleware | 中间件，目前只支持Rabbitmq和Kafa |
| Binder |
Binder是应用与消息中间件之间的封装，目前实现了Kafka和RabbitMq的Binder,通过 Binder可以方便的连接中间件，可以动态的改变消息类型（对应kafa的topic, RabbitMQ的exchange）,这些都可以通过配置文件来实现 |
| @Input | 注解标识输入通道，通过该输入通道接受到的消息进入应用程序 |
| @Output | 注解标识输出通道，发布消息将通过该通道离开应用程序 |
| @StreamListener | 监听队列，用于消费者的队列的消息接受 |
| @EnableBinder | 指信道channel和exchange绑定在一起 |
问题：
1.重复消费
通过分组实现 a.不同组是可以全面消费的（重复消费） ;b.同一组内会发生竞争关系，只有其中一个可以消费
2.消息持久化