00:00
同学们,我们继续写这个代码。咱们上节课呢,已经把。这一段啊,中间的这段配置呢,终于写完了啊,代码呢,你看写完了。写完之后呢,紧接着我们下面的任务呢,开始写下一个叫生产消息,也就是生产者。完我们写完生产纸之后呢,再写消费者。对吧,所以呢,先写生产者好。把这图挪开。我们打开我们的项目,找到生产者,生产者呢,其实它就是一个抗超的层。将来呢?我们打算用发消息的方式,发请求的方式将消息发过来,真的。就像这样是吧,发一个嘻嘻嘻,来发这么一个三个字,把消息发过来。那我们将来发这个消息呢,把这个CCC的仨字作为消息发送给我们的消费者。
01:02
所以呢,我们现在的代码应该怎么写呢?应该按照这个链接来写。对,完了我们会写一个能够接收请求的一个controller层。来,来一个叫controller,完之后再写一个发消息send message简写是吧,Controller。就他这个呢,我们就是我们的发消息是吧,这是我们的,呃,发送延迟。消息对发送延迟消息。发送延迟消息呢?延迟多久呢?延迟默认现在是十秒钟吧,我们来看一下是不是十秒,因为咱上节课已经写完了。啊,发生发现是一个是十秒,一个是40秒,两个时间,好,那么我们接下来开始发一下试试啊,首先这个类要好用,必须打上注解,打上一个叫rest CTR,注解完之后呢,再打一个叫request mapping完之后再写一个。
02:09
TTL,那为什么要写它呢?是因为文档上将来发消息发的是这一段,你看是一个8080端口的这么一个请求,我放在这里。对,完了它的第一个路径级别呢,就是TTL对吧,完了之后紧接着再往下。发消息对吧,开始发消息完之后呢,再来一个get请求。请求当中后半段你看TTL已经放在上面了,那你再把后半段的发消息。发消息放在这,你再把这个CCC是吧,CCCC再弄过来,那当然它是个变量啊,因为呃是个变量,所以呢,这个位置呢,你写一个叫啊MYI对这么一个变量。
03:00
完之后呢,再public最终呢,返回值你可以返回可以不返回啊,所以我们void不返回就可以。Send msg发消息完之后再来一个pass value完之后再来一个字符串类型的message,将它进行接收,注意名字一定要跟它名字一样,这样才能接收进来,把CCCC是吧接收进来。完了再往下可以打印一下日志是吧,如果打日志呢,这个位置呢,还得加一个叫哎。是吧,S LF four接这么一个日志,这个日志呢,非常好用啊,现在目前企业上班都要用这个日志,完了呢,紧接着ino,哎,打一个日志。打印一下时间啊,毕竟我们是一个延迟消息,那么延迟是否是十秒还是40秒,取决于开始时间和结束时间,往我们发的时候来一个当前时间。对,完了当前时间冒号来一个占位符。
04:03
占位符之后呢,紧接再来一个逗号隔开,对发送一条。信息给。两个。对,给两个谁呢?两个TTL对立。对,名字你随便起啊完冒号都是什么内容是吧,什么消息又来一个占位符,后面呢,你再加上这个叫当前的时间。当然需要字符串是吧,转成字符串。完了再来一个消息本身message。对吧,这就打印了这么一条日志,从而呢记录下时间,这个是占位符的啊,就是把这个时间这个位置会替换前面的这个大括号。把这个消息会替换成前面的大括号,大括号就后期就没有了,那打印的日志应该是当前时间,冒号完就是这个时间。完发送一条消息给两个队列什么消息对吧,所以这个大括号就后期就会没有啊,因为大括号属于占位符啊,相当于占一下位置。
05:07
会被后面的两个参数替换掉。完了,接下来开始发消息。发消息呢,我们用的是这个spring公司提供的一个叫template,用它发。完他发消息呢,拿过来往这一写,首先呢,我们发一个点convert是吧,准备发一个延迟为十秒的消息。那么你得把图拿过来,哎,拿过来往这一放。这呢,往这往,往哪放,往这儿放,哎,往这儿放。我们先发一个十的,再发一个40的是吧,所以我们得发一下,首先交换机是多少。对,交换机是X,你可以手写X。完了,K是多少xa?对不对对啊,逗号都是照抄的,这是交换机叫X嘛,完它就xa嘛,完了再往下呢,它让你填写的是发送的消息。
06:06
本身的这个内容,那你怎么写,你就写叫消息字TTTL为多少,为十秒,你再写一下,你是准备发十秒的那个那个那个队列是吧,十秒的一个。啊,对。没了,完了呢,后面呢,消息本身再把消E加上。哎,Message加上message这个消易不是嘻嘻吸嘛是吧,嘻嘻西吗?完了呢,你把CCCC加上,就表示来自于十秒的消息对立。那为什么十秒呢?跟你的指定的交换机以及这个roting k有直接关系。你这个交换机和柔钉K注定了走QAQA就是十秒钟。以此类推,你再来一个例如交换机依然是X,但是这个叫QXB是来自于40秒的。
07:04
队列完了呢,消息是一样的。就这不一样,一个是十秒,一个是40秒。好,这就是我们发消息,呃,就是这么写的。把这个写好之后呢,我们就可以写另外一个消费者了。
我来说两句