从小白到高手：轻松学会RabbitMQ延迟队列、重试队列和死信队列的技巧!

我不是女神ヾ 2024-03-22 09:33 30阅读 0赞

![b475899075b74505a505151677ea13e6.png][]

大家好，我是小米，一个热衷于技术分享的程序员。昨天，有一位童鞋在 QQ 群里向我请教了一个问题：“一个延迟队列绑定了死信队列和重试机制的重试队列，那消息会进入到死信队列还是重试后进入重试队列呢？”在这篇文章中，我将为大家详细解答这个问题，并介绍延迟队列、重试队列、死信队列这三种常见的消息处理队列，以及如何在 RabbitMQ 中实现它们。

## 消息的处理流程 ##

首先，让我们来看一下消息的处理流程。当消息发送到延迟队列时，根据设置的延迟时间进行等待。等待时间过后，如果消息未被消费者消费，则会进入绑定的死信队列。如果消费者消费了消息，但消息处理失败，消息会被发送到绑定的重试队列，进行重试操作。如果在重试队列中仍然无法处理成功，消息最终会被发送到死信队列。这种处理流程可以有效地处理消息处理失败的情况，确保消息能够被正确处理。

## 延迟队列、重试队列、死信队列的区别 ##

*  **延迟队列是指将消息延迟一段时间后再投递给消费者的队列。**它通常用于处理**需要延迟处理**的业务场景，例如**订单超时未支付、秒杀活动结束后未支付的订单**等。延迟队列通过设置消息的过期时间来实现延迟投递。
 *  **重试队列是指在消息处理失败后，将消息重新投递给消费者进行重试的队列。**它通常用于处理**消息处理失败**的情况，例如**网络异常、业务处理失败**等。重试队列可以设置**最大重试次数**和**重试间隔**，确保消息在处理失败时可以进行自动重试，提高消息的处理成功率。
 *  **死信队列是指无法被消费者成功处理的消息最终被投递到的队列。**它通常用于处理**无法处理**的消息，例如**消息处理失败达到最大重试次数、消息过期**等。死信队列可以用来记录无法处理的消息，并进行相应的处理操作，例如**记录日志、发送告警**等。

## 如何实现延迟队列、重试队列、死信队列 ##

在 RabbitMQ 中，延迟队列、重试队列、死信队列可以通过以下方式实现：

*  **延迟队列：在RabbitMQ中，可以使用RabbitMQ的插件 rabbitmq\_delayed\_message\_exchange 来实现延迟队列。**这个插件可以让我们在声明交换器时指定一个延迟时间，在消息发送到交换器后，会根据设置的延迟时间进行等待，等待时间过后，消息会被发送到绑定的目标队列进行消费。这样就实现了延迟队列的功能。

*  **重试队列： 在 RabbitMQ 中，可以通过设置消息的TTL（Time To Live）属性来实现重试队列。**当消息在目标队列中消费失败时，可以将消息重新发送到绑定的重试队列，并设置一定的TTL，即重试的时间间隔。如果消息在重试队列中未被消费成功，则会再次被发送到重试队列，直到达到设置的重试次数。如果重试次数达到上限，消息会被丢弃或者发送到死信队列。

*  **死信队列： 在 RabbitMQ 中，可以通过设置队列的属性和使用DLX（Dead Letter Exchange）来实现死信队列。**当消息在目标队列中因为某些原因无法被消费时，可以将消息发送到绑定的死信队列中。在声明队列时，可以设置队列的 x-dead-letter-exchange 和 x-dead-letter-routing-key 属性来指定死信队列的交换器和路由键。当消息成为死信后，会被发送到指定的死信队列中。

## 电商项目实际案例 ##

假设我们有一个电商项目，其中涉及到订单的处理。在订单支付后，我们需要发送订单消息到 RabbitMQ 进行异步处理。为了处理可能出现的处理失败情况，我们可以使用延迟队列、重试队列和死信队列来保证订单消息的可靠处理。

首先，我们可以创建一个延迟队列，设置订单消息的过期时间为30分钟，并将该队列绑定到一个延迟交换机上。订单消息会在30分钟后自动投递到绑定的队列。

如果订单消息在延迟队列中未被消费者消费，那么会被投递到绑定的死信交换机，并路由到死信队列。在死信队列中，我们可以记录日志，发送告警，或者进行其他的处理操作。

如果消费者消费了订单消息，但处理失败，我们可以将消息重新发送到一个专门用于重试的队列，设置最大重试次数为3次，重试间隔为5分钟。在重试队列中，消费者会尝试处理消息，并进行最多3次的重试。如果仍然无法处理成功，则消息会被投递到绑定的死信交换机，并路由到死信队列。

通过以上的处理机制，我们可以保证订单消息在处理失败时能够进行重试，并最终投递到死信队列进行处理。这样可以有效地处理订单消息处理失败的情况，确保订单消息的可靠处理。

以下是一个简单的 Java 代码演示如何在 RabbitMQ 中实现延迟队列、重试队列和死信队列的功能：![4e13b210e637414cbb44e6dd3c1f85a3.png][]

![6371fd1b1aa24202b6c1aff642c4643b.png][]

![25a09a2e4b8d4fee94af75775d17aa2c.png][]

通过上述代码，我们可以看到延迟队列、重试队列和死信队列在实际应用中的使用方式。延迟队列用于设置消息的延迟处理时间，重试队列用于处理消息处理失败后的重试操作，死信队列用于处理无法成功处理的消息。

## END ##

*  **延迟队列通过设置消息的过期时间来实现延迟处理，将消息发送到一个特定的交换机，并设置延迟时间作为消息的过期时间。**当消息在延迟队列中等待的时间超过设定的延迟时间时，消息会自动转发到绑定的死信交换机，从而进入死信队列。
 *  **重试队列通过设置消息的最大重试次数来实现消息的重试操作，将消息发送到一个特定的交换机，并在消息的 headers 中设置最大重试次数。**当消息在重试队列中被消费者消费但处理失败时，会根据设置的最大重试次数将消息重新发送到重试队列，直到达到最大重试次数后，消息会被发送到死信交换机，从而进入死信队列。
 *  **死信队列通过将无法成功处理的消息发送到一个特定的交换机来实现。**当消息在队列中发生死信情况时，如消息过期或重试次数超过最大重试次数等，消息会自动转发到绑定的死信交换机，并进入死信队列。

以上是延迟队列、重试队列和死信队列的简单介绍和实际应用案例，通过合理使用这三种队列，我们可以有效地处理消息的延迟处理、消息处理失败的重试以及无法成功处理的消息，从而提升系统的可靠性和稳定性。

希望本文对大家在使用 RabbitMQ 时有所帮助！欢迎关注我的微信公众号“**知其然亦知其所以然**”！

## 参考文献 ##

*  RabbitMQ官方文档：**https://www.rabbitmq.com/**
 *  RabbitMQ in Depth：Gavin M. Roy
 *  Mastering RabbitMQ：Simon M. Pleasant
 *  RabbitMQ Cookbook： Sigismondo Boschi
 *  RabbitMQ中文文档：**https://rabbitmq.mr-ping.com/**

![fdc8e470787d454d85a14d386dcfae87.jpeg][]

[b475899075b74505a505151677ea13e6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/98444535a351444b8f6cbf32b24c2f50.png
[4e13b210e637414cbb44e6dd3c1f85a3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/e3cfc9013b104d5aa80818c08634ce73.png
[6371fd1b1aa24202b6c1aff642c4643b.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/1f1a423809a148e89865a20dbb703661.png
[25a09a2e4b8d4fee94af75775d17aa2c.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/c92ff7c1b9f24f89903373a29b405637.png
[fdc8e470787d454d85a14d386dcfae87.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/496ef366410449b4869d9ac863f5addc.png