网站建设书籍在线阅读,synology做网站,凡客官网登录,深圳 营销型网站建设#x1f3f7;️个人主页#xff1a;牵着猫散步的鼠鼠 #x1f3f7;️系列专栏#xff1a;Java全栈-专栏 #x1f3f7;️个人学习笔记#xff0c;若有缺误#xff0c;欢迎评论区指正 目录
1.前言
2.Redis如何实现延迟任务#xff1f;
3.代码实现
3.1. 过期键通知事… ️个人主页牵着猫散步的鼠鼠 ️系列专栏Java全栈-专栏 ️个人学习笔记若有缺误欢迎评论区指正 目录
1.前言
2.Redis如何实现延迟任务
3.代码实现
3.1. 过期键通知事件实现
3.2. 使用ZSet实现延迟任务
3.3 使用Redisson的延时队列(常用)
4.Redis实现延迟任务优缺点分析
5. 总结 1.前言
延迟任务Delayed Task是指在未来的某个时间点执行相应的任务。也就是说延迟任务是一种计划任务它被安排在特定的时间后执行而不是立即执行。
延迟任务的常见使用场景有以下几个
定时发送通知或消息 发送定时短信、邮件或应用内消息如注册确认、订单状态更新、促销活动通知等。定时推送新闻、天气预报、股票价格等实时信息。异步处理和后台任务 将耗时的操作安排为延迟任务避免阻塞主线程或用户界面提高系统的响应性能。执行批量数据处理如日志分析、数据报表生成等。缓存管理和过期处理 定时清理过期的缓存数据释放存储空间。更新缓存中的数据保持数据的时效性和准确性。计划任务和定时调度 在特定时间执行系统维护任务如数据库备份、系统更新等。定时启动或关闭服务以节约资源或满足业务需求。订单和支付处理 在用户下单后的一段时间内如果用户未支付则自动取消订单。定时检查订单的支付状态并更新相应的订单信息。重试和失败恢复机制 当某个操作失败时可以在延迟一段时间后自动重试以提高成功率。实现分布式锁的超时释放避免死锁情况。提醒和日程管理 设置日程提醒如会议、生日、纪念日等。定时提醒用户完成任务或进行某项活动。定时数据采集和上报 定期从传感器、设备或外部系统中采集数据。定时上报应用的使用情况、统计数据或用户行为分析。
2.Redis如何实现延迟任务
Redis 本身并没有直接提供延迟任务的功能但可以通过一些策略和手段在 Redis 中手动实现延迟任务。
使用 Redis 实现延迟任务的主要手段有以下几个
1. 使用过期键的事件通知执行延时任务开启过期键通知当 Redis 中键值过期时触发时间在事件中实现延迟代码但因为 Redis 的 Key 过期时不会被及时删除所以这个过期事件也不保证可以立即触发所以此方式很少用来实现延迟任务因为极其不稳定。 2. 使用 ZSet 执行延时任务在 ZSet 中插入延迟执行时间和任务 ID如下命令所示
ZADD delay_tasks timestamp task_id然后启动一个后台线程或者定时任务定期通过 ZRANGEBYSCORE 命令从有序集合中获取已到达执行时间的任务即分数小于或等于当前时间的任务进行执行即可实现延时任务。
3. 使用 Redisson 执行延迟任务在 Redisson 框架中提供了一个 RDelayedQueue 用于实现延迟队列使用简单方便推荐使用。
3.代码实现
3.1. 过期键通知事件实现
Redis 提供了键空间通知功能当某个键发生变化过期时可以发送通知。你可以结合 EXPIRE 过期命令和键空间通知来实现延迟任务。
当为某个键设置过期时间时一旦该键过期Redis 会发送一个通知。你可以订阅这个通知并在接收到通知时执行任务。但这种方法可能不够精确且依赖于 Redis 的内部机制。
它的实现步骤是
设置开启 Redis 过期键通知事件可以通过执行“CONFIG SET notify-keyspace-events KEA”命令来动态开启键空间通知功能而无需重启 Redis 服务器。设置过期键可以通过命令“SET mykey myvalue EX 3”设置某个 key 3 秒后过期3s 后执行。编写一个监听程序来订阅 Redis 的键空间通知。这可以通过使用 Redis 的发布/订阅功能来实现具体实现代码如下以 Jedis 框架使用为例
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub; public class RedisKeyspaceNotifier { public static void main(String[] args) { // 创建Jedis实例 Jedis jedis new Jedis(localhost, 6379); // 配置键空间通知通常这一步在Redis配置文件中完成但也可以在运行时配置 jedis.configSet(notify-keyspace-events, KEA); // 订阅键空间通知 jedis.subscribe(new KeyspaceNotificationSubscriber(), __keyevent0__:expired); } static class KeyspaceNotificationSubscriber extends JedisPubSub { Override public void onMessage(String channel, String message) { System.out.println(Received message from channel: channel , message: message); // 在这里处理接收到的键空间通知 // 例如如果message是一个需要处理的任务ID你可以在这里触发相应的任务处理逻辑 } Override public void onSubscribe(String channel, int subscribedChannels) { System.out.println(Subscribed to channel: channel); } Override public void onUnsubscribe(String channel, int subscribedChannels) { System.out.println(Unsubscribed from channel: channel); } }
}但因为 Redis 的 Key 过期时不会被及时删除Redis 采用的是惰性删除和定期删除所以这个过期事件也不保证可以立即触发所以此方式很少用来实现延迟任务因为极其不稳定。
3.2. 使用ZSet实现延迟任务
可以将任务及其执行时间作为成员和分数存储在 ZSET 中然后使用一个后台任务如定时任务或守护进程定期检查 ZSET查找分数即执行时间小于或等于当前时间的成员并执行相应的任务。执行后从 ZSET 中删除该成员具体实现代码如下
import redis.clients.jedis.Jedis; import java.util.Set; public class RedisDelayedTaskDemo { private static final String ZSET_KEY delayed_tasks; private static final String REDIS_HOST localhost; private static final int REDIS_PORT 6379; public static void main(String[] args) { Jedis jedis new Jedis(REDIS_HOST, REDIS_PORT); // 添加延迟任务 addDelayedTask(jedis, task1, System.currentTimeMillis() / 1000 5); // 5秒后执行 addDelayedTask(jedis, task2, System.currentTimeMillis() / 1000 10); // 10秒后执行 // 模拟定时任务检查器 new Thread(() - { while (true) { try { // 检查并执行到期的任务 checkAndExecuteTasks(jedis); Thread.sleep(1000); // 每秒检查一次 } catch (InterruptedException e) { e.printStackTrace(); } } }).start(); } private static void addDelayedTask(Jedis jedis, String task, long executeTime) { jedis.zadd(ZSET_KEY, executeTime, task); System.out.println(Added task: task with execution time: executeTime); } private static void checkAndExecuteTasks(Jedis jedis) { long currentTime System.currentTimeMillis() / 1000; SetString tasks jedis.zrangeByScore(ZSET_KEY, 0, currentTime); for (String task : tasks) { jedis.zrem(ZSET_KEY, task); // 从有序集合中移除任务 executeTask(task); // 执行任务 } } private static void executeTask(String task) { System.out.println(Executing task: task); // 在这里添加实际的任务执行逻辑 }
}在这个示例中我们首先使用 addDelayedTask 方法向 Redis 的有序集合中添加任务并设置它们的执行时间。然后我们启动一个线程来模拟定时任务检查器它会每秒检查一次是否有任务到期并执行到期的任务。
3.3 使用Redisson的延时队列(常用)
在 Redisson 框架中提供了一个 RDelayedQueue 用于实现延迟队列使用简单方便推荐使用它的具体实现如下
import org.redisson.Redisson;
import org.redisson.api.RDelayedQueue;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;import java.util.concurrent.TimeUnit;public class RDelayedQueueDemo {public static void main(String[] args) throws InterruptedException {// 创建 Redisson 客户端Config config new Config();config.useSingleServer().setAddress(redis://127.0.0.1:6379);RedissonClient redisson Redisson.create(config);// 获取延迟队列RDelayedQueueString delayedQueue redisson.getDelayedQueue(delayedQueue);// 添加延迟任务delayedQueue.offer(task1, 5, TimeUnit.SECONDS);// 监听并处理延迟任务Thread listenerThread new Thread(() - {while (true) {try {// 通过 take 方法等待并获取到期的任务String task delayedQueue.take();System.out.println(Handle task: task);} catch (InterruptedException e) {break;}}});listenerThread.start();}
}在上述示例中我们首先创建了一个 Redisson 客户端通过配置文件指定了使用单节点 Redis 服务器。然后我们获取一个延迟队列 RDelayedQueue并添加一个延迟任务延迟时间为 5 秒接着我们通过线程监听并处理延迟队列中的任务。
4.Redis实现延迟任务优缺点分析
优点
轻量级与高性能Redis 是一个内存中的数据结构存储系统因此读写速度非常快。将任务信息存储在 Redis 中可以迅速地进行存取操作。简单易用Redis 的 API 简洁明了易于集成到现有的应用系统中。
缺点
精度有限Redis 的延迟任务依赖于系统的定时检查机制而不是精确的定时器。这意味着任务的执行可能会有一定的延迟特别是在系统负载较高或检查间隔较长的情况下。功能有限与专业的任务调度系统相比Redis 提供的延迟任务功能可能相对简单。对于复杂的任务调度需求如任务依赖、任务优先级等可能需要额外的逻辑来实现。稳定性较差使用 Redis 实现延迟任务没有重试机制和 ACK 确认机制所以稳定性比较差。单点故障风险如果没有正确配置 Redis 集群或主从复制那么单个 Redis 实例的故障可能导致整个延迟任务系统的瘫痪。
5. 总结
以上我们总结了使用redis实现延时任务的几种方案在一些简单的场景可以直接使用redisson提供的延时队列来实现延时任务非常容易上手。在复杂大型的场景下还是推荐使用专业的任务调度系统如xxl-jobQuartz等。
