Rabbitmq之延迟队列_mq dxl

什么是延时队列

延迟队列存储的对象是对应的延迟消息，所谓"延迟消息"是指当消息被发送以后，并不想让消费者立刻拿到消息，而是等待约定时间后，消费者才能拿到这个消息进行消费。

延迟队列的使用场景有很多，比如:

• 在订单系统中， 一个用户下单之后通常有30分钟的时间进行支付，如果 30 分钟之内没有支付成功，那么这个订单将进行取消处理，这时就可以使用延迟队列来处理这些超时订单了。
• 用户希望通过手机远程遥控家里的智能设备在指定的时间进行工作。这时候就可以将用户指令发送到延迟队列，当指令设定的时间到了再将指令推送到智能设备
• 用户注册成功后，如果三天内没有登陆则进行短信提醒
• 密码定期失效

 RabbitMQ本身没有直接支持延迟队列的功能，但是可以通过DLX(死信队列) + TTL 模拟出延迟队列的功能， 此时的DLX（死信队列）就可以被认为是延时队列。

例如：一个应用中需要将每条消息都设置为 10 秒的延迟， 生产者通过业务交换机exchange.normal将发送的消息存储在业务队列queue.normal中。消费者订阅的并非是 queue.normal 这个队列，而是死信队列queue.dlx（即延时队列） ，当消息在queue.normal中过期之后被存入queue.dlx队列中，而监听queue.dxl的消费者就能正确消费到延迟 10 秒的这条消息。

如何实现一个延时队列

假设这么一个场景，我们需要将过期5秒、10 秒、 30 秒、 1分钟的消息分别交由不同的应用系统处理。为满足需求，生产者在发送消息的时候通过设置不同的路由键，以此将消息发送到与交换机绑定的不同的队列中。这里队列分别设置了过期时间为 5秒、 10 秒、 30 秒、 1分钟，同时也分别配置了 DLX 和相应的死信队列。当相应的消息过期时，就会转存到相应的死信队列(即延迟队列〉中，这样消费者根据业务自身的情况，分别选择不同延迟等级的延迟队列进行消费。

简单实现代码后续再补充