1.在实际环境中，可能不同服务使用不同的MQ，这使得信息的发送和接收比较复杂，Stream可以? ? ?屏蔽底层消息中间件的差异，降低切换成本，统一消息的编程模型来解决这一问题。但目前? ? ? ? ? ?Stream只支持RabbitMQ和Kafka。
? ? ? ? ? ? ? ? ? ? ?
2.Stream统一了信息的发送和接受格式，由binder对象来负责和MQ交互。
3.信息发布者建立（以RabbitMQ为例）
? 建立RabbitMQ环境
? 建立moudle
? pom（stream-rabbit依赖）
? yml：
?业务类（发送信息方法的接口，接口实现类，controller）
? ? ? 实现类：
controller：
4.信息接受者建立
? 建立RabbitMQ环境
? 建立moudle
? pom（stream-rabbit依赖）
? yml：
业务类（只需要controller）
5.问题1：重复消费：一个消息被多个消费者接收到
? ?原因：stream默认对消费者分组：同组的竞争：只有一个可以接受到消息
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?不同组的无竞争：都可以接收到消息
? ? ? ? ? ? 不分组：默认各个消费者都是独立组的，无竞争，都可以接收到消息
? 解决：分组：不想都接受到就分到同一个组内
? ?问题2：错过信息：当未分组时（即默认组）当服务器关闭时，消息会被错过
? ? 解决：分组：手动分组后，信息会存储，当服务器开机时，进行读取消费
