00:00
好,各位同学,那么接下来我们把发布订阅的命令做一下当场演示,用案例把前面所讲的命令给它串一下,串起来和刚才一样分三组,第一个那么就是发布订阅,第二个呢,演示批量订阅和发布,第三一个取消订阅,来我们呢,先做好啊这个初始化的工作,ABC3台机器。AB模拟两个客户端,C代表发布好,来吧,先第一组。强调过,先订阅,再去发布。规矩不能乱,顺序不要错,那你说我非要反过来呢?那么同学们来订阅成功之前发布的消息是收不到的,现在没人订阅,C作为一个客户端,他来发布publish,假设频道叫C1哈。有没有,没有任何意义,我推送出去一条消息,不OK,所以说同学们先订阅,那么来吧,Script CE这个频道我。
01:09
只定义了只定阅了C1这个频道,而这个呢,大家请看,我是C1C2,没问题吧,两个频道,同学们OK,好,上面就是种类,这个就频道名字,那么这个就是true OK来了,那么publish好了,你对CE1这个频道发布什么消息?Hello喽,CE同学们请看几个人收到两个,哎,那么所以说在这订阅了CE1这个频道的收到了一个消息,来自于谁?C1频道丢过来的内容是什么?Hello c1,那么来这同学们请看消息,C1发送过来的内容是什么?Hello c1,好,各位亲。搁到这订阅的客户端,每次可以收到一个含有三个参数的消息,分别是消息种类、始发频道,实际内容够清晰了吧。好,第一组过。
02:02
那么第二个演示批量订阅以及统计和发布的情况,那它这是什么意思呢?请大家先请先看啊,这个叫PU sub number pattern,就是说你现在有没有。开始呢,订阅过带通配符的这样的一种情况,那么下面我们先统计啊,那么同学们啊,这是三个,那么现在我们先统计,我现在呢是只写过了一种命令啊,就是发布了是C1,然后呢,我们的订阅也是C1 C1C2是具体名字的,听懂了吧,所以搁到这儿,我们呢,回到我们的这个发布订阅讲完了这个叫P什么。Script就是带pattern这种模式的,按照模式批量订阅,也就是说我们现在还没有给大家演示。星号井号这样的,所以我们第一组啊,先来统计。
03:00
只统计使用P萨命令。带模式执行过的有没有没有,所以现在同学们请看我跑到这儿啊。有没有,根本就没有,OK,那么怎么样才能出现呢?我们来同学们啊,现在这个C我也换一下它呢,也作为了一个订阅者,OK,好。现在它叫P干嘛呢C。星号A问号弟兄们没问题吧?那么大家请看啊。刚才是我们根本没有用这种命令去做过模式订阅,所以说它统计的话是多少是零,那么现在我们再统计一次是几,就变成了二,能理解这个命令是什么意思了吧?OK,好,那么下面我们再来试试这个啊来。搁到这几代表具体名字的活跃的频道有几个?C1和C2,我们前面是不是说过这个A只订阅过C1,这个B可是定阅过C1和C2的,明白了吗?好了,那么接下来这个统计我们呢?说了两个再来,现在这哥们是不是pscript?
04:19
然后呢,是带是吧。通配符的,我们来试试啊,统计,刚才这个哥们专做统计吧,那么我们再来一个窗口啊,给同学们呢。这个是一个发布的啊,来他干什么呢?Client干A好了,那么就是publish,请看好啊,他要发布消息了。那么搁到这儿,我们呢,直接过来,他要发布消息的话呢。PCE1假设啊,那么这个就是我们的这个CE1V2这个版本,那么大家觉得应该有几个频道可以获悉三个,第一个指订阅了C1的。
05:06
收到了吧,第二个B客户端订阅了C1和C2的,收到了吧,第三一个,那么就是用C。信号定义了模糊版的,请看它叫什么t message,这是代表什么?Pattern带有通配符,这样的也能收到,所以说这就是几个三个,那么好,同学们请看啊,咱们再来现在C11,那么就是C11 OK,注意几个只有一个收到,为什么只有这个通配符的这个才能获悉,弟兄们。讲完了,不难吧,就这么简单,OK,所以呢,在这块。我们刚才呢,给大家呢,都给他演示了,这个是具体的,这个是看通配符订阅的有几个啊,比如说刚才我们是两个,但是我笔记里面这个一统计是几个,是四个,为什么?因为我们pscript用的是四个通配符,OK,那么还有最后一个pop sub number channel,那么就是某个频道有几个订阅者,那也很简单了,那么这个是pop sub number sub c1C1这个频道有几个订阅者,有两个,OK,也是一个什么具体的一个细节,好,那么同学们来吧,咱们搁到这啊,也是给大家干脆也就全部讲完给大家看看吧,哎哎,统那个统计是这个做是吧。
06:25
还是那个来C1频道有几个人有两个订阅,具体的是不是AB订阅了,订阅了空配符的,那不算OK好了,那么同学们这个呢,也很简单好,那么第二组也就是我们刚才所演示过的啊,我就挨个挨个给大家做了各种发布,各种统计都有了,那么下面第三组什么鬼取消订阅不用我说了吧,简单到。我都懒得做了,你们自己下去做一下吧,很简单,这个是订阅的C1嘛,那么请大家呢,你看他说按照CTRLC去退出一下,退出以后你连上的话呢,你在script c1就搞定了,OK,不难啊,那么假设啊,他说了退出的话是相当于按这个呢,等于你退出,那么A客端退出好了。
07:12
那么按script谁C就完了,这么说够简单吧,那么你要想重新订阅,那么你再重新开启一曲script就完了,OK,好,那么同学们,这个就是我们的什么案例演示这几个命令了解到这足以,那么接下来来吧呢,可以实现消息中间键这样MQ的功能,你看刚才已经看到了,发布订阅是不是就是订阅者就是不停的在那监听。收到消息是我频道订阅的,直接给你显示好,但是前面也说过了,我个人绝对不会用啊,了解就行了,所以我也不想过多的深入,那么它的缺点主要是有这么几个,第一个没有持久化。因此必须先。执行订阅在等待发布。
08:02
如果先发布消息了,那么该消息由于没有订阅者,消息将被直接丢弃,多么恐怖的一件事情况丢消息,第二个消息只管发送。对于。消费者而言,消息即发即失,不管接收,也没有A签收机制,我并不知道这个消息是不是100%被你收到甚至消费,所以呢,以上的缺点就导致呢,这个red pop就是个小玩具,在生产环境中几乎无用武之地,因此5.0以后增加了stream数据。那么我们前面已经详细讲过这个register stream,这消息流对吧,他肯定要比他强大,即便用这个了,我们也说过了,专业的事交给专业的人,OK,所以不再废话,这个就是给大家呢做一个知识全面性的讲解,至少让你知道了有这么个东东足矣。OK,好,不再过多展开,这章就到这儿,谢谢各位。
我来说两句