85_Stream的设计思想

好，同学们，那接下来我们简单的入门了解了。Spring cloud stream是什么？为什么引入它解决的痛点和帮顶对象？清楚了以后，我们下面整体要来看看。Stream的设计思想再次强调，不要是一上来就是一套编代码，哎呀，我最烦就是这样的，给你一套啊，同学们照着这么一个编码的流程安装一下，然后一个套路写完了，只会用其他的狗屁什么都不懂，一看就是什么学成傻子了。那么像这样呢，我们要避免这样的，因为我呢，大家都清楚啊，杨哥是最后一个高级部分的老师，差不多我只有兴趣培养进大厂的更好的弟子，所以说希望对同学们的要求呢，拔高一点。不但要知其然，更要知道其所以然。那么能说会用多角度、全方位下面。我们来看看班绑定器，它的设计思想和理念。

首先，我们。老规矩，一条线画下来对吧？我们是不是说过一个东西叫before after，还记不记得兄弟们没有引入cloud之前和引入cloud之后有什么区别？那么下面我们先看一下我们标准的MQ。也就是我们这四大要挟，听懂这4F4啊，这四个是目前最流行的，兄弟们没有任何问题吧？那么消息的发送以某种格式封装一下我们的消息到我们的队列，那么这块就是一个消息中间键。当然也可能是主题哈，这无所谓了，不是队列就是主题，都这都这么回事儿，然后订阅的，或者是在队列里面就来取，这是最简单经典的MQ，那么这个时候我们从上面标准的MQ，就是没有引入spring cloud STEM之前我们干的活就这么岁月静好，生产者和消费者之间靠消息媒介传递信息的内容，兄弟们，就这个我们约定好格式啊，消息头消息正文消息的附件和属性是什么？那么这个就是我们的message。

消息必须走特定的通道，这个就是我们的消息通道message channel频道。消息通道里面的消息如何被消费呢？谁负责收，谁负责发，谁负责处理。那么消息通道里面的直接考。订阅的这个频道将由消息处理来进行，订阅过的给你推送和处理，再次强调上硅谷微信公众号，你订阅的我们给你发，没订阅的我们是不是不打扰，所以说传统而言，我们有消息走通道，然后在通道里面的订阅者，然后获得，那这是我们的，没有引入spring cloud。STEM之前就是你用那些active MQ等等，好吧，最原始最普通的，那么你现在引入了以后，我们来看一下。

现在比方说我们消息就跟我刚刚所说的，你现在是Java，用的是MQ，大数据用的是卡夫卡，可能整个系统里面存在着两种MQ，绝对会碰上这样的消息，中间键的切换和试派真的很烦，那么这样的话呢，来吧。我们呢，两个消息中间的架构是肯定不一样的，像比方说我们的MQ，我们有一个嵌解交换机，卡夫卡，有什么topic，皮口主题和提分区的概念，就是鸡同鸭讲，都是中国人，但是各地方言不同，所以说我们现在就需要有一种目的地的绑定器。官方标准的普通话，你说福建话，我说广东话，我们中间OK，没关系，国语普通话来实现沟通，屏蔽差异，那么这个时候大家请看。我们这后面我们会讲这些注解啊，那么通过这消息input，另外一个消息output，那么是不是干成一种事。

中间件的差异导致我们实际项目开发中造成一定困难，肯定存在，如果两个中用了一个后面的业务需求，我们想往另外一种消息队列进行迁移、升级或者备份，这种是很恐怖的。说难听点，比方说同学们，你们不会135用Oracle 246用mycq吧？那么所以说如果要进行这样的升级切换，一大堆东西都要重新推导重做，那么凡是跟我们系统耦合了，这个时候我们就用STEM提供一种解耦的方式啊，来吧。怎么干？你凭什么可以屏蔽底层统计差异？兄弟们，我们呢，实现了通过定义绑定器作为中间键，完美的实现了应用程序与消息中间细节结耦，我们通过应用程序暴露统一的channel频道和我们的通道，使得应用程序不再要考虑不同的落地实现。那么来吧，这儿就是它的官网rabbit MQ绑定器的大纲，那么我们后续就是围绕着这些理论知识来给大家进行讲解编码和配置啊。

定义绑定器班作为中间层，实现应用程序与消息中间键细节之间的解耦和隔离。好，那么。来。花大概十秒钟看一眼input消费output生产，说白了是不是就是对于我们的消息生产者和消息消费者嘛，消息无非就是一个收发的关系关系，那么我的绑定器来吧。基本上官方文档就这么回事儿，兄弟们。很简单，下面是消息的发送，微服务处理等等，那么这有个消息中间键，上面是我们的spring cloud stream application，只要我们程序里面引入了，那么对于我们的消息的发送，对于我们消息的接收，我们用这个绑定器中间键来进行屏蔽和细节化的插件。所以说我们本次啊，由于。

Rabbit MQ和卡夫卡我们只选择一个，那么所以说本次啊，杨哥的案例讲解就用班这个绑定器，目前就是我们的rabbit MQ一脉相承，因为前面的配置我们也是用这个，所以说呢，请大家注意，中间玩的就这么一个绑定层，然后进行消息的收发，很简单好思想搞清楚以后就了解它用的通讯方式，遵循的是发布订阅模式，你是我们这个组的，你发布订阅了，我们给你推送，那么主要就是用topic皮主题进行广播，在这个topic皮卡，在我们的rap MQ里面就是我们的交换机exchange，卡夫卡里面就是我们的topic皮卡，OK，说穿了就是一个发布订阅模式啊，那么用最终总结一句话。也就是我们实现用我们的。绑定线作为中间层，屏蔽我们的加va应用程序和底层的各种消息中间键之间的细节差异和隔离，当然再次强调目前只支持两种，MQ和卡斯卡好。那么对于。

Cloud STEM的它的设计思想，我们就给大家讲解到这儿。