java定时器Scheduled，可动态设置定时器执行时间

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
@Component
@EnableScheduling
public class DayTimerTask implements SchedulingConfigurer {

    private final static Logger logger = LoggerFactory.getLogger(DayTimerTask.class);

	//动态设置定时器执行时间
    @Autowired
    private TimerConfigureService timerConfigureService;

    private static String cron;
    private static ScheduledTaskRegistrar scheduledtaskRegistrar;
    private static ScheduledFuture<?> future;

    public DayTimerTask() {
        cron = "0 50 23 * * ?";
    }

    /**
     * 轮询查询日期设置 30分钟
     */
    @Scheduled(cron = "0 0/30 * * * ?")
    public void test(){
    	//查询动态设置的定时器执行时间
        TimerConfigure timerConfigure = timerConfigureService.getOne(
                Wrappers.<TimerConfigure>lambdaQuery()
                        .eq(TimerConfigure::getType, 0));

        if(!cron.equals(timerConfigure.getCron())){
            if(Objects.nonNull(future)){
                future.cancel(true);
            }
            timer(timerConfigure.getCron());
        }else {
            if(Objects.isNull(future)){
                timer(cron);
            }
        }
        //修改每天更新时间
        cron = timerConfigure.getCron();
       
    }

    public void timer(String nextCron){

        TaskScheduler scheduler = scheduledtaskRegistrar.getScheduler();
        Runnable runnable = () -> {
            // 任务逻辑
            SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            logger.info("开始执行定时任务(每天),开始时间:" + sf.format(new Date()));
            //执行具体的业务
            logger.info("定时任务执行完成(每天),更新完成时间:" + sf.format(new Date()));
        };
        Trigger trigger = triggerContext -> {
            // 任务触发，可修改任务的执行周期
            CronTrigger trigger1 = new CronTrigger(nextCron);
            Date nextExec = trigger1.nextExecutionTime(triggerContext);
            return nextExec;
        };
        future = scheduler.schedule(runnable, trigger);
    }

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        scheduledtaskRegistrar = taskRegistrar;
    }
}