RabbitMQ实现延迟消息的方式-死信队列、延迟队列和惰性队列

本文主要是介绍RabbitMQ实现延迟消息的方式-死信队列、延迟队列和惰性队列，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

当一条消息因为一些原因无法被成功消费，那么这这条消息就叫做死信，如果包含死信的队列配置了dead-letter-exchange属性指定了一个交换机，队列中的死信都会投递到这个交换机内，这个交换机就叫死信交换机，死信交换机再绑定一个队列，死信最终会进入到这个存放死信的队列，这个专门存放死信的队列成为死信队列。消息会成为死信原因会有很多。

比如消费者使用basic.reject或basic.nack声明消费失败，消息的requeue重入队参数设置为false。在失败重试策略中，默认的RejectAndDontRequeueRecoverer会在本地重试次数耗尽后，发送reject给RabbitMQ，消息变成死信，被丢弃。

还比如消息是一个过期消息，超时了无人进行消费。原因是因为消息在队列中是可以设置生存时间的，即TTL（Time To Live生存时间值）。死信的产生，可能情况就TTL的设置分为两种情况：

1.队列设置超时时间，进入队列后超过ttl队列超时时间，消息会变为死信

2.消息设置了超时时间，队列接收到消息后超过ttl消息超时时间，消息会变为死信

上述两者都设置了，以时间小的为准（白话理解：尽可能使时间超时）

再比如要投递的队列消息满了，无法投递。

延迟队列模式：利用TTL结合死信交换机，发送消息后，消费者延迟收到消息的效果。延迟队列的应用很常用，比如延迟发送短信，用户下单在规定时间内未支付会自动取消订单，预约工作会议指定时间后自动通知参会人员等等。

使用RabbitMQ的延迟队列需要使用插件DelayExchange，并且需要将交换机声明为delayed类型。当消息发送到delayExchange延迟交换机时，会判断消息是否具备x-delay属性，如果属性具备说明是延迟消息，将消息持久化到硬盘，读取x-delay值，作为延迟时间。x-delay时间到期后，重新投递消息到指定队列中。

Lazy Queues惰性队列，惰性队列在接收到消息后会直接存入到磁盘中（而非内存），并且在消费者要消费消息时才会从磁盘中读取到并加载到内存，基于这个特性多以惰性队列支持百万条消息的存储。可用于解决消息堆积问题（当生产者发送消息的速度超过消费者处理消息的速度，会导致队列中的消息堆积，直到队列存储消息达到上限，达到上限后再发送的消息就会成为死信，可能会被丢弃，这就是消息堆积问题）（解决消息堆积问题还可以增加消费者，提高消费速度来解决，但是惰性队列思路，将消息持久化到硬盘上提高堆积上限更具有实际意义）。

这篇关于RabbitMQ实现延迟消息的方式-死信队列、延迟队列和惰性队列的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---