延迟队列

1. 延迟队列是什么？

延迟队列是一种带有延迟特性的消息队列，队列中的消息不会立即被消费，而是要等待指定的延迟时间后，才会被推送给消费者进行处理。它的核心价值在于实现任务的异步延迟执行，广泛应用于订单超时关闭、定时通知、重试机制等场景。

2. 延迟队列特性

延迟触发：消息入队后，不会立刻被消费，需等待 TTL（Time-To-Live）到期。
有序性：通常保证消息按照延迟时间的先后顺序被消费（先进先出的变种，按到期时间排序）。
可靠性：支持消息持久化，避免服务重启后延迟任务丢失。
可重试：消费失败时，可重新入队等待下一次处理。

3. 常见应用场景

订单超时处理：用户下单后，若 30 分钟未支付，自动关闭订单并释放库存。
定时任务通知：下单成功后，延迟 24 小时发送 “商品使用评价” 提醒。
失败重试机制：接口调用失败时，延迟 5 秒 / 10 秒 / 30 秒后自动重试，避免瞬时故障导致的任务失败。
缓存过期刷新：缓存数据到期前，延迟触发刷新逻辑，保证缓存数据的有效性。
分布式定时任务：替代传统的 Cron 任务，实现更灵活的分布式定时触发。

4. RabbitMQ实现延迟队列

用 RabbitMQ 实现延迟队列，核心思路是利用 RabbitMQ 的 TTL（消息过期时间） + 死信队列（DLX）组合方案，让消息在普通队列中等待指定延迟时间后，自动转发到死信队列，再由消费者消费死信队列中的到期消息。
给普通队列设置 x-dead-letter-exchange（死信交换机）和 x-dead-letter-routing-key（死信路由键），并为消息设置 TTL。

5. RabbitMQ实现的延迟队列和JDK中自带的延迟队列有什么区别？

JDK DelayQueue：JDK java.util.concurrent 包下的 DelayQueue 是一个本地内存级别的阻塞队列，基于优先级队列实现，仅能在当前 JVM 进程内使用，队列中的元素需实现 Delayed 接口（指定延迟时间）。
RabbitMQ 延迟队列：基于 RabbitMQ 中间件实现的分布式延迟队列，消息存储在 RabbitMQ 服务器，可跨进程、跨服务器、跨服务使用，依赖网络通信。

JDK DelayQueue 坑点：

消息仅存于内存，服务重启 / 崩溃会丢失所有未执行的任务，绝对不能用于核心业务。
大量消息（如百万级）会占用大量 JVM 内存，易引发 OOM 异常。

RabbitMQ 延迟队列坑点：

存在 “队首阻塞” 问题（前面消息未过期，后面消息即使过期也无法消费）。
依赖网络通信，存在少量延迟误差（毫秒级），不适合对延迟精度要求极高的场景（如微秒级）。

核心差异：JDK DelayQueue 是本地内存级延迟队列，轻量高效但无分布式 / 持久化能力；RabbitMQ 延迟队列是分布式级延迟队列，支持跨服务 / 持久化但依赖中间件、复杂度稍高。
选型原则：单进程、非核心、小量延迟任务用 JDK DelayQueue；分布式、核心、大量延迟任务用 RabbitMQ 延迟队列。
补充建议：如果需要更高精度的分布式延迟队列，可考虑 RocketMQ 原生延迟队列（弥补 RabbitMQ 队首阻塞问题）。