14_消息消费者MessageListener方法说明

各位小伙伴，我们继续，那接下来大家请看那么对于消息的消费者代码的第一种情况，那么同学们我们用了这个receive方法，这个时候给大家是不是进行过。详细的讲解呢，那接下来我们还有第二种情况，那么就是什么呢？消息的消费者需要在这儿什么监听好，那么我么直接上代码，那么这是我们的刚才学过的什么第一种方法，那么请同学们注意。那么他能够完成的这种东东是我们的编码的第一种方法，那么receive这样的方法，那么这个方法有什么好处和情况，两个带时间和不带时间的都讲过了啊，那么所以说这种接收方法，杨哥呢，给大家呢，写好一下这个笔记，我之前已经写好过，那么在大纲里面给大家说，那么订阅或者接收的时候哈，那么这个。

用这个方法来接收，嗯。在能够接受消息之前干嘛加一直什么阻塞，如果不加参数就是一直阻塞加参数，那么就是什么过时不候，那么好，这是我们的第一种访问方式啊，那杨哥第二种访问有没有呢？那么这个呢隆重登场，就是我们给大家介绍的代码二。这个时候代码要解决什么问题啊，就是消费者的监听。那么通过监听的方式来消费消息好，那什么意思呢？二话不说还是跟这个有关系哈，那么同学们，那么上一步啊，为了怕大家不好看，那么上一步呢，我们是不是已经。获得了我们的消息的consumer了。那么来吧，Consumer点。

第二种方法，第一种方法是调水器物，那么抑制阻塞过时不候，OK，那么第二种方法呢，相对而言好一些，我们用什么叫监听器？要设置第2THAT，请看message listener，那么言下之意就是就是这个消费者就在这个队列里面，我监听着，如果有消息我就消费，没消息我不管。OK，那么所以说这个时候，那么删掉，我们待会再来一组，那么这个时候那怎么用呢？消息的消费者，That message listener叫监听的方式，你看这有个message listener，那么消息监听，那么开高。干什么的message？Listener，那么大家请看一眼这货，我一将看点看是个啥，是不是一个接口啊，那么同学们你们懂的，那么接口的话，我们这儿是不是可以直接拗这个接口，用它的逆累不累，这么说能跟上好，那么同学们。

这个时候请看这有一个消息了，那么也就是说在这个message listen这个接口这它有一个方法叫o message，那么盯着这个消息在监听，就说穿了，我就随时盯着这个杨哥的手势，只要杨哥说这道题做完了，他马上过来抽，那么好了，接下来请看啊，这是啥，Message this。三次啊，重复啰嗦的强调把细节做到位。咱们。第一次啊，就要把事情做好做到位，讲过了，人家给你传的是test message，你也一定要弄成test message，传什么消费什么，所以说在这里干一件事，做个判断。如果。不等于。不等于，那就是这个message并且干嘛message instead of是test message的话，那么OK，我们才能干，听懂了吧，那么避免控制的一弹，然后确认消息O不OK，如果这个能错，说明什么？它合适强制类型转换，那么这个时候我们来test message test message等级干嘛我们的。

Message，但是这个时候他会报错，那么怎么修正，那么这个时候大家看是不是要把我们这个message弄成这个东东，因为有前面的通过，这肯定能够强制转换成功，那么好了，接下来OK了，以后就是我们的什么out，那么test message点是吗？Get看text那么O了，那么这边呢，跟前面的呢一样，这块我干脆就不写了，那么这个时候同学们请看是不是跟刚才的一样，那么这块干嘛报错，那么为什么没有异常，那么这TRY开始弄过了，然后呢，我们这块呢，是用消息监听的方式来干，你是第二种方法，那么接下来我们要干嘛？如果你这么写，它有可能收不到，为什么？因为太快了，它没有关。

它就干嘛呢，它马上就关闭了，那么这个时候，所以说我们这儿就要一个system.in点，对这一步同学们能跟上那么好。如果说需要有这么一个处理，那么言下之意是不是又是各种异常，往外上面抛一个IO的异常，那同学们，这个杨哥给大家讲double的时候是不是讲过？没同感不是吧，二话不说double阿帕奇，那这个有没有带着大家看过啊，那么不废话干嘛？这个是不是保证控制台我们先看double啊，你们来read德莫，我们带着大家关元码看过的时候，你千万别跟我说过，杨哥没带你们看过这个，这有没有S音瑞的，是不是保证控制台不灭呀，那么好，那么接下来那么能规规矩矩的那么。

我们呢，干嘛？Message consumer第二是吗？Close，那么这些东东干嘛我们呢？Close，那们connection，第2CLOSE，其实呢，就说这次单寒如果到这儿的话呢，干嘛写不写作用不是特别大，但是呢，我们还是给它写上啊，这是为什么呢？那么请大家看严格演示啊，那么现在第一种方法用receive同步阻塞的方法，第二种我们是不是设置监听器啊，那么二话不说，那么这个时候，那么假如说为了使监听器，那么message listener，我这边这个消息，那么message listener专门为他做这么一个，好吧。二话不说干嘛老规矩。过来发布完成，那么同学们请看一眼，现在是不是什么都没有为队列3030有三条进来了吧？好的，那么接下来同学们请看啊，那么这个时候我们换了第二种写法，用监听器，那么。

这个时候我们一跑。大家请看消费者接收到消息是不是message listener专门为他做的123，那么由于有this in点什么read的这个方法在，那么请看灯有没有灭，是不是没有灭呀，这一步同学们能跟上，那么所以说这个时候大家请看3030，那么这个时候我一队列变成多少0133待处理的处理掉了，那是不是要出去，那么所以说这个三变成零，这个是不是从零变成三，一正一负刚好抵消啊，那么这个时候干嘛？就是我们的第二种方法叫什么消息的监听器message listener，那么好，同学们，我们呢，这是第一种案例的情况。

再来删除，那么同学们，我们现在把它灭掉，那么这个时候你懂的，里面空空如也，什么都没有，这也灭掉了，那杨哥我要是不写这句话呢？大家请看啊，我们再来。三条没错吧，那么好，接下来我们在这儿干嘛一跑？同学们。嗯，有没有。哎，刚才明明能消费啊，现在根本就没有了，那杨哥什么鬼，你看3030什么意思啊，因为我这没加这句话有点类似于什么消费者干嘛，他现在毕竟是给个面子，我是不是要从Windows连到我们的，通过TC pip的协议，从我们的Windows连到我们的Linux MQ服务器吧，地址加端口各种验证，那大哥你在这不等我唰唰唰全给我关了，那么言下之意什么意思啊，我都还没有消费到，你就已经把它给关了，那么所以说在这块虽然说程序运行通过了，但是根本就没有到MQ是吧，消费掉这三条消息，那么所以说你要用监听器这种写法的话呢，那么这个时候要注意，要给人家一点时间，起码消费完了你才能够什么关闭好吗？那么好，言下之意，这种就是什么一种监听的方法，我就在这一直监听着，那么言下之意，有消息了，我消费，没消息了，我等待。

啊好，那么这个就是我们第二种监听的第二个细节，那么第三一个。