rabbitmq 实现延时队列的方式

刺骨的言语ヽ痛彻心扉 2023-06-08 14:00 232阅读 0赞

延迟队列存储的对象是对应的延迟消息，所谓"延迟消息"是指当消息被发送以后，并不  
想让消费者立刻拿到消息，而是等待特定时间后，消费者才能拿到这个消息进行消费 。  
延迟队列的使用场景有很多，比如:  
令在订单系统中， 一个用户下单之后通常有 3 0 分钟的时间进行支付，如果 30 分钟之内  
没有支付成功，那么这个订单将进行异常处理，这时就可以使用延迟队列来处理这些  
订单了 。  
~用户希望通过手机远程遥控家里的智能设备在指定的时间进行工作。这时候就可以将  
用户指令发送到延迟队列，当指令设定的时间到了再将指令推送到智能设备 。

在 AMQP 协议中，或者 RabbitMQ 本身没有直接支持延迟队列的功能，但是可以通过前面  
所介绍的 DLX 和 TTL 模拟出延迟队列的功能。  
在图 4-4 中，不仅展示的是死信队列的用法，也是延迟队列的用法，对于 queue.dlx 这个死  
信队列来说，同样可以看作延迟队列。假设一个应用中需要将每条消息都设置为 10 秒的延迟，  
生产者通过 exchange.normal 这个交换器将发送的消息存储在 queue.normal 这个队列中。消费者  
订阅的并非是 queue.normal 这个队列，而是 queue.dlx 这个队列 。当消息从 queue.normal 这个队  
列中过期之后被存入 queue.dlx 这个队列中，消费者就恰巧消费到了延迟 10 秒的这条消息 。  
在真实应用中，对于延迟队列可以根据延迟时间的长短分为多个等级，一般分为 5 秒、 10  
秒、 30 秒、 1 分钟、 5 分钟、 10 分钟、 30 分钟、 1 小时这几个维度，当然也可以再细化一 下。  
参考图 4-5 ，为了简化说明，这里只设置了 5 秒、 10 秒、 30 秒、 l 分钟这四个等级。根据  
应用需求的不同，生产者在发送消息的时候通过设置不同的路由键，以此将消息发送到与交换  
器绑定的不同的队列中。这里队列分别设置了过期时间为 5 秒、 10 秒、 30 秒、 1 分钟，同时也  
分别配置了 DLX 和相应的死信队列。当相应的消息过期时，就会转存到相应的死信队列(即延  
迟队列〉中，这样消费者根据业务自身的情况，分别选择不同延迟等级的延迟队列进行消费 。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM0NTIzMzc_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTM0NTIzMzc_size_16_color_FFFFFF_t_70]: /images/20230531/888c7b604e3b45869bc838bd4e281431.png