springcloudStream 理念分享

消息驱动

解决的痛点

现有的MQ(消息中间件)

• ActiveMQ
• RabbitMQ
• RocketMQ
• Kafak

对于前后端及大数据多系统交互,有可能存在多个mq使用,有没有一种新的技术,让我们不再关注具体MQ的细节,我们只需要一种适配绑定的方式,自动的给我们在各种MQ内切换

屏蔽底层中间件的差异,降低切换成本,统一消息的编程模型

应用程序通过inouts或者outputs来与Spring Cloud Stream中binder对象交互

设计思想

对于项目中引入多个消息中间件,这些中间件的差异性导致我们实际项目开发给我们造成了一定的困扰,我们如果用了两个消息队列中的一种,后面的业务需求,我想往另外一种消息队列进行迁移,这时候无疑就是一个灾难性的,一大堆东西都要重新推到和崇左,因为它跟我们的系统耦合了,这时候springcloud Stream给我们提供了一种解耦合的方式

Binder
很方便的连接中间件,屏蔽差异

channel
通道,是队列Queue的一种抽象,在消息通讯系统中就是实现存储和转发的媒介,通过Channel对队列进行配置

Source和Singke
简单理解就是我们生产者和消费者