101-重试队列及其实现原理

好，下面我们来看这个从事队列。从队列啊，呃，我们前面讲过的。在哪，在这看看。管理。这是不是个从事队列，我们当时在这儿给大家当然当然仅仅是简单给大家说了啊，简单给大家说了说。呃，实际上因为这里边，呃，我们后讲这儿的时候，后续还有很多东西没有说到啊，用到的知识都不清楚，我没法计讲，那么在这儿我们需要。把这个。从队列详细给大家说一下。是吧？对于需要从事消费的消息，并不是consumer在等待了指定的时长以后，再去拉取原来的消息进行消费。就我们这个从是怎么实现的，不是我在这等等等啊，你比如说啊，这个我等十秒，等十秒以后我进行啊，这个这个一第一次从试样不行，我考啊，再等等等等30秒我再进行重试，他不是这样的。

不是这样的啊。那它是什么呢？而是将这些需要从事消费的消息放入到了一个特殊的topic队列。给它放到那个特殊的topic队列里边，然后进行再次消费的。这个特殊的队列就是从事队列。就是我要把它扔到一个队列里面。那当然这这里边啊，我们继续来看，他说当当出现啊，需要进行从事消费的消息时，Worker会被每个消费者组注意是每个消费者组设置一个topic，名称为他re try，你看re try，然后这是什么？

Person'group at persons。所以这是什么？Consumer group at consumer group。的从数队列，所以它是为什么消费者组设置的？这个是吧，那么对于对于这句话解读啊。对这句话的解读。就是有两两条。有两条，第一是什么啊，这个从事。队列是。对。消费者。主的。是针对消费者组设置的。而不是针对每个。Topic。设置什么意思我们知道啊，一个topic消息，它可以有很多的。

去。那我的这个。呃，这个这个从类是针对这个消费者组的。而不是topic。对吧，这个我们需要注意的就是呃，一个。一个。消息，呃，可以。呃，让。多个。嗯。嗯，很厉。消费者。就进行。消费。是吧，所以呃，会。嗯。一些。消费者。个。创建。这个从事。这里对吧。第二个。第二个，创建这个消费对待的时机是什么？

是当出现需要进行从事的消费者。从事消费的消息来说。就是只有当。出现需要，呃，进行从事。消费的。消息时。才会为该。消费者。五。啊，创建。同时。那平常你没有需要从事消费的，他就不需要，他就没有不跟你借。不给你念啊，这是我需要注意的，另外，呃，其实说这儿的时候，哎。说这样说啊，其实我就突然间想到还有一个问题。你这不是一共16次吗？默认有16次，如果16次重试还不行怎么办？是不是？

这个问题。哦，还不行，那怎么办啊，如果还不行啊。呃，将会在这这这第16次重试是吧，啊若。仍然。失败。对吧，这怎么讲消息。投递到胆儿。哥们说从事队列，这已经是在从事队列了。啊，后边我们要说的死性对联。死性。当然这个是我们后边要给大家说的啊，呃，一会儿再讲它死刑对联啊，这这这这这个突然想到它了，呃，我现在想给大家说什么呢？我发现一个现象啊，一个什么现象大家看。十秒30秒，一分钟两分钟三分钟是吧，我们看着这啊看着这。

这边有个延迟等级。你看这是什么？啊，一秒。是吧，五秒。不一样啊，但你看这十秒30秒，一分钟两分钟三分钟，一直到十分钟20分钟，30分钟，一小时两小时诶。嗯。你看。A到十分钟，20分钟。半个小时，一个小时，两小时，也就是说我们发现一个很很有意思的现象啊，就是我们的同事。这个间隔。和我们延迟等级很相似。除了前俩以外。其他都一样。对不对，我们是不是发现这样一个很很有意思的事情是吧。

呃。喂。呃，注意，呃，就是就是。也。呃，消费。从事的时间间隔。与与谁与？呃，延时消息。呃，与延时消息的什么。这个叫。岩石。等级。十分潇洒。怎么？啊，除了。除了呃没有呃延时。等级的。前两个。时间对吧。

其他。世界都是。对不对，那这这发现这样一个现象啊。那为什么呢啊，这说到我们这个从事对的他的工作原理啊，博克对于从事消息。的处理，所以从事消息的处理是通过延时消息实现的。所以他的处理是通过岩石。消息。谢谢。怎么做的呢？但是先把你如果有消息啊，需要需要从事了第一次消费出现问题了。好，我马上把这个消息先扔到哪，扔到这个，这这这我们大家知道，就那个延迟队列是吧，那个topic。啊，扔到这个延迟队列中。先生呢？

他肯定是先扔到那个延迟级别是一的，就是QID是一的。先扔到QID是。呃，错了，就ID是一它的延迟等级。它的延迟等级，第一个是第一个是几呃十秒，十秒是延迟等级。是。十秒延迟等级是几？123这三是吧，延迟等级是三，对的QID是二。是不是扔到QID是二的那个队列里面。对吧，他先先生的是他啊，哎，然后延时时间到了以后。那延迟时间到了，我们正常的啊，这个延迟我们延迟消息会把这个消息会将消息投递到。投递到你正常的，按理说应该投，投递到你的目标topic现在的目标topic是谁？目标变成他了。

变成这个从事队列。所以你看这个实现原理实际上和谁。和延迟等级，这样就底层是延迟等级实现的。对不对，呃，这个延迟消息啊，用这个延迟消息实现的。对不对，那这样的话，我们大家对于这个。从事队列就有了深入的认识了，就不像我们之前呃，讲讲讲这个原理这儿的时候是吧，讲这个ET的管理，这里边这个呃。这个这个从对那简单的说了一句。是不是啊，OKOK。