00:00
同学们,我们接下来呢,发送一个延迟队列啊,演示一个实战当中在企业上班时的一个延迟队列,代码呢,应该怎么写?首先呢,我们得有一个案例啊,现在目前呢,有一个代码的架构图。这个架构图呢,这里面有几个队列呢,有。三个队列,两个交换机。哪两个交换机呢?分别一个交换机叫X,一个交换机叫Y。那么不用想,这个X呢,肯定是一个普通的交换机,这个Y呢,肯定是一个延迟交换机。对,完了呢,我们又有三个队列,分别为QAQBQD对QD。那么QA和QB都是。普通的一个队列。那么QD呢?是一个死心队列。对,是一个死刑队列,完了,普通的两个队列呢,延迟时间是不一样的,一个是延迟十秒,一个是延迟40秒。
01:06
完了,我们演示的场景当中呢,就是你选择,如果你选择这个交换机柔筋可以为xa的话,那么延迟多久十秒?如果你选择roting k是。XB的话,那你延迟多久,延迟40秒,所以呢,这么写代码呢,可以有一定的选择性,因为不同的业务延迟的时间是不一样。那么我们根据不同的业务可以选择什么?选择不同的ROK就可以达到不同的延迟效果。完了,我们发送发消息谁呢?是P发消息,谁接收消息呢?C接收消息,那么从P开始发到C接收到消息,中间间隔多久呢?间隔可能十秒,也可能是40秒,完全取决于你到底路由哪个队列。如果你路由队列是QA的话。
02:02
那么你就延延迟十秒,那如果你是Q币,它延迟40秒。对,这就是我们本次代码的一张架构图,为了完成这张图上的这个案例,我们代码要写多少东西呢?要写。多少哎,要写三个啊,没多少,第一个要写一个消消生产者发消息的,还要写一个C消费者。接收消息的。咱们之前呢,这个没有整合per部这个这个工程的时候呢,当时我们是把所有的声明,包括。这个普通交换机、延迟交换机和普通两大队列以及延迟队列都是放在消费者当中进行声明。但是自从你整合了这个工程之后。他的这个声明是有单独的一个叫做配置文件类代码,就这个由他来进行声明,比如说专门就有这么一个类是声明。
03:08
这个叫普通交换机,延迟交换机,普通的两大队列以及延迟队列,诶这些是由一个单独的类来完成,不需要生产者和消费者在负担这块的业务。你只负责发消息,你只负责接收消息就可以了。所以呢,整合了这个死分布的这个框架呢,使得代码更加的清晰明朗。好,那我们既然已经非常清楚了,那我们就写一下这个代码,要写多少东西呢?要写三部分代码,首先别着急发,也别着急接收。先把中间这些东西。先创建出来。也叫声明出来。那么声明的东西有一个,两个,三个,四个,五个,对两个交换机,三个队列外加上三个队列之间还有关系吗?有关系包括交换机与队列A,队列B之间的捆绑关系是吧?绑定关系完,同时与。
04:15
交延迟交换机与延迟队列之间的捆绑关系,都需要这个叫配置文件类代码来完成,所以这个是整体啊,由一个类完成,也就是说我们这是第一步啊,这是第一步,那第二步呢,自然是。呃,生产生产消息了是吧,第三步呢,当然是消费消息了。所以总共几步,三步来完成。
我来说两句