12_消息消费者编码

好，同学们，那么呢，我们继续。下一步我们完成了消息的生产者，那么言下之意是不是左边这栏搞定，那么接下来MQ上面我们大家看一下在队列这是不是已经有待消费的消息有三条，现在几个消费者没有，那么你可以把它理解，为什么你们先提问了，杨哥还没到教室，那么大家请看干嘛？你们把你们的消息就像发一个邮件一样的给我，杨哥什么时候回我得空的时候回你们，那么这个时候是不是一种最经典的异步调用，而且还解耦了，你们不用耗在这等着杨哥，那么现在MQ里面进来了，En进来第一出去你们，我们呢？待会一消费，那么你懂的，待消费的消息，如果杨哥把这三条都干掉了，那么这个时候是不是应该变成零啊，所以说现在记着我们的数字3030，那么好，MQ上面由于有多个人，多个线程，多个系统可以投递消息，所以说我们最重要的是不是队列这个名字Q01那么一样，这次Q01有三个提问，同理，那么严格去学，是不是也要跟你用一样的名字啊，好，那么接下来。

我们呢，就要来写一下消息的什么consumer消费者，那么第一点杨哥呢，详详细细一步一步的给大家。讲了全部的源码，还有底层原理是怎么怎么怎么来的。那么后面。为了节约时间快一点，那么这些我就直接粘贴，那比如说我再写一次active MQ connection，这就没有任何意义了，那么所以说这边直接粘代码过来。那么同理。你在哪提交的，那杨哥是不是也要去哪去取才能够给你回答问题啊，所以说我的MQ的地址和你队列的提问，那么言下之意，你的提问叫Q0线提问到这儿生产了，那我去消费，我是不是也要找这个好，那么接下来干嘛，那么。

跟前面一样，基本上那么欧拉同学们到这几乎前四步都是差不多的，那么有异常，我们呢？往外抛，那言下之意，同学们，这就是我们的消费者，这个没问题吧，那么到了第四步以后，稍微有点不一样的，你不要装装装装傻了啊，那么思维方式啊，过来还是看我们架构图，那么现在我们左边这栏。是不是完了？那么消息的生产者send to destination，那么请看我们消息的生产者，我们这儿是不是掉了send的方法到我们的什么队列里面，那么同理还是按照价格官方架构图那么一样，这个三要干什么？是不是消息的什么者消费者干什么？Receive干嘛服蓉从目的地能理解了吗？所以说现在我们的消费者杨哥要编的是右下角这半旮旯的，那么过了我们呢？

不一样了。这个时候我们的。第五步，我们将要产生的内容。创建消费者注意哈，那么创建消费者注意啊，这现在不再生产者了，前面代码该粘的我粘，严格节约时间写过一遍了，但是现在要明白，我们呢变了一样，我这个消费者也要去队列里面取，那么我们要干的事是什么呢？和前面差不多，Sunsh.create，大家请看这是不是有个consumer一样，那么你去哪提问，你就要去哪生生产，你就要去哪消费，那么我也找同样的这个队列，那么这个队列你看跟这个名字绑定，那么我们两个是不是？同一个呀，好，接下来我们呢，就是消息的消费者欧了。

那么接下来我们来看那么这个消息的消费者，我们呢？怎么干呢？我在这儿是不是最好就是一直等着同学们来问，那么杨哥呢，就是一个提问器，对吧，尽量的帮助同学们找到好工作，回答各位同学们的学习上工作上的疑问，所以说我要处，但是你们都明白，只不要错，是不是有种死循环，那么这干嘛，我们呢，我呢，那么消费者第二干嘛？大家看这是不是有个receive啊，那么回答杨哥是不是军事杨哥是按照官方的标配架构，请看这是不是有个receive from，哪一个是不是从目的地好了那么过来。但是这个receive方法有讲究，主要是有两个receive这个方法，那么啥意思呢？它的意思是什么概念，一直等。死等，永远等着，我一直在这儿。

等着有消息过来，我不吃饭不睡觉，换句话说是吧，不见不散，那么这个叫receive time out，比方说我这写个3000证明什么等三秒，三秒钟，如果没有消息可以被消费干嘛？我就走了，这个消费者就出发，这个消费者就消失，有点类似于是什么概念呢？比如说哈，现在，那么杨哥已经在这做了30分钟了，都没有人来问我问题的，假设这个时间是30分钟，那么杨哥可能现在呢，就暂时离开一下，我就出去了，好休息一下，那么好，我们现在随便选一个，先选第一个，那么消息的消费者，好，那么message。O了，那么这个时候我们就是message，但是注意这有条件。我这发的给你是test。Message干嘛？你收的时候也要这么干，所以说我们这需要有一个东东叫强制类型转换，这么说同学们能跟上，你看它receive receive什么是个message，因为后面我们会介绍哈，这个MQ它有五种message的消息，那你得给人家讲明白，这个message自是个啥，有点类似于就是说你们是用中文给我提问，那么自然而然，我是不是也应该用中文给你回答，你宣传的是什么消息，我们消费的也要是什么消息，同一个格式，同一个约定，那假如说同学你现在干嘛用日语来给杨哥提问，那这个是不是有点装逼啊，那这个时候我是不是要批你，对吧？好，那么这个时候呢，过来，我们呢，我要出来看看receive能不能接收到消息，接收到消息就过来，这好那。

如果我们这个消息不等于那。OK，那么接下来我们呢，直接过来就是什么消费者。接收到消息，那么来同学们这有个重要的，那么就是我们的test manager.get是吧？Test，那么把我们介绍的内容弄出来，如果说没有了，那么break，我们呢，跳出来好。

那么最终我们的message干嘛close？那么言下之夜顺着申请倒着关闭，那么connection第2CLOSE，好，彻彻底底关闭完成，那么如果后台能够看到这句话，打印出我们的消息的内容，那么说明我们的消费是成功的，好，那么我们呢，把我们的消费者。也写完了，那么接下来来看一下我们程序这个层面后台会打印出什么消息，我们MQ这个控制台对于我们这现在的数字是什么？三零，三零，它会有产生什么样的变化？好，那同学们，我们现在receive过来这一运行。

看是不是很快啊，如果一切顺利，我们将会看到消费者接收到消息，Test get contest，那第二次强调重复啰嗦，主要是让同学们尽量少编bug，你生产了是test message，你接受了也要是test message11对应，OK，那么第二个，那么请看我要出，那么在这第一次receive有没有接收到，接收到了不等于钠，那么这是不是弄过来打印出来好离开第二次又进了这个外交处循环，那干什么呢？相当于我这个时候什么意思啊，Receive，我这是不是就是一直在这等着，注意你看这个灯是不是没有灭呀。这么说能理解，这个没有stop，这个灯是一直还亮着呢，那么大家请看，后台接收到了message 123发了三条，解决了三条消费了三条，成功访问通过，那么这张图现在是不是又半拿子也搞定，那么全班。

OK，那么接下来我们来来看看我们的控制台的变化，我再点一下我们的队列，注意。没点之前对于这个消息这个三条3030我一点，大家请看是不是变成了0133啥意思啊，那么现在带消费的消息没有了，那么消息的消费者有几个，一个有一个一直在连着连上了，那么谁是不是当前这个为啥你看这个灯是不是还没灭。好，那么大家请看消息入对有几个三条，消息出对有几个三条，那么这个时候干嘛发了三条，消费了三条，一一对应，说明我们的消费程序也已经成功完成，OK，那么好，对于我们的。消费者的代码，我们就给大家介绍到这儿。