RabbitMQ 延迟任务(限时订单) 思路

一、场景
    我们经常会碰见,一个需求就是,发送一条指令(消息),延迟一段时间执行,比如说常见的淘宝当下了一个订单后,订单支付时间为半个小时,如果半个小时没有支付,则关闭该订单。当然实现的方式有几种,今天来看看rabbitMQ实现的方式。

二、思路:rabbitMQ 如何实现
1:rabbitMQ为每个队列设置消息的超时时间。只要给队列设置x-message-ttl 参数,就设定了该队列所有消息的存活时间,时间单位是毫秒。如果声明队列时指定了死信交换器,则过期消息会成为死信消息

2:需要设置的参数为:
图片[1]-RabbitMQ 延迟任务(限时订单) 思路-牛翰网

三、原理:上图

1:将延迟队列(queue)在声明的时候设置参数 “ x-dead-letter-exchange ”,“ x-message-ttl “ 分别对应 死信路由器(dlx_exchange) 和 消息过期时间(比如说30分钟)。

2: 一个消息从生产者发送到延迟队列 ,在延迟队列里等待,等待30分钟后,会去绑定的死信路由(dlx_exchange)。通过死信路由的规则,走到死信队列。

3:这时候监听死信队列的消费者就可以接收到消息,消费消息。比如说提交订单限时15分钟的支付时间,时间到后,查看该订单是否支付,如果没有支付,则关闭该订单。

来源链接:https://www.cnblogs.com/tzzp/p/18631601

© 版权声明
THE END
支持一下吧
点赞13 分享
评论 抢沙发
头像
请文明发言!
提交
头像

昵称

取消
昵称表情代码

    暂无评论内容