RabbitMQ 实现延迟队列的两种方式！

定时任务和RabbitMQ延迟队列实现概述

定时任务在日常开发中非常常见，如日志备份等可通过cron表达式轻松实现的任务。然而，有些任务如电商订单支付超时处理、智能砂锅煮粥定时、会议预定提醒、安全工单超时提醒等需要延迟执行的场景，则需要延迟队列。本文以RabbitMQ为例，探讨了如何实现这类延迟队列的两种方法：使用插件和DLX实现。

1. 使用rabbitmq_delayed_message_exchange插件

• 插件安装：下载插件，复制到Docker容器中，并在容器里启用插件。
• 消息收发：创建Spring Boot项目并配置RabbitMQ，定义CustomExchange交换机并设置延迟类型，创建消息消费者和单元测试方法来发送带有延迟时间的消息。

2. 利用DLX实现延迟队列

• 延迟队列实现思路：结合DLX（死信交换机）和TTL（消息超时时间）实现延迟队列，未被及时消费的消息将进入死信队列。
• 案例实现：配置RabbitMQ，设置普通队列和死信队列，发送消息并在消费者处验证。

3. 小结

文章介绍了两种利用RabbitMQ实现延迟队列的方法，为有类似需求的开发者提供可行的解决方案。

TDD、BDD、ATDD都是什么、有什么区别？（下）

了解更多

想要了解更多内容？

查看原文：RabbitMQ 实现延迟队列的两种方式！

文章来源：

江南一点雨

扫码关注公众号