86_Stream编码常用注解简介

来同学们那。设计思想，我们讲解完成以后，为了后续我们更好的做这个落地的编码实现，那么我们现在先要了解一下spring cloud stream常用的标准编码的流程套路和它常用的注解，那么把这些理论知识扎扎实实的先有理论了。咱们再到实操最后小总结。理论实操小总结，那么三板斧希望同学们呢，不要一上来就撸代码，为什么这么写不知道，哎呀，反正跑通了。跑通了以后，你会发现你都是虚的，你说不清楚，好，那么所以说兄弟们走起。那么我们先来看看啊。Stream呢，遵循的是发布订阅，你到最后你在我这里消息里面啊，在rabbit MQ里面，你订阅了，我们给你推送，不订阅我们也不打扰你，好，那么我们来看看，如果我们要用是不是cloud stream进行编码开发的话，它的标准的套路有哪一些？

首先这是官方架构图，见过很多次了，生产消费用B绑定器屏蔽。那么来。它大致的模型就是这样。消息生产者。处理一大堆业务逻辑，然后我们用绑定器string cloud stream进来，可以这个框框里面是到了我们的stream里面了，原。频道或者通道channel。然后OK了，我就不管了，我下面可没有跟我的MQ耦合，我也不知道下面是rabbit MQ还是卡夫卡，我的业务逻辑，我只知道stream stream用绑定器它的套路和流程。说穿了就是一些常用的注解和它标准的业务逻辑编码，然后给我们的消息。MQ之后，这边是生产者，那么自然而然有发送就有接收吧，就跟发邮件一样，那么也是一样，底层也是用绑定器来获得，绑定器知道的，走专属的订阅发布通道，然后这块OK，我们来解读消费者获得，那么这块完了以后，我们至少知道了三个东西。

第一个绑定器，很关键的连接中间键，说穿了兄弟们是不是就是我们这个。绑定器连接中间键OK，那么第二个。频道类似于我们的队列。它是一种在。我们的STEM里面的一种抽象，它主要是负责消息通讯系统中实现存储和转发的媒介。通过频道和通道。既可以叫频道，也可以叫通道，都是一个意思啊，对队列进行配置啊，你走哪条道？最后是source和think，那么这个时候什么概念？简单的理解为就是我们的输入输出消息的生产者和消费者。好那么最后我们待会编码当中会用到一些注解，那么不妨我们先来看一下。

首先这个中间键啊，就围围绕着官方这张图就行了，不用去找别的了。MQ和卡夫卡绑定器。那么这。我们呢，通过把兵器来跟底层配合。卡夫卡是托皮，Q是exchange交换机，然后input output。Stream listener和enableing，那么这个时候还记不记得引入要什么激活什么之类的，我们讲过吧？那么input输入，那么通过该输入通道接受消息进入程序，那么消息的接受者，消费者，Output输出啊，那么换句话说发送者，那么监听队列，那么我们在这个里面，诶，有消息了，监听到了。该怎么转发怎么转发，该发布订阅发布订阅，OK，那么所以说后续我们会用到相应的，那么先在这混个眼熟，那么接下来我们的案例说明呢，就要给大家呢，来进行我们的落地编码，实现常用API和常用注解，了解了以后我们来看，首先不用说我们的rabbit m q现在是不是搞定，那么最后当然啊，我们的那个有瑞卡消息注册的中间键，服务注册中间键随便你啊，用keep can。

都可以，那么我们下面新建三个子模块，那么分别是我们的8801作为生产者发消息，8802消费者，8803消费者。换句话说，现在我们就是。可以把它理解为一个服务注册中心有瑞卡7001，当然你要用集群也行啊，我是少启动两个，然后呢，三个微服务，再加我们一个rabbit MQ OK，我们的工程案例和常用的编码API和常用注解先给大家介绍到这儿，下一讲我们就正儿八经开始用STEM来进行消息中间键的操作。