spring动态配置cron表达式，不需要停服

绝地灬酷狼 2023-07-24 09:21 14阅读 0赞

spring做定时任务调度时有常用的两种方式，分别是基于配置文件的quartz和基于注解的@Scheduler。quartz需要较多的配置文件，个人感觉比较麻烦，@Scheduler注解只需要简单的配置即可，但是这两种发方法不能动态加载cron表达式，每次更改调度规则都需要重启服务。本文介绍一种不需要重启服务的动态加载cron表达式的方法。  
使用SchedulingConfigurer 接口来实现动态加载cron表达式。  
代码示例如下：

@Component
    @EnableScheduling
    public class Test implements SchedulingConfigurer {
    
        @Override
        public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
            //创建一个线程池调度器，默认是单线程执行
            ScheduledExecutorService executorService = Executors.newScheduledThreadPool(100);
            scheduledTaskRegistrar.setScheduler(executorService);
    
            //增加任务
            scheduledTaskRegistrar.addTriggerTask(new Task("test1"),new Trig("cronExpess1"));
            scheduledTaskRegistrar.addTriggerTask(new Task("test2"),new Trig("cronExpess2"));
            scheduledTaskRegistrar.addTriggerTask(new Task("test3"),new Trig("cronExpess2"));
        }
    }
    
    /**
     * 业务类
     */
    class Task implements Runnable{
        String task;
        public Task(String task){
            this.task = task;
        }
    
        //具体业务
        @Override
        public void run() {
            System.out.println(task+":"+LocalDateTime.now()+","+Thread.currentThread().getName());
        }
    }
    
    /**
     * 调度类
     */
    class Trig implements Trigger{
    
        private String cronExpress;
        public Trig(String cronExpress){
            this.cronExpress = cronExpress;
        }
    
        @Override
        public Date nextExecutionTime(TriggerContext triggerContext) {
            String cron = null;
            try {
                //每次调度时加载cron表达式
                cron = new Config().getCrons().get(cronExpress);
            } catch (IOException e) {
                e.printStackTrace();
            }
            CronTrigger cronTrigger = new CronTrigger(cron);
            return cronTrigger.nextExecutionTime(triggerContext);
        }
    }
    
    /**
     * 加载cron表达式
     */
    class Config{
        private static Map<String,String> cronMap;
        private static long preModifyTime;
        private String cronFile = "config/application.properties";
    
        public Map<String,String> getCrons() throws IOException {
            File file = new File(cronFile);
            long nowModifyTime = file.lastModified();
            if (cronMap != null && nowModifyTime == preModifyTime){
                return cronMap;
            }else {
                cronMap = new HashMap<>();
                BufferedReader br = new BufferedReader(new FileReader(file));
                String line = null;
                while ((line = br.readLine()) != null){
                    String[] s = line.split("=");
                    cronMap.put(s[0].trim(),s[1].trim());
                }
                preModifyTime = nowModifyTime;
                return cronMap;
            }
        }
    }

配置文件:

cronExpess1 = 0/5 * * * * *
    cronExpess2 = 0/10 * * * * *

运行结果（为了查看方便，只运行一个任务）：

![format_png][]

[format_png]: /images/20230528/1222182047c34965b83d0fbec8c8daa7.png