赞
踩
在这个电子商务流行年代,24小时随时随地网购已经成为我们习以为常的生活习惯。看到不错的商品,我们会立即下单,完全不受时间、空间的限制,剁手,然后在家坐等收快递,那种感觉。。。。
细心的你是否发现,我们好像很少去主动点击‘’确认收货”,毕竟拿到了货,我总要先体验几天,谁知道它会不会坏,但时间一拖就忘了操作确认收货。而担保交易,如果买家不确认收货,交易订单无法完结,那商家是收不到货款的。有什么解决办法?
上面示图是淘宝APP的订单详情页,左上方的自动确认时间起到了关键作用。也就是说,到了目标时间系统会自动触发代替买家执行确认收货。对上述的任务,我们给一个专业的名字,那就是延迟任务。那么这里你可能会问,这个延迟任务和定时任务的区别究竟在哪里呢?
1、定时任务有固定的触发时间(比如每天的凌晨2点执行),延迟任务的执行时间不固定,严格依赖于业务事件的触发时间(比如:自动确认收货是在卖家发货那个时刻往后延15天)
2、定时任务有执行周期,而延迟任务在某事件触发后一段时间内执行,一般是一次性的,没有执行周期
3、定时任务一般执行的是批处理操作多个任务,而延迟任务一般是单个任务
延迟任务的一些业务场景:
1、当你下了一笔订单后,一直没有付款,一般超过30分钟后,系统会自动关闭订单并退还库存
2、购买一件商品,如果你不喜欢会申请退款,当卖家超过3天未处理,系统会自动退款成功
3、生成订单60秒后,自动给用户发短信
延迟任务不仅仅适用于电商业务,对于预先设定目标执行时间,当时间到了需要自动触发执行的业务场景都可以参考该设计方案。下面我们具体讲一讲延迟任务常见的技术实现,后面工作中你可能会用的上。。。
一、JDK 延迟队列
通过JDK提供的DelayQueue 类来实现。DelayQueue 是一个无界阻塞队列,支持延时获取元素,队列中的元素必须实现 Delayed 接口,并重写 getDelay(TimeUnit) 和 compareTo(Delayed) 方法,代码示例如下:
public class DelayQueueTest {
public static void main(String[] args) {
DelayQueue<DelayTask> dq = new DelayQueue<DelayTask>();
//生产者生产一个2秒的延时任务
new Thread(new ProducerDelay(dq, 2000)).start();
//开启消费者轮询
new Thread(new ConsumerDelay(dq)).start();
}
}
class ProducerDelay implements Runnable {
DelayQueue<DelayTask> delayQueue;
int delaySecond;
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
public ProducerDelay(DelayQueue<DelayTask> delayQueue, int delaySecond) {
this.delayQueue = delayQueue;
this.delaySecond = delaySecond;
}
@Override
public void run() {
for (int i = 1; i < 6; i++) {
delayQueue.add(new DelayTask(delaySecond, i + ""));
System.out.println(sdf.format(new Date()) + " Thread " + Thread.currentThread() + " 添加了一个延迟任务,id=" + i);
try {
Thread.sleep(500);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class ConsumerDelay implements Runnable {
DelayQueue<DelayTask> delayQueue;
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
public ConsumerDelay(DelayQueue<DelayTask> delayQueue) {
this.delayQueue = delayQueue;
}
@Override
public void run() {
while (true) {
DelayTask delayTask = null;
try {
delayTask = delayQueue.take();
} catch (Exception e) {
e.printSta
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。