要求:在E-商务峰值场景中,如果用户下订单10分钟,则需要偿还库存。
在许多情况下,我们需要延迟队列。这篇文章以RabbitMQ为例,与您讨论延迟队列。
使用RabbitMQ的RabitMQ_DELAYED_MESSAGE_EXCHANGE插件来实现计时任务。该方案更简单。
官方网站插件 - 下载地址
如上图所示,延迟消息队列插头安装已完成
核心代码如下:
此时,生产消息是通过接口调试工具执行的
使用Postman模拟生产消息,其效果如下:
然后消费者消息,使用命令,如果执行了5秒钟,它将成功
此时,RabbitMQ异步延迟消息队列已完成
该代码已由GIT仓库上传
原始:https://juejin.cn/post/7094916704043712519