88_Stream消息驱动之消费者

好，同学们，我们继续上一讲，我们完成了消息驱动生产者8801消息的发送和推送，那么MQ上面也看到了那个波峰的那个流量变动，这个完成，那接下来我们要讲一下我们的消息驱动的消费者，那么你要有消息的生产，必然有消息的消费，然后我们呢，没有用任何rabbit MQ的API，我们现在。屏蔽了MQ，甚至我都没有怎么讲MQ提都没怎么提，对不对，就看到一个播放流量，那么所以说现在我们呢。来看看我们的消费者如何获得我们的消费呢？来吧。按照我们的设计，那么案例说明在这块三个子工程。那么现在我们的。8802802是不是作为消息的接收模块，好，那么还是以前这些东西来同学们，那我直接开始新建。这些我就不再多废话。

快快的过。OK，完成以后我们的泡沫，那么这个时候直接拉下来。基本上也是引入我们的stream这一波OK吧。好，那么第三步写我们的。8802的我们的配置文件。好。修改一下我们的配置文件。OK，那完成以后，那么同学们。看一眼。来吧，其重点和区别的对话在哪呢？我们看这个。

8802闭嘴。名字不说了，上面都一样。唯一的区别就这。前面我们是不是output消息的生产者发送，那么这个是不是应该是反过来input？是我们在同一个通道上面的消费和接收啊，兄弟们，这个没有任何问题吧，只要你8801听懂了，8802就这么一点区别，其他没有任何变化，后面就是一张的事哦，最多完成一个就是receive接收消息，我们是8802，.com OK，我们在那个有卡的那个ID，那我们稍微有点不一样啊这块。也不是特别重要，重要的是这个东东，刚才我们有瑞卡都不用打开，现在有瑞卡都是OK的，好，那么现在。我们的八八。零二搞定，那么老规矩，完成这些事情以后直接come at，硅谷点spring cloud 8802我们的消费者端口号，那么这些我就不再写了，那么兄弟们。

直接拷贝。好，那OK，前面这些琐碎的工作完成以后，重点是这儿啊，一定要明白，我们都是往study exchange交换机这去取。好，那么接下来我们来写写我们的业务逻辑代码，老规矩，因为它是什么者消费者自己本身就不带着什么service啊，那些东东就是个controller，那么我们现在呢？就来完成我们编码的实现。那么来吧，CTRL包。点，那么这个我们叫什么呢？Receive。这么说能跟上。没在那儿吧？好，那么同学们就叫这么一个名字，长一点就长一点了啊，那么来吧，那么这个东东，那么同学们我们CTRL了。

组件添加进去没问题吧？那接下来这个问题主机又要回到我们的基础篇。什么鬼？这两个这个首先你一样的要开启这个绑定通道，另外。Listener，消费者是要作为监听我。MQ上面来个消息有了，我们是不是要用于消费者队列的消息的是吧，接收，所以说待会儿要用这两个主角标签，那么同学们请了解一下好，那么这块我们业务类。过来也是able bonding，那么这个时候。Think第二。Class，那么兄弟们，这一波能不能理解？导入这个包，那么弟兄们是不是应该是stream message这个东东不要搞错。那如果不怕啰嗦的情况下，兄弟们，我们再来看看。一个是API，另外一个我们编程套路，我们这儿前面讲过，这儿是不是要一个生产者作死消费者think没问题吧欧啦，所以说各种身份的标明和说明，在业务类这我给大家写清楚，那么在这块我们后面还要起一个8803，所以说为了给大家演示后面的高级特性。

在这块。我们呢，直接把我们的端口号写好，这手握不应该是这个，应该是我们的艾特value，那么这个呢。兄弟们呢，已经写过很多遍了，那么点port，说穿了这块是不是得到我们的端口编号8802，好，那么接下来我们就是public word，我这儿就是input，相当于是消息的接收了，那么接收什么呢？Message，那么string，那么这。Message OK，那么这这块来了新知识，那么这是不是就是我们的STEM什么listener，那么你监听的这不是不是一个think第2INPUT，你作为一个输入员啊，那么这标配的写法好，那么接下来干嘛呢？

来吧，我呢自己呢是消费者。一号。好吧，那么在这块。来，那么我们收到的消息。那是一些什么呢？那么同学们，那么现在是不是要用我们的message点前面是不是pay漏这块是不是我们的get pay漏，同学们这一波能跟上那么好。打出来我们一个table键缩进，那么这我们后面要演示两个的时候，我们这儿最终让大家看看它的端口号是多少，是不是破这波能跟上，那么同学们啊，上一讲我们的8801啊，这样我们对比着来学一下，那么大部分呢，同学们第一次听我讲慢一点。

我们这一块的的时候。在这儿是不是有一个消息，构建以后位置。拍漏把我们的序列号发进来，发进来了以后，整体而言它是不是个message，那么你是发了什么message，我收是不是要收message？你这收的是string，发的是string吧？那么我这收的是不是也是string？那么你这边发送的时候用的是with pay漏的方法，那么我这边收的时候是不是用get拍漏的方法，只要是同一个消息给我过来，我们两个是不是能够看到一样的内容啊？好，那么这个同学们就是我们的业务类，那么接下来我们看一下我们的7001启动，我们的80018801起动，那么接下来是不是要起到我们的。8802这个动作OK，好老规矩，我先启动并暂停一下录屏，同学们启动终于成功了，那么下面70018801消息的发送者，8802消息的消费者，那接下来我们的测试就很简单了。

8801发送，8802接收，那么像这样一句话，现在我们要看到的是第一个8801控制台是不是要要打出我们的流水号，8802是不是要有接收到，那么8802的接收消息是不是就是我们的这句话，我是消费者一号，并且消息的流水号内容，并且还有端口号，这是第二步，第三步我们的MQ这块是不是又要出现心电图的波动了，那么来看看我们的exchange，现在消息的发送者，那么我们已经有建立过，那么消息的接受者会不会就像是订阅号一样关注进来拿到消息呢？那么走起兄弟们，这三个维度我们都要来看看，那么。拿到我们的这个测试地址啊，那么跑到这儿啊，这已经有了，好同学们，我为了让大家好看啊，我先发。

五条12345，那么同学们请看啊。8801最后一条是不是。八八第二第212345没问题吧，请看8802是不是一样的，8802端口号八八第二第二和我们的这个吻合了吧，读到了吧，那么再来，兄弟们请看我们的一个陷阱在这儿点进去以后搁到这儿，大家请看是不是开始有波峰，那么然后我现在又平归于平静不点了，然后他慢慢的沉沉沉静下来，那么再来绑定8802来了，This。嵌机交换机上面是不是开始有一个，当然我们没有指定名字，这个是不是个匿名的一个粉丝啊上来了，你可以把它理解为在这个通道上，现在是不是已经有人开始来关注了，好，那么同学们不妨我们再多点它几次啊，那么eeeee的狂点哈，那么这个时候rabbit MQ，那么自然而然，你看是不是猛的又升上来了，OK，那么自然而然兄弟们，后面的东西也就是可以看到这么多好端口号和我们的消息，那么到这儿我们可以完整的给大家介绍了我们的消息生产者。

用spring cloud stream结合rabbit MQ让消费者获得，大家请看我这次贡献，没有过多的详细的来说我们的rabbit MQ，因为之前杨哥给大家讲过，尽量的屏蔽，就是让你感觉到以前我们要写一些跟MQ相关的相关代码，现在我们一行都没写，我们用的全是我们的标准流程API和我们前面的理论知识，这些注解可以这么讲，说坑爹一点的话，狠一点的话，那这四个差不多一般的。消息中间件的处理你可以做得到了，好，那么接下来。我们的入门级别的supreme stream讲解前四章完成，那么我们下面它对它的一些真真正正的工作中要用到的分组消费持久化，那么要给大家进一步深度的讲解。