00:00
好,那同学们,我们下面呢来看一下哈,什么情况呢?呃,继续加深我们对于发布订阅主题相关的知识,那么刚才呢,我们呢是操作了这个正常的流程,言下之意就是先启动了消费者,也就是先订阅后发布,那么现在那杨哥你一再强调,但是呢,我现在就要跟你对着干,你给我演示一下,那么大家请看啊。现在我们这儿呢。脱皮口的这块删掉删掉全部都干干净净了啊,现在脱皮口主题这那么首先。注意,对于脱皮口一定是先订阅,有有消费者了,我呢再去。发送,那么相应的谁订阅谁收到,不订阅不打扰,那么接下来我们来搂一眼,反过来没有订阅者,那么大家请看啊,脱皮口现在没有一个人订阅,没有消费者进来,我现在呢,干嘛先生产?
01:04
好,发布完成了吧,那么同学们我点一下脱皮卡,那么这个时候请同学们搂一眼干嘛?没有消费者,但是现在这个主题这边的话,进来队列的里面的话有几个消息记en q,那么进对的话是不是有三条好同学们请看,那么大家思考一下,我现在是不是先生产。再订阅,你们觉得后来这个订阅者可以消费到这三条消息吗?那么大家看。我跑。我是三号消费者。没问题吧,那么好,再来看看我们的脱皮考。几个现在的话是什么,我们的消费者进来了一个,那么消息入队的话呢。有三条,那么does,我就在这儿。监听长,Message listener。
02:00
灯没灭,灯没灭,所以说这有一个消费者,但是回答我同学们控制台后面有没有读到你上一波发的这三条消息,根本没有,那么这个时候。消息的。主消息主题的生产者再来第二次啊,请看啊,我们是生产消费再生产,那么大家猜一下第二次生产的能不能获得,100%能够获得,那么大家请看,又过来了,弄过来大家请看,消费者接受到topic的。主题的消息123,那么这个时候我点大家请看干净一点哈,一个消费者六三,我们讲过最好的是不是消费者乘上这个数字要一样啊,那么现在。进来是六条,但是出去的几条三条,那么分两批次,第一批次三条,由于没有订阅者,你就去推送,你就去发送,就变成了废消息,根本就没有人消费,所以说在这块我们要明白,先要启动订阅,再启动生产,不然发送的消息就是废消息,好,那这个就是我们对发布。
03:14
订阅相关的一个解释和介绍,那么我们来总结一下。那么两个模式我相信应该很清楚了,无非就是消息中间件,具体一点,你的目的地是队列还是topic皮口,那么第二个,那么人家可能会问你,那这个队列和脱皮口有什么区别呢?那么这样呢,杨哥呢,给大家呢总结了一下,罗列了一张表,大家先粗略的看一下。好。来。从这1234这四个维度,那么给大家一分钟做一下课堂练习阅读理解吧。就当是。好同学们,那么给大家看了一下呢,杨哥呢,还是给大家呢再讲一下哈,因为这个面试题呢被问过,他就说基础篇哈,呃,就是说一下你在电商项目中,你们用过这个active MQ,那告诉我一下两大经典的默认端口是多少啊,616168161弟兄们没问题了吧?第二个他就会问,我们都知道,对于这个消息里面两大经典的。
04:23
队列一个叫Q,一个叫脱皮考,那么这两个有什么区别?谈谈你的理解。那么言下之意,一般问这种题目,切记杨哥说过叫什么,至少你跟面试官说什么,三个维度你看。什么东东?计数维度明白,那接下来开工,我们先说队列。负载均衡,因为我们是先从队列开始,对吧,如果那么负载均衡这个不用我解释了吧,刚才我们讲过六条消息是不是135246轮着允许一样的个人云这点如果当前没有消费者,消息不会丢弃,这是从工作模式上来说,那么我发短信给你,你不开机是不是也能收到?好,如果有多个消费者,那么一条消息也会发,只会也怎么着,只会发送给其中一个,因为是一对一的嘛,并且要求消费者AC信息,严哥AC啥前面讲过了,这个是什么?
05:21
我们在三审,这是不是有个,呃这么一个东东干嘛,它是第二个参数,就是怎么个签收方式,由于我们这是用自动默认就帮你什么签收了,所以说这个呢,待会后面我们讲这个的时候呢,再展开,那么topic皮口主题的话是发布订阅模式,如果没有订阅者消息将会被丢弃,我们有没有演示过废消息对吧,多个订阅者干嘛,这些订阅者都会收到消息,那么。不再废话了,好吧,应该都很清楚了,Topic口的这个没有状态队列的这个默认会存储在MQ服务器上,以文件形式保存,那么这一块呢,大家呢,了解一下就行,后面我们会详说,当我们在做MQ的消息持有化的时候,肯定嘛,能够保存到MQ上面,那必然而然。
06:12
肯定是保存在某种持久化的。地方吧,要么是硬盘,要么是文件,要么是数据库是吧,所以说这个时候我们可以先提前剧透。这个时候会保存在它默认有个存储机制叫可看DB,那么它呢,被保存在那个文件下面,好那么我们到时候再展开说,现在由于是入门级别,我先不拔高这个难度,好那么从传递的完整性。脱皮口没有订阅者消息被丢弃,队列消息不会丢弃,那么最后处理效率,那么大家呢一眼,那么处理性能会随着订阅者的增加而什么明显降低,那你坦白讲是吧,100个人订阅了我和10万个人订阅了我这个发布的量变是不是引起质变啊?那么这个呢,我相信大家呢能够理解,那么由于一条消息只发生给几一个消费者,那么各种性能不用多废话,因为最终要明白一对一和一对多哪一个影响严重,那么我相信是不言而喻的。好,那么这个就是我们用编码实现active MQ相关的一些总结和演练,那么希望大家通过第三章的学习,能够迅速入门我们的消息中间键,且能够上手编码。好,我们先给大家介绍到这儿。
我来说两句