温馨提示:文本由机器自动转译,部分词句存在误差,以视频为准
00:00
同学们,我们接下来写一写生产者。刚刚我们定义了交换机队列,以及他们之间的这个绑定关系,接着呢写一下生产者,再写一下消费者,对。好,我们先写生产者。写生产者的话呢,我们打开我们的CTR的层,对,一直由他来发送。我们都已经发送两波了是吧,发个消息,又发了一个带延迟信息的消息,而我们就写第三个。这个还是开始发消息,只不过这是基于插件的,完了也要发送什么呢?发送消息及。时间,只不过这个时间是延迟的。世界。好来,那么我们把上面抄一下啊,首先这个路径名我们这改一改,这个应该是发送叫做。赖对,这种延迟消息完之后传一个消息,再传一个时间,时间不是TTL时间啊,是延迟时间。
01:06
你看延迟时间,哎,就这么发完之后呢,紧接下面我们再把这个拿过来复制一份,这个呢改一下子叫发送。消息对不对,发送消息呢,我们也可以不用改,因为重载没问题是吧,至少消息这么接,但是这个延迟的时间它是一个整数。对整数。世界。好了,这呢,还是重载方法是吧,重载完里面发消息是一样的嘛,对一模一样啊,只不过打印的这个打印的这个时间是一样的,也就是说你把这个打印。这句话还要放这儿,例如当前时间是多少,发送一条多久的一个延迟消息,对吧?这是这都是一模一样的,只不过就这不一样,对。这是言之消息。完了发给这个不是TTL信息是一个延迟信息是吧,所以发送信息给延迟队列。
02:09
对,给延迟队列完了,队列的名字你可以写上叫底。累的我点儿上。困完了,消息的内容放在上。你看最终呢,咱们发送一条消息呢,就是哎发送一条这呢写着。当前时间是多少,发送了一条时长为多少毫秒的信息给延迟队列,哎,他呃,内容是什么呢?哎,内容是这个消息体是吧,消息的内容。完了,定义完之后,紧接着开始正式发送。那么正式发送呢,跟上面的发送呢,其实是一模一样的,对一模一样。只不过交换机不叫这个名字。交换机叫什么名儿?叫这个名字。对,你像交换机的这这个名字,那么我们为了能够去找到这个交换机的智能交换机的名字,你其实可以用这个类名对吧?哎,直接在这写啊,类名点上,由于它是一个常量,其实可以直接写交换机的啊。
03:11
完了呢?Rolling k也可以直接写,例如这个类的类名。点上柔ting k,这是柔ting k。对吧,完了发送消息,消息当中要求设置延迟,延迟消息是吧,这个位置要改成。设置。延迟消息。把你的延迟的消息。这个时间放在里面。单位呢,依然是毫秒,也就是说单位还是毫秒。MS这个叫。单位啊,MMS。所以呢,也就是说一会儿你发消息的时候,记住这个是毫秒值。好,没问题,这就是发送消息。
我来说两句