00:03
好,那么下边我们再来看这个无序消息的消费城市。那对于无序消息,那我们前面说的这个是有序消息是吧,就是无序,无序消息是什么?那无序消息就是我们的普通消息。呃,延时消息,事物消息啊。呃,普通消息。呃,还有什么呀,这个延时消息。事物消息是吧?这就是我们的无序消息啊,呃。对于无消息,当消费消息失败的时候,可以通过设置返回状态达到消息重试的结果可以设置。设置啊,可以设置。呃,返回状态是吧,这个返回状态什么呢?呃,我们一会儿这儿啊,就会给大家说这个返回状态的问题啊,一会专门说那不过需要注意无序消息的从事。
01:04
只对我们集群消费方式生效。注意这点。它只对集群。只对集群消费模式生效,当然默认就是集群消费是吧,然后广播消费方式不提供失败从事都行。即对于广播消费,消费失败以后,呃,失败消息不再啊,继续消费后边后续的消息这个啊。广播消费啊,广播消费是这样的,呃,有些时候啊,我们对于。嗯,我们这样,我找到啊,找到原来咱们那个图。小小的消费。交换模式。广播消费,这个广播消费啊,实际上是什么呢?每个消费者消费所有的消息,每个消费者消费所有的消息是吧,但他们又属于同一个。
02:03
很多时候我们什么时候用这个,呃,广播消费呢。嗯。比如说某些呃,就是实际性要求比较高的,他要求啊我们的consumer啊,要求我们的呃消费所有的消息。那所以我就搞出来很多,让他们同时都消费,谁先消费完,我就取谁的最后那个结果。其他的我就不用不再管了。将来他们在并行消费。他们在病人要问谁先消费完,谁就有了结果了,我就要你这个结果就行了。所以这时候大家想一下,如果说啊,我这里边儿某一个消费失败了。他对整体有影响吗?你这个消费失败了,我还有这么多的呀。对不对,其他都在消费这些数据,所以对于广播消费啊,对于广播消费。重新回答下。
03:00
广播消费方向啊,不提供我们失败城市。这个这个策略啊,那么前面我们说了,他这边啊,这个对于顺序啊,消息它的重试间隔是一秒钟,那么我们无序消息它的从事。间隔是多少?这个比较复杂。我们看。第三点啊,消费从事次数与间隔,注意我们下边讲的这些啊。通通都是无序的,都是针对无序的啊。所以我们看这个对于无序消息,呃,集群消费下的从事消费,所以你看这个是有前提的,首先无序消息,然后呢,又是集群消费。这个东西是有前提的啊。呃,他的从事,那么每条消息默认从事16次。
04:01
最多从事16次啊,但每次从事的间隔不一样。大家看这是从这次数12345678~16,这是间隔。就是你第一次失败了?你正常,呃,消费失败了,然后我第一次从事就是距离你正常消费那一次,我十秒钟以后正常。呃,吃完肉以后进行第一次。第一次又失败了。或者30秒以后进行第二次。第二次又失败了,我一分钟以后进行第三次。等等等等等等。那第十前面啊,第15次。尝试也失败了。那么我两个小时以后进行第16次。从事。这最多十六十六次,当然这16次啊,老雷给他算了一下,算了一下啊。就是如果一条消息啊,我。
05:00
最后呃,经过重试啊呃。我一共从事就是最多可以从事多长时间。就把这些消息这些时间给他加一块啊,把这些消息这个时间加一块啊,这个。呃,怎么说呢。若一条消息在一直。消费。失败。的前提下。嗯。在这个前提下。啊,将会在,将会在呃。多长时间?呃,就是。正常消费后。的B。四小时46分。分号进行。
06:00
16。从事。四小时将将近五个小时。因为第15个。第15个也失败了,我两个小时以后再进行第16次。所以这一块加一块啊是多少是。四小时46分,将近五个小时啊,将近五个小时。当然了,这个啊,呃,默认次数是16次,我们这个是可以改的。呃。消费啊,就这个消费。点。下。Max。Reconume times看到了吧,这个reconume,哎,我比如说我设置十次。
07:01
那就是说你最多从事十次就可以了。对吧。这是修改。呃呃,修改这个消。消费同事。十。嗯。消费。从事。次数是吧,呃,Max consume。啊,就是重新消费,这样suspend suspend就是休眠啊,休眠。嗯。就是你休眠的时间,就中间间隔时间是吧。然后呢,当然咱们肯定有哥们会问这个问题,那老雷,我这要给你设成20次门。你这一共16个。那我给你设了20行不行可以。呃。就是。
08:01
我们可以这样吧,呃,修改吧。修改,呃。呃,消费。同事。45。咱写一下啊。还是考出来给他。然后。我拷出来给他看。是吧,哎,然后我们来说啊,就是这个。对于修改。过。的,呃,从事。次数。呃,怎么说呢。将呃,按照以下策略吧。
09:03
呃,将按照以下策略。呃。就行吧。啊,什么呢,第一个。就是。呃。若修改值。小于16。呃则按照呃。指令。指定间隔。嗯,直针间隔这个进行。从事是吧。若修改值。大于16除以大于16。则超过16次的。从事。时间间隔。聚美两小时。就是你以后你第17次,你不是只要20嘛,第17次间隔也是两小时,18次也是两小时,都是两小时。
10:07
这这是呃,我们大家需要注意的这么一小点吧。另外还有一个问题啊,就你这做了这个修改以后,因为我的一个group里边啊,好多consumer,你现在这个consumer。修改了。其他的呢?我这个改成比如说十了啊,我改成十了,那其他的注意要改都改。要改都改。就是。啊,对于。Consumer。呃,仅修改一个。Consumer的消费。同事。次数。
11:00
则会运用到该。中。所有其他。啊,他会用到所有的实例啊。当然了,这边肯定咱们有哥们又想到一个问题,说,哎,老雷,但是你打了我感的单。他敢了,大家都改,那怎么办?啊,若。出现。桌子。做了修改的情况对吧。采用什么覆盖还是?Forget。方式。生效。去什么?是不是你最后?呃,这。后被修改。的职会。嗯。覆盖前面设置的。
12:05
啊,这是关于这个这个这个这个这个。间隔啊,次数和间隔它的设置啊,我们大家就要留意这么几点吧,当然我们一般啊从事也不会让我们从事这么多次,你像将近五个小时啊,到这就将近五个小时了。对不对,OK。
我来说两句