00:01
同学们,我们下一个要写谁呢?要写生产者了,对,要写谁,要写这个生产者对吧?完了再写个消费者,咱们就写吧,是吧,因为也不是第一次写了,非常的容易啊,生产者呢,就不用单独再开类了啊,这不就有嘛,是吧?咱之前呢,这个类里也不少写,接下来呢,我们继续啊往下写,写下一个。写下一个什么呢?发送一些发布确认是吧。发消开始发消息,目的是为了测试。什么呢?测试确认。对,确认。什么确认呢?就是发布确认,就是一旦交换机接收不到消息,我们应该怎么办?我们是这么测的啊,我们打算先写完。完了呢,先跑通一下,对,先能跑通一下。如果跑不通,怎么跑不通?当我们把这个交换机的名字一旦写错了,就应该跑不通了。
01:00
是这意思吧,是这意思对,所以呢,我们试一下啊,先写一个成功的,所以下面下面。写一个写一个确认啊。等会儿这个确认的名字,我们是这么的打算再开一个新的CR。名字呢,就叫produce。就这名儿啊。这个名呢,最好再再加一级啊,因为少一个CTRL层,这名字就显得是吧,显得不够不够清晰,等会啊,这怎么重启启服务了。这是快捷键造成的,所以我们来右之键重起个名字啊。重命名。完了呢,紧接着加上一个超的,对,就它吧。这名字稍微好一些啊。来这个是。
02:01
粘上开始发消息测试确认完了,首先呢,我们写一个叫CTR了,完之后再写一个叫request mapping完了再写一个,注意come进行确认,对吧。完了呢,为了打日志是吧,所以这块呢加一个。SLF负接对完这块呢,就进行啊发消息了。完之后再来个get的请求,完再这里面再写一下。这里面再写一下叫发消息是吧,三的message完了把消息发过来。等会啊,这名字我再看一眼,跟那边有没有重名的,如果你请求路径重名是不可以发消息的,例如你看这是发MSG是吧,跟这个不一样。这个是发送完整的。哎,不是MSG是吧,哎,是message是吧,这就行了,不一样,Public。完了呢,我们需要word是吧,发message消息。
03:03
完再来一个圈2A。Pass。再把这个消息字符串类型的Mac的消息接进来。写完成了吗?下面是不是可以发消息了,哎,可以发消息来发一下试试啊。首先呢,你发消息,你像原来一样,你得注入一个叫rabbit。Template,等会template。完了把它拿过来,在这点convert进行发送。那么把你的交换机拿过来啊,交换机在这儿。所以拿着这个名字直接调取交换。机。完了再调取这个名字对应的ROK。完之后再把消息message。放。对,发走了。注意咱发的不是延迟啊,就是发一个正常的消息,这就是发一个正常消息,呃,要写的这么一个内容对吧。
04:04
哎,就这么一个内容,好没了吧,没了完了,紧接着我们打印一下信息。对吧,打印一下就叫叫log log点缝完之后呢,这个信息叫。发消息。发送消息内容为,诶,来个站位符。完之后再把这个消息内容写。哎,正常情况下就是这样。没了吧,没了,这就是发消息。那么接收消息呢,那就更简单了是吧,接收消息呢,咱们就直接到达这边,诶来一个正常的接收消息,例如。什么呢?就叫consumer是吧,就这名吧。Consumer吧,这就是接收消息。对,就他完了接收消息之后呢,打上注解。叫。
05:00
To是吧?打注解完之后,紧接着打一个叫呃,Rabbit listener,完之后再队列是吧,完之后再把那个叫那个类是吧?当中不有它吗?你把这个名字给他。拿过来点儿上。边儿上。之所以点不了,是因为刚才没倒包是吧,现在包已经倒了,点上就来了。对立完之后,紧接着再接收消息,Public avoid完之后呢,接收是receive是吧,Receive完接收什么消息?接收确认消息message。完之后呢,再来一个message,这么一个对象,别导错包啊,别导错包,咱们已经导过了错包了,所以现在呢,咱们比较谨慎,一般不会导错。把它点get对消一体。这就是接收到了消息完之后,我们接收完消息之后呢,打印一下的内容是吧。
06:01
打印一下内容的话呢,你得用日志呗,或者是我们不用日志也行,哎,这个消息不就打印了吗,是吧。消息打印了,那我们可以打印的好看一点啊,例如我们再把这个消息叫SL fo接对。消息打的好一点,例如叫log.o。完了呢,这块呢,写个叫接收。接受到的队列。K。第二。Quit。消息冒号再来个占位符,完了再把消息本身放里面,当然了,这个要是用这个打的话,就不用C打印了啊。我们就可以把它进行快速返回,拿到MSG对吧?完我们把MSG扔。所以,这不就相当于接到消息了吗?对吧,那我们试一下啊,起伏试一下,因为。也挺简单的。
07:00
我们来试一下。咱们看一下怎么测啊,首先咱发消息那边呢,是怎么发的,是这么发是吧,所以咱们组装一下请求的这么一个。路径啊,这个路径前半部分不是这样的了,是叫康。看看这边啊看这啊,这不写着呢,Come完之后紧接send message斜线,例如呃,大家好是吧,哎,大家好。大家好一吧。对吧,一回车一回车完之后,紧接着咱们看下面是不是接收到消息了。你看发送消息内容为大家一接收到消息的内容为大家好一行不行,行没问题,注意这是在没有问题的情况下,那如果出了问题呢。出了什么问题?出了一个这么重大的问题,就是交换机收不到消息。
08:02
不管什么原因可能导致啊,不管是什么原因啊,可能就是对,可能是网线断了。对,可能是这个rob比克服务器重启了。都可以啊,不管什么原因,出了问题了。那么一旦出了问题了。那势必就会怎么办,势必就收不到。那么如果真出问题,那试试啊,如果真出了问题,咱们不用想这个消息投递肯定是丢失了,也收也收不到这个是吧,发也发不出去。
我来说两句