00:03
好,呃,我们说过这个发送同事啊,我们现在再看一下消费同事。就是我这边消费啊,就是这个这个这个出现了问题了啊,怎么样处理呢。呃,这里边我们分为这样的六点来给大家说啊,首先来看顺序消息的消费城市。对于顺序消息啊,当consumer。呃,消费消息失败以后呢,为了保证消息的顺序性,其会自动不断的进行销售重试。直到消费成功。注意啊,他他这个。呃,就是就是我们一定得注意这个情况。就是这个东西,它会不断的一直进行重试,直到成功,而整个这个从事过程里边。我们的应用啊。对于会出现什么消息消费被阻塞的情况,就是整个这个过程里边,我一直在从事,他不会继续再消费其他的。
01:08
不会继续消费其他的。所以,呃。我们这儿呢,就是就是一定得留意这个问题啊,就是。嗯,由于。啊,由于这个对肾虚消息的。从事。嗯,是。无休止的。不间断。是不间断的。啊,直到什么,直到消费成功,所以所以啊,就是呃。对于顺序消息的消费。
02:01
5B。啊,务必要保证我们的应用能够。及时。监控。并。处理消费。失败的情况。因为呃,这样避免吧,避免这个消费。呃,被永久性。阻塞。就是这个过程啊,就是其实还是很危险的。因为你对于这个顺序消息啊,只要消费失败,一般情况下给大家这样说,一般情况下只要消费失败了,自己处理不好。就我们生产方来讲啊,这种这种消费失败正常是不会失败的。但是只要出现失败了,一般他自己是处理不好的,所以我们必须要能够及时的你监控到。
03:01
把他消费失败,然后呢,及时的处理。这个消息失败,否则他真的就被你永久阻塞了。这是一定要注意的地方啊。呃,当然这这里边说啊,我们这个从事啊,呃,他实际上是。有间隔的啊呃。写到这儿吧。这个。消费。同时默认。间隔时间为段。1000毫秒。啊,这一秒钟啊。诶,1000毫秒。当然这个1000毫秒是这个东西默认的,它是可以修改的啊,我们看一下。Consumer。呃,我们。就这吧。
04:00
在这。给给他写一下吧。然后点。Set。呃,Suspend content million啊,比如说我这儿给它设置成这个。让间隔间间隔小一些,100就100毫秒啊那。这个啊是呃。顺序消息。消费。失败。的消费。从事。时间间隔。默认。嗯。1000。一切好。诶。毫秒是吧?呃,但是它有个取值范围,这需要注意的其取值。
05:06
范围。嗯,喂。十。十到。这个。30秒。3万。这它它是有取值范围的啊。吃到。30是吧,是不是30秒嘛,是吧,啊3万毫秒啊。嗯。这样吧,给大家。写到这儿。写到这儿,嗯。来个这个吧。
06:05
再来上一个他。单位。后面默认1000。其实范围。怎么也不行是吧,我还说让他弄到一行啊,那就这吧,就这嗯。呃。然后呢,那其实我们因为前面我们说过这个说过这个消费从事了啊,不是呃,消息消息发送从事啊,那这里面我们刚才还说到。关于这个顺序消息啊。
07:02
剩余消息没有什么没有发送。失败。同时。但是有消费充实,所以这这个这个我们呃,对比一下啊。注意。顺序消息。肖。消息。呃。没有,呃。发送。啊,失失败。城市机制。但具有。肖贝。失败。从事。这是吧,这这这两个啊,我们需要呃对比的记忆一下,OK,这就是关于顺序消息,它的消费模式。
我来说两句