00:00
同学们,我们接下来呢,再写一个生产者。对吧,这个生产者呢,既要发消息还得发时间,因为咱们这次创建的QC根本就没有时间。对,没有一个过期时间,或者叫存活时间TTL,所以需要在这个位置发出来,对吧,发出来所以呢,我们去写一下。来到咱们的生产者这边,生产者发消息,这呢。之前咱们开始发消息,只是发消息对不对,所以咱们再写一个新的,叫做开始。发消息对,开始发消息呢,我们这里面呢,既要发消息还要发。TTL这个时间,所以get。Get完之后,紧接着咱们发一下是吧,叫散。过期写上过期时间是吧,Print。完了再来一个叫inon是吧,完了呢,MSG对吧,这叫发送过期时间的一个消息,完之后呢,紧接着再斜线。
01:12
当然前面最好加个斜线是吧。更加的好看一些。不加其实也不错啊,也没有,不,不会报错message消息完了再来一个什么。时间吗?叫TTL时间。But the public。完了,我们也不需要什么返回值啊,所以说继续VOID完了呢,Send my。方法名是可以相同的啊,只要你写重载是吧,写重载因为你写了其中一个参数之后呢,哎,你再写一个不就行了吗?是吧,Pass。好,完了再来一个什么类型的呢?字符串类型的TTL。Time。一定要对应上啊好,所以时间也有了。接下来呢,你怎么办?你一如一如既往的像原来一样发消息并记录当前时间嘛,对吧,所以这个当前时间这个日志呢,我们就粘过来吧,是吧,扔在这儿时间是一模一样的。
02:11
哎,发送一条数据给两个T点了,不是啊,是给那个。TTL,对立。对,是给TTL一个啊,是给一个TT队列。可以这么改一下名是吧,发送一条。这呢发送一条时长。时长是多少呢?时长是多少得写上是吧?时长是多少加一个占位符完了呢,毫秒。毫秒。TTL。信息给队列。解压给队列C。对,给队列CQC是吧,队列QC。完了,消息是什么?在这儿呢,占位。所以呢,我们这里头时长是三个数是吧,第一个是时间,第二个是多长时长完了我们这个位置呢,就得这么想。
03:08
这个是被第一个位置占了啊,这个是对吧,这个是占第二个位置,第三个位置,第这是第二个位置时长,就是我们传进来这个TTL看。这样啊,被占了,最后呢,发了一句话,就是当前多长时间发送了一个多长毫秒的一个,呃,TTL信息给队列QCQC的内容是多少是吧,这么个情况完发吧。所以这里面叫rabbit template,点上convert water发的时候用谁发呢?得用这个发,就我看得用。有交换机得有ROK,同时有消息还得有参数嘛,是不是。这个吧。对这个啊,那就咱们写一下。来吧,写一下啊,写一下的话呢,咱们就写了第一个是交换机。
04:00
交换机咱们依然是原来的这个叉吧,对,是这个叉,你看这图啊,看这图在这写着呢,你发消息不给这个叉吗?啊,这X是X不是给X方完了呢,这个柔进K是多少差。叉C是吧,XC对完了再往下呢消息。消息。消息是message。对。完了第四个参数是什么参数呢?我们来去看一眼啊,因为我们呃参数太多蒙圈了,这呢,你看它就提示我交换机柔丁K消息来加上第四个参数是吧,这第四个参数就是专门设置这个过期时间的,或者存活时间的。它是一个接口。咱们去看一眼啊,把它点一下。点一下啊,这这这个是吧,这个是啊,完了呢,它是一个接口,我们进去看一眼,是一个函数式接口,可以用拉布达斯表达式的,对不对,完了拉布达斯表达式的话,那我们用它来用这个,用这个啊,这个是不是它的方法,这个是它的方法,所以一个入参一个返回值,你看入参是一个message对象,返回值还是message对象,而且message对象千万别传。
05:14
类型别传错了,因为咱之前都传错过一次是吧。好,接下来我们写一下啊。把谁写过来呢?把它写过来吧。复制。往往这儿一写。完了这个位置呢,传一个呃,Message完来一个箭头是吧,这个括号其实可以不写啊。尽量的可以省略,怎么简单怎么来啊。箭头大括号下来。下来就是由于这个你名字跟他一样了是吧,所以呢,我们最好起个别的名字呗,叫MSG呗是吧,完再往下这里面。返回值依然是MSG,对,就它完这个位置设置。发送消息的时候的。
06:01
延迟时长,对在这写完了呢,你把时长往里面一。一些获取一个参数,再设置一个过期时间。那你设置多久啊。你设置多久都行,但是呢,不要写死,因为人家从页面对吧,从前面请求已经传过来了,那就是他呗,你把时间填里。想发多久发多久。诶是吧,是这就完成了,那么等到接收消息还用写吗。就不用写了,因为接收消息都是一样的。对,没有什么,没有什么变化。所以呢,我们消一方就不用写了。
我来说两句