00:00
出门再写一个,写一个消费者,那消费者不挨个都写了这个写过了这个呢,打算不写了,哎,再写一个报警的情况是吧,写一个报警的跟他是一样的啊。报警消费者来我们看看能不能收到啊,所以呢,咱们再写一个消费者。消费者在这里是吧,完了我们写一个报警的。报警的就是单词叫什么警告是吧,警告完了呢,Consumer,对,就这么一个报警。写上啊,这是一个叫叫报警。消费者。完之,再打上注解。打上这个日志租界。完了,下方进行消息的接收。接收。接收报警。消息。完了之后再来一个监听器。
01:01
再来一个队列,队列的名字在那边已经确认,这边已经加了,你看这个就是报警队列呗,所以你用这个名字进行,呃,大写点上。等会包没导入的吗?倒包了啊,刚倒的慢啊。点上这个叫报警队列,就它,反之呢,是帕雷VO完之后紧接着re。Receive是receive完之后呢,报警。那么MSG是吧,消息完了再把消息对象接进来。就这完了,再往下呢,把它转成我们的MSG消息啊,你有一个字符串类型的message,点钙的消息体。完之后呢,进行log的一个AR级别打印报警了嘛,这个时候就。报警。发现不可,哎路由。消息冒号对完了呢,来个占位符,什么消息?
02:04
不是加号,是逗号mst。这就行了。好,那我们准备起伏测一测吧,对吧,测之前是这样的,一定要将原来的这个这个交换机你得给它删掉,因为原来交换机已经在咱们的这个MQ当中已经创建了,后来这个交换被我们改了吗?改了这个交换机,改了一个又能怎么的,又能转发备份了。所以呢,这个交换机必须要删掉重来,删掉重来的话什么意思呢,就是我们。大蒜。到这儿。到这里面是吧。把我们之前产生过的一次交换机名字叫。确认交换机。把他干掉。得把它删除掉,重新创建,因为它你改信息了,你改信息了就必须重新创建。好,咱们再重新起一下吧。
03:04
咱们之前测过啊,咱们之前是测过,这个叫路不可路由是咱写过。咱之前写代码看一眼啊,什么样啊。打开看一下,我们发了两调取这个方发消息,发了两个消息,一个可以路由,对,一个不可以路由,因为路由的ROK不写错了吗?那多写了个二。是吧,那个不可路由这个就会被。发送到。这个叫报警,消费者对,就按照这这张图是吧,进入到报警就这里。那么我们发了,你看发了几条,两条啊,发一条发两条,其中有一条是正常,诶到达这个消费者的完,另外一条不正常,就必须诶转过来走他。到达这个位置,当然也会走走一份上上面这个,但是上面这个我们不是没写吗,是吧。来吧,试一下。把它。这个不是这个啊,是debug好清理一下,完我们一起发一下。
04:04
刷新。发完之后一起看。你看这来了。当中发了几条呢,两条啊,其中这是第一条,这是第二条,发两条,第一条消息成功的被你看被接收到了,大家好,K1。没有经查到的是被报警发现不可漏由消息叫大家好,K12。所以咱们这次的这个路由不可不可路由转发这个叫备机交换机是成功的,经过这个测试结果啊是。成功的,也就是说以后呢,我们如果发现这种情况,其实也可以不用将消息啊,就是发不了消息的事儿转发给什么呢,或者是回调给生产者,让怎么呢让。这个由备份交换机来完成。那么这个时候同学们会发现一点啊,我们有一个重大的问题是。
05:01
我们同时配置了这呢。我们同时配置了由由什么,由生产者。回退消息。和备份交换机一起使用,两者同时开启消息究竟何去何从呢?我们之前的这个参数对应的回退消息方法,我们写不写,是不是写了,你看写了在这儿,在这儿呢吗。我们都。在。在这儿,不在这是在在这呢,在这呢。也就是说我们交换机应答以及队列回退我们都写了。并且配置文件也开启了,你看也开启了一个队列的回退。对,对立的回退。就是回头不可路由啊,那么同时我们也配置了。这个叫备份交换机,两者是同时存在的。那么。
06:00
以谁为准了?以备份交换机为准了,备份交换机的优先级要高一些。所以最终你会发现,我们经过测试的答案是以备份交换机为准,你看备份报警发现了不可路由消息,所以是以他为准的。没有在报谁呀,没有在报这个消息回退的这个。打印啊,要是打印的话,这个应该打这这句话你看消息是谁被交换机回退回了啊,退回原因是什么?这句话打印了吗?并没有打印表示当不可。到达时这个退回是没有执行的。执行谁了,执行了这个备份交换机,所以备份交换机的预算机高一些。
我来说两句