1. 概述
- Spring Cloud Stream：是Spring提供的消息通信框架，旨在构建跨不同消息中间件的统一通信平台。
- 目的：通过消息通信机制降低分布式系统中服务间的耦合度，实现异步服务交互。
2. 消息通信与RPC
- RPC：远程过程调用，实现简单，但耦合度高。
- 消息通信：引入以降低服务间耦合，支持异步交互。
3. 消息中间件多样性
- 存在多种消息通信规范和中间件，例如JMS、AMQP、ActiveMQ、RabbitMQ、Kafka、RocketMQ等，它们具有不同的使用方式。
4. Spring Cloud Stream核心组件
- Binder：连接业务服务和消息中间件，抽象不同中间件的差异。
- Channel：消息通道，用于消息传递。
- Source：消息发布者，生成并发送消息。
- Sink：消息消费者，接收并处理消息。
5. Spring家族消息通信框架
- Spring Messaging：提供基础消息通信API。
- Spring Integration：企业服务总线，扩展Spring Messaging，支持多种集成模式。
- Spring Cloud Stream：基于Spring Integration，提供消息发布和消费的封装。
6. Spring Messaging基础
- Message：包含Header和Payload。
- MessageChannel：发送消息的接口。
- PollableChannel：可轮询获取消息的通道。
- SubscribableChannel：通过订阅回调函数响应消息的通道。
7. Spring Cloud Stream架构
- Source & Sink：分别负责消息的发布和消费。
- Channel：消息的通道。
- Binder：与消息中间件的粘合剂，提供统一API。
8. Binder工作原理
- @EnableBinding：指定Source或Sink接口。
- BindableProxyFactory：工厂类，实现MethodInterceptor和Bindable接口，用于绑定Input和Output。
- Binder接口：提供绑定生产者和消费者的方法。
9. 消息发送与消费
- SendingHandler：处理Source发送的消息。
- @StreamListener：标注方法以接收消息，通过StreamListenerMessageHandler类实现。
10. Spring Cloud Stream与RabbitMQ集成
- spring-cloud-stream-binder-rabbit：集成代码工程，提供与RabbitMQ的集成。
- RabbitMessageChannelBinder：实现消息发送和消费，使用RabbitTemplate和AmqpOutboundEndpoint。
11. 消息格式转换
- MessageConverter：转换消息数据结构，如从
org.springframework.messaging.Message到org.springframework.amqp.core.Message。
12. 总结
- Spring Cloud Stream通过Binder组件实现了与多种消息中间件的统一集成，提供了Source、Sink、Channel等组件，简化了消息通信的复杂性，为开发者提供了统一的消息发送和接收API。
