1. 定时任务的实现

梦里梦外; 2024-03-31 15:53 66阅读 0赞

### 1. 定时任务的实现 ###

#### 1.1Cron表达式 ####

*  Cron表达式是一个字符串,字符串以5个空格隔开,分为6个域,每一个域代表一个含义
 *  第一位,表示秒,取值0-59
 *  第二位,表示分,取值0-59
 *  第三位,表示小时,取值0-23
 *  第四位,日期天/日,取值1-31
 *  第五位,日期月份,取值1-12
 *  第六位,代表星期,取值0-6
 *  (\*)星号:“每”
 *  (?)问好:这个位置的值不确定
 *  (-)减号:表达一个范围
 *  (,)逗号:表达一个列表值
 *  (/)斜杠:如:x/y,x是开始值,y是步长,比如在第一位(秒),0/15就是,从0秒开始,每15秒,最后就是0,15,30,45,60 另:\*/y,等同于0/y

#### 1.2 定时任务在spring中的应用 ####

*  使用@Scheduled注解实现定时任务
 *  用定时任务实现查询超时未付款订单并自动取消
 *  加分布式锁:防止资源浪费和数据出错

需求:在我们订单成功,但是未付款时,需要将时间过了一天的未付款订单删除掉

@Configuration
    @Slf4j
    public class JobConfiguration {
        
        @Autowired
        OrderService orderService;
        @Autowired
        RedissonClient redissonClient;
    /*
        @Scheduled(fixedRate = 3000)上一次执行完毕时间点之后多长时间再执行
        public void process() throws InterruptedException {
            log.info("start...");
            Thread.sleep(2000);
            log.info("stop");
        }
     */
        @Scheduled(cron = "0 0/5 * * * ?") //每五分钟进行一次此操作
        public void cancelUnpaidOrders(){
        
            //获得分布式锁 需要加分布式锁防止资源浪费和数据出错
            RLock redissonLock = redissonClient.getLock("redissonLock");
            boolean b = redissonLock.tryLock();
            if(b) {
        
                try {
        
                    /*
                    //此方法是将过了一天未付款的查出来
                    List<Order> unpaidOrders = orderService.getUnpaidOrders();
                    unpaidOrders.forEach(order -> {
                        //遍历删除订单 不过这样会循环查表 需要改进
                        orderService.cancel(order.getOrderNo(), true);
                    });
                    */
                   //改进方案 符合条件的一次直接删除
                 List<Order> unpaidOrders = orderService.getUnpaidOrders();
                  List<String> orderNos = unpaidOrders.stream().
                            map(order -> order.getOrderNo()).collect(Collectors.toList());
                    // delete from imooc_mall_order_item where order_no in(no1,no2..);
                    orderService.cancel(orderNos);
                }finally {
        
                    redissonLock.unlock();
                }
            }
        }
    }

@Override
        public List<Order> getUnpaidOrders() {
        
            Date date = new Date();
            //获得当前之间的前一天
            Date endTime= DateUtils.addDays(date,-1);
            //获得当前时间的前一天的前五分钟给 这个五分钟需要与定时任务的时间相匹配
            Date beginTime=DateUtils.addMinutes(endTime,-5);
            //进行查表
            List<Order> list=orderMapper.selectUppaidOrders(beginTime,endTime);
            // select * from imooc_mall_order_item where create_time between beginTime 
            //and endTime and oreder_no=10   10表示未付款
            return list;
        }