项目产品中，大家都会有"定时任务"和"定时超时"的需求，初始阶段，我们基本都是用少数的一些timer，即使是任务量越来越大的时候，我们就难免维护着大量的timer，或者进行了大量低效的扫描。
定时任务使用场景：当订单一直处于未支付状态时，如何及时的关闭订单(已经使用)
如何定期检查处于退款状态的订单是否已经退款成功(后期重构使用)
设计方案：
咱们公司现阶段就是使用的这套方法：
1.新增一个job，会job_pool中插入一条数据，记录了业务方消费方。也会在bucket插入一条记录，记录执行的时间戳
2.搬运线程会去bucket中查找哪些执行时间戳的RunTimeMillis比现在的时间小，将这些记录全部删除；同时会解析出每个任务的Topic是什么，然后将这些任务PUSH到TOPIC对应的列表queue中
3每个topic的list都会有一个监听线程去批量获取list中的待消费数据，获取到的数据全部扔给这个topic的消费线程池
4.消费线程池执行会去job_pool查找数据结构，返回给回调结构，执行回调方法。
图片
待优化的内容：
一般来说还有什么其他方法实现这类需求呢？
“轮询扫描法”
1.用一个Map<uid, last_packet_time>来记录每一个uid最近一次请求时间last_packet_time
2.当某个用户uid有请求包来到，实时更新这个Map
3.启动一个timer，当Map中不为空时，轮询扫描这个Map，看每个uid的last_packet_time是否超过30s，如果超过则进行超时处理
“多timer触发法”
1.用一个Map<uid, last_packet_time>来记录每一个uid最近一次请求时间last_packet_time
2.当某个用户uid有请求包来到，实时更新这个Map，并同时对这个uid请求包启动一个timer，30s之后触发
3.每个uid请求包对应的timer触发后，看Map中，查看这个uid的last_packet_time是否超过30s，如果超过则进行超时处理
方案一：只启动一个timer，但需要轮询，效率较低
方案二：不需要轮询，但每个请求包要启动一个timer，比较耗资源
ZSet（有序集合）数据结构来实现
import redis.clients.jedis.Jedis;import redis.clients.jedis.Tuple;import java.util.Set;public class OrderCancellationSystem { public static void main(String[] args) { Jedis jedis = new Jedis("localhost"); // 连接到本地Redis服务器 // 模拟添加订单 addOrder(jedis, "Order1"); addOrder(jedis, "Order2"); // 定时任务，每分钟检查订单并自动取消 while (true) { cancelLongUnpaidOrders(jedis); try { Thread.sleep(60000); // 等待一分钟再次检查 } catch (InterruptedException e) { e.printStackTrace(); } } } public static void addOrder(Jedis jedis, String orderId) { long currentTime = System.currentTimeMillis(); jedis.zadd("orders", currentTime, orderId); } public static void cancelOrder(String orderId) { // 执行取消订单操作，例如更新订单状态 System.out.println("Cancelling order: " + orderId); } public static void cancelLongUnpaidOrders(Jedis jedis) { long expirationTime = System.currentTimeMillis() - 3600 * 1000; // 60分钟前的时间戳 Set<Tuple> longUnpaidOrders = jedis.zrangeByScoreWithScores("orders", "-inf", String.valueOf(expirationTime)); for (Tuple order : longUnpaidOrders) { String orderId = order.getElement(); cancelOrder(orderId); jedis.zrem("orders", orderId); // 从ZSet中删除已取消的订单 } }}
本文链接：http://www.28at.com/showinfo-26-17398-0.html数十万定时任务，如何高效触发定时和超时
声明：本网页内容旨在传播知识，若有侵权等问题请及时与本网联系，我们将在第一时间删除处理。邮件：2376512515@qq.com
上一篇： 了解 Go 中原子操作的重要性与使用方法
Copyright © 2016-2023 天津谷骐科技有限公司 版权所有 sitemap.xml
违法及侵权请联系：2376512515@qq.com 津ICP备18001702号
津公网安备 12010102000574号