SpringCloud Stream消息驱动实现原理
通过定义Binder绑定器作为中间层，实现了应用程序和消息中间件之间实现细节的隔离。通过向应用程序暴露统一的Channel通道，可以让应用程序不再需要考虑各种不同的消息中间件实现的兼容性问题。当需要升级消息中间件，或者是更换其他消息中间件产品时，我们需要做的就只是更换对应的Binder绑定器即可，不需要再修改任何应用中对接消息中间件的实现逻辑。

Stream消息驱动中有以下几个核心概念：
Source: 当需要发送消息时，就需要使用Source来实现，Source会把所要发送的消息(POJO对象)进行序列化（默认转换成JSON格式字符串），然后将这些数据发送到Channel中。
Channel: 消息通道是Stream消息驱动的抽象之一。通常我们向消息中间件发送消息或者消费消息时需要指定主题（Topic）名称或消息队列名称，但这样一来，当我们需要变更主题名称的时候就需要修改大量消息发起方和消息消费方的代码，但是通过使用Channel消息通道，消息发起方和消息消费方的业务代码只需要连接到Channel消息通道就可以了，具体这个Channel消息通道对应的是哪个主题，就可以在配置文件中指定，这样当主题变更的时候我们不需要对代码做任何修改，就实现了业务代码和具体消息中间件的解耦。
Binder: Stream消息驱动中的另外一个抽象层，通过不同的Binder可以实现和不同的消息中间件整合，比如针对Kafka的Binder等等，通过Binder提供统一的消息收发接口，我们可以根据实际需要部署不同的消息中间件，或者根据实际生产环境中部署的消息中间件来调整我们的配置。
Sink: 当需要监听消息时，就需要使用Sink来实现，Sink负责从Channel消息通道中获取消息，并将消息反序列化成消息对象(POJO对象)，然后交给具体的消息消费方处理相应的业务逻辑。

SpringCloudStream原理图