RabbitMq(十二) 借用死信交换机实现延迟队列

概述:延迟队列即在消息发送后延迟固定时间后再去接受处理,做相应的一些相应。

应用场景举例:在电商购物后,订单支付前发送消息信息,在三分钟之后检查订单是否支付成功,如果支付,则取消订单并库存数量恢复;或者一些其他需要延迟处理场景。

借助死信交换机实现消息延迟接收处理,mq中的消息流转图如下:

RabbitMq(十二) 借用死信交换机实现延迟队列

代码可以参考 RabbitMq(十一) 死信交换机DLX介绍及使用 进行实现。