如何基于Redis实现延时任务
约 1289 字大约 4 分钟
Redis 过期事件监听实现延时任务功能的原理
在 Redis 中，过期事件监听功能依赖于 Redis 的 keyspace notifications，这是一种通过发布/订阅（pub/sub）模式来监听键的变化的机制。当 Redis 中的某个键过期时，Redis 会通过一个默认的频道 __keyevent@<db>__:expired 发布该键过期的事件。
关键流程
- 设置过期时间：当你为一个键设置过期时间时，Redis 会在后台根据过期时间来标记该键为过期。
- 发布过期事件：当键过期时，Redis 会通过
__keyevent@<db>__:expired频道发布一个过期事件消息。 - 订阅频道：客户端通过
SUBSCRIBE命令订阅__keyevent@<db>__:expired频道，监听到过期事件后，客户端可以获取过期键的消息并执行延时任务。
Redis 过期事件监听实现延时任务功能的缺陷
1. 时效性差
过期事件的发布时机有一定的延迟，因为 Redis 使用 定期删除 + 惰性删除 策略：
- 定期删除：Redis 会定期检查一部分过期的键并删除，这可能导致过期事件发布的时间滞后于键实际过期的时间。
- 惰性删除：当客户端访问过期的键时，Redis 才会删除它。因此，如果某个键在过期时并未被访问到，过期事件也不会立即发布。
2. 丢消息
在 Redis 的 pub/sub 模式中，消息是非持久化的。如果没有订阅者在消息发布时订阅了频道，消息会直接丢失。因此，如果在发布过期事件时没有客户端订阅相关频道，消息会丢失，导致延时任务无法触发。
3. 多服务实例下消息重复消费
由于 Redis 的 pub/sub 模式是广播模式，当多个服务实例订阅同一个频道时，所有实例都会收到消息，导致同一条消息可能会被多个实例处理。这会导致消息重复消费的问题，需要额外的处理来避免这一情况。
Redisson 延迟队列原理与优势
Redisson 是一个基于 Redis 的 Java 客户端，提供了多种分布式功能，其中包括 延时队列（RDelayedQueue）。它使用 Redis 的 SortedSet 数据结构来实现延迟任务的功能。
原理
- SortedSet 结构：Redisson 使用 Redis 的 SortedSet（有序集合）来存储延时任务。每个任务会被插入到 SortedSet 中，任务的分数（score）表示任务的执行时间。分数通常是一个时间戳，表示任务应当执行的时间。
- 扫描过期任务：Redisson 使用 Redis 的
zrangebyscore命令定期扫描 SortedSet 中的任务，查找出过期的任务。符合执行时间的任务被移除，并加入到就绪队列中。 - 阻塞队列：Redisson 使用阻塞队列（例如
RBlockingQueue）来存放准备执行的任务，当任务进入就绪队列时，消费者可以及时获取并执行这些任务。
优势
- 减少丢消息的可能性：Redisson 使用了 Redis 的持久化机制（例如 AOF 或 RDB），因此即使 Redis 宕机，任务数据也能被持久化，丢失的概率较低。
- 消息消费不重复：Redisson 使用阻塞队列的方式处理任务，每个任务只能被一个消费者处理，避免了消息重复消费的问题。
- 高效执行：Redisson 不需要轮询所有的任务，它通过 SortedSet 的分数来判断哪些任务已经过期，然后只处理那些过期的任务，提高了执行效率。
- 容错性强：由于 Redisson 的延迟队列基于 Redis 的高可用性机制（如 Sentinel 或 Cluster），它具有很高的容错能力。
适用场景：
Redisson 的延迟队列在实现高可靠、低延迟的分布式任务调度中非常有用，尤其适用于需要确保任务可靠执行且不希望丢失的场景。相比 Redis 过期事件监听，Redisson 延迟队列提供了更高的可靠性和灵活性。
总结
- Redis 过期事件监听：通过订阅
__keyevent@<db>__:expired频道来监听键的过期事件。这种方案存在时效性差、丢消息、消息重复消费等问题，适用于一些对时效性要求不高、可以容忍丢失消息的场景。 - Redisson 延迟队列：通过 Redis 的 SortedSet 实现延时任务队列，任务按时间排序并进行扫描。它比 Redis 过期事件监听方案更可靠，能够避免丢失消息、避免重复消费，并具有较高的性能和容错性，适用于需要高可靠性和高效率的延时任务场景。
在面试中，如果被问到为什么选择 Redisson 的延迟队列，你可以指出 Redis 过期事件监听的缺点，并强调 Redisson 延迟队列在高可靠性和消息消费一致性方面的优势。