在实际的业务中我们会遇到生产者产生的消息，不立即消费，而是延迟一段时间在消费。RabbitMQ本身没有直接支持延迟队列功能，但是我们可以根据其 TTL（TIME TO LIVE）和 DLX（Dead Letter Exchanges）实现延迟队列.
1.TTL
RabbitMQ可以针对消息和队列设置TTL（过期时间）。队列中的消息过期时间(Time To Live, TTL)有两种方法可以设置。第一种方法是通过队列属性设置，队列中所有消息都有相同的过期时间。第二种方法是对消息进行单独设置，每条消息TTL可以不同。如果上述两种方法同时使用，则消息的过期时间以两者之间TTL较小的那个数值为准。消息在队列的生存时间一旦超过设置的TTL值，就成为死信（dead message）
2.DLX（Dead Letter Exchanges）
当消息在一个队列中变成死信后，它能被重新publish到另一个Exchange，这个Exchange就是DLX，绑定DLX的队列称之为死信队列。消息变成Dead Letter一向有以下几种情况：
消息被拒绝（basic.reject or basic.nack）并且requeue=false
消息过期
队列达到最大长度
3.延迟队列使用场景，比如：
在订单系统中，一个用户下单之后通常有30分钟的时间进行支付，如果30分钟还没有支付成功，那么这个订单将进行异常处理，这个时候就可以使用延迟队列来处理。
4.实现延迟队列
假设一个订单系统中将每条支付消息设置为30分钟延迟，生产者通过exchange.normal交换机将发送的消息存储在queue.normal队列中，消费者订阅的并非是queue.normal队列，而是queue.dlx队列，当消息从queue.normal队列中过期之后被存入queue.dlx队列中，消费者就恰巧消费到了延迟30分钟的这条消息（推送消费方式），支付成功后则需要通过拉取消费方式从queue.normal中拉取消息消费。
网友评论