图解RocketMQ之消费者如何进行消息重试

news2025/1/12 9:54:53

大家好，我是苍何。

在上一篇[[图解RocketMQ之生产者如何进行消息重试]]中分析了当生产者发送消息失败的时候，RocketMQ 是如何进行重试的。

最后留了一个问题，生产端的消息是重试 hold 住了，但如果消费者出现异常，消费某一条消息失败，这时候 RocketMQ 会怎么处理呢？

这还是很普遍的场景，试想一下如果订单系统发了个消息出去，库存系统消费这条消息失败，那会出现一个什么奇葩的现象呢？

就是你明明下了单买了一包辣条，结果迟迟收不到货，一查人说你的辣条订单压根没出库。

这可了得，吃不上的上辣条先不说，劳资付出去的钱可不能打了水漂啊。

那有了 RocketMQ 的消费重试，就能解决这个问题。

所以，为了了解辣条正常出货不被卡顿，学起来吧🐶。

消费重试的基本原理

当消费者在消费消息时失败，RocketMQ 会自动进行消息重试。对于顺序消息，默认会重复 16 次，每次重试间隔时间为1秒。

而对于无序消息（如普通、定时、延时和事务消息），则可以通过设置返回状态来达到重试的目的。

那如果重复 16 次之后还无法正常消费，那怎么办呢？

RocketMQ 会把该消息直接发送到死信队列中，这名字够吓人的，我先用正式的解释下：

死信队列用于处理无法被正常消费的消息。当一条消息初次消费失败，消息队列会自动进行消息重试；达到最大重试次数后，若消费依然失败，则表明消费者在正常情况下无法正确地消费该消息，此时，消息队列不会立刻将消息丢弃，而是将其发送到该消费者对应的特殊队列中。

RocketMQ 将这种正常情况下无法被消费的消息称为死信消息（Dead-Letter Message），将存储死信消息的特殊队列称为死信队列（Dead-Letter Queue）。在 RocketMQ 中，可以通过使用 console 控制台对死信队列中的消息进行重发来使得消费者实例再次进行消费。

这就像是你的女朋友连续给你发了 16 条消息，你一条都没有回复，气急败坏的她直接将你拉入黑名单，此时你就成了死信消息。

而女朋友的黑名单就是个死信队列，要想再次恢复和你宝贝女朋友的聊天，得她在微信上操作才行。

通常引起消费重试有以下两种情况：

异常重试，包括消费者返回消息失败状态标识或抛出非预期异常。
超时重试，包括在 PushConsumer 中排队超时。

聪明的你肯定看出这里又抛出一个概念 PushConsumer，我最讨厌留坑而不填坑，所以介绍下什么是 PushConsumer 吧。

其实它是一种消费者类型，在 RocketMQ 中把消费者分为 PushConsumer、SimpleConsumer 和 PullConsumer。

下面一张图简单介绍一下这 3 种消费者的区别吧：

RocketMQ的3种消费者的区别

很遗憾的是，在官方文档中和 PullConsumer 的介绍还没补充完🐶

PullConsumer官方介绍待补充

不过没关系，不是我们这一章的主角儿，哈哈。

消费重试策略

RocketMQ 的消费重试策略的内部机制其实是通过控制一下 3 个大将展开的：

重试过程状态机：控制消息在重试流程中的状态和变化逻辑。
重试间隔：上一次消费失败或超时后，下次重新尝试消费的间隔时间。
最大重试次数：消息可被重试消费的最大次数。

通常是通过控制重试次数和重试时间间隔，来修改具体的重试状态来达到重试的目的。对于重试状态，大家可看下这张图：

消息状态机-官网

RocketMQ会为每个消费组都设置一个Topic名称为“%RETRY%+consumerGroup”的重试队列（这里需要注意的是，这个 Topic 的重试队列是针对消费组，而不是针对每个 Topic 设置的，也就是一个组内的消费者都是用的该重试队列），用于暂时保存因为各种异常而导致Consumer端无法消费的消息，每个Consumer实例在启动的时候就默认订阅了该消费组的重试队列Topic。

考虑到异常恢复起来需要一些时间，会为重试队列设置多个重试级别，每个重试级别都有与之对应的重新投递延时，重试次数越多投递延时就越大（实际上就是配置的延时队列的级别level）。RocketMQ对于重试消息的处理是先保存至Topic名称为“SCHEDULE_TOPIC_XXXX”的延迟队列中，后台定时任务按照对应的时间进行Delay后重新保存至“%RETRY%+consumerGroup”的重试队列中。