微服务之Stream入门Demo
1、Stream概述
Spring Cloud Stream是用于构建消息驱动的微服务应用程序的框架。Spring Cloud Stream基于Spring Boot来创建独立的生产级Spring应用程序，并使用Spring Integration提供与消息代理的连接。它提供了来自多家供应商的中间件的合理配置，并介绍了持久性发布-订阅语义，使用者组和分区的概念。
屏蔽底层消息中间件的差异，降低切换成本，统一消息的编程模型
Spring Cloud Stream的核心构建块是：
-
Destination Binders：负责与外部消息传递系统集成的组件。
-
Destination Bindings：外部消息传递系统和应用程序之间提供的消息的生成者和消费者（由目标绑定程序创建）之间的桥梁。
-
Message：生产者和消费者使用的规范数据结构，用于与目标绑定程序（以及通过外部消息传递系统进行的其他应用程序）进行通信。
2、基本环境
eureka-server7001为服务注册模块（服务注册中心使用的是eureka）
cloud-stream-rabbitmq-consumer8802和8003为消费者模块
cloud-stream-rabbitmq-provider8801为生产者模块
2、Stream常用注解开发
- Binder：很方便的连接中间件，屏蔽差异
- Channel：通道，是队列Queue的一种抽象，在消息通讯系统中就是实现存储和转发的媒介，通过Channel队列进行配置
- Source和Sink：可理解为参照对象是Spring Cloud Stream自身，从Stream发布消息就是输出，接收消息就是输入
可参考上图
| 组成 | 说明 |
|---|---|
| Middleware | 中间件，目前只支持RabbitMQ和Kafka |
| Binder | Binder是应用于消息中间件之间的封装，目前实行了Kafka和RabbitMQ的Binder，通过Binder可以很方便的连接中间件，可以动态的改变消息类型（对应于Kafka的topic，RabbitMQ的exchange），这些都可以通过配置文件来实现 |
| @Input | 注解标识输入通道，通过该输入通道接收到的消息进入应用程序 |
| @Output | 注解标识输出通道，发布的消息将通过该通道离开应用程序 |
| @StreamListener | 监听队列，用于消费者的队列的消息接收 |
| @EnableBinding | 指信道channel和exchange绑定在一起 |
3、Stream消息驱动之生产者
pom依赖
配置文件
注意：使用的用户是guest,而guest只能默认只能连接本机IP(也就是127.0.0.1)，如果安装在虚拟机上需要增加配置文件，具体可以百度。
建立接口和实现类
可参考官方文档
controller
发送请求
控制台
3、Stream消息驱动之消费者
配置文件
业务类
发送请求
控制台打印
rabbitmq中
4、Stream消息重复消费
在实际中可能会遇到一个订单被多个服务获取到，那么就会造成数据错误，我们要避免这种情况。
这时我们就要使用Stream中的分组解决，同意分组中各个服务之间为竞争关系，但能确保消息只会被消费一次。
解决：自定义分组
只需在配置文件中设置group属性。注意设置为相同分组，这样就能避免重复消费
本文源码已由 GitHub https://github.com/2335119327/SpringCloud 已经收录（内涵更多SpringCloud的Demo,有兴趣的小伙伴可以看看）,之后会持续更新SpringBoot系列，欢迎Star。
觉得博主写的不错的读者大大们，可以点赞关注和收藏哦，谢谢各位！