00:03
好,呃,我们下边来看一下这个代码啊。代码就是它里边delay下边的,它这有个delay producer是吧,我们刚才看到了,这都不用和你说了啊是吧,再往下我要发送呃,发送呃这个消息了是吧,发送消息呃十条我们就十条吧。然后你看在这儿。最关键点是不是在这儿。这什么指令消息?延迟等级。喂。三级,三级是延迟多长时间,我前面一直在说啊,这延迟。十秒。延迟十秒。对吧,其他的都一样。对不对,哎,这这啊,我们添加了这样一句话。干什么输出消息?
01:03
对。被L送。时间。对吧,就你你你要我准备,我就在这个时间这边这一发送是吧?呃,我在这个时间啊,就把消息给你发过去,对吧,我这一发啊,然后紧接着。呃,走这呃。紧接着他会,他会有这样一个输出,对吧,有这样一个输出。呃,然后我们再看这。我们再看这。这是消息的消费的消费,呃,可以看到这是从。从第一条开始消费啊,我们这里边定义的这个topic是B啊topic b。呃,然后再往下消费是吧?呃,Consume message,我要消费,这不是逐条消费这些消息,我这。是不是输出?
02:02
呃输出呃消息被。呃,消费的。时间。是吧,啊。就是。就是我们跑一下啊,这跑的时候我我先运行这个。先云他啊。当然现在这套币是没有的,对吧。在启动了,现在没有啊,没有我要生产了。生产啊,大家注意看。哎,我这生产了,你看这边啊。十秒钟以后。他才会出来。你看这这会儿还没有呢啊。
03:02
十秒钟到了呀。十秒钟到了,怎么怎么还没有,诶大家看出来了吧,是不是十秒钟啊,十秒钟以后。他会消费到这些。但是你看啊,我们能够对比一下,我如果把它去掉,这就是一条普通消息。对吧,我把这个。对吧,这个倒无所谓了。呃,我去掉的是它,我这个没有重启啊,我这个可是没有重启的是吧,我就重启它就可以了。好出来了,你看这是不是也出来了,这马上是不是消费。和刚才那个延迟消费是不是就对比了。是不是这就对比了?
04:00
Okok。呃,这所以这个很简单啊,呃,这就是我们的这个叫什么,呃。还是一样啊,给大家把这个。加了注释。代码卡住了。然后。是吧,嗯,把这个。呃,需要大家注意。注意这个东西啊,呃,这样吧,这个这个大家看起来说实话,这看起来不是那种。你注意啊,我我这样。把它清掉啊。我这儿。就。
05:03
我这儿就生产。一条消息,我们生成一条消息啊。那剩下一条是吧,这边。一会儿看啊。你看啊。看到这儿。这是时间24。13。二十四二十三看到没有。是不是差十秒?就差十秒啊,十秒钟啊,那还是那句话,我我如果说把它去掉。是吧,然后这个清掉。嗯,然后。这个重新运行。
06:00
24、56。二十四五十六对不对。这是不是就看到这个延迟。是吧,啊,它的效果了啊,OKOK。
我来说两句