SpringBoot定时任务动态修改cron表达式改变执行周期

一、场景引入

前不久做过一个根据下载指令定时下载文件到服务器的需求。轮询下载的周期需要根据下载任务量的大小动态修改，下载任务密集的时候就周期缩小，下载任务少量时就扩大周期时间。java本身和第三方开源框架Spring共有三种执行定时任务的方式：

Java自带的java.util.Timer类：这个类允许你调度一个java.util.TimerTask任务。(这种方式比较古老，自从第三方开源框架出现以来，基本不使用java自带的定时任务组件)
开源的第三方框架： Quartz 或者 elastic-job ，但是这个比较复杂和重量级，适用于分布式场景下的定时任务，可以根据需要多实例部署定时任务。
使用Spring提供的注解： @Schedule 。如果定时任务执行时间较短，并且比较单一，可以使用这个注解。

以上三种执行定时任务的方式都只能固定执行周期，一旦定时任务跑起来之后就不可能修改周期，只能修改周期后重新启动，现在需要动态修改执行周期，故这三种方式都不能使用。

二、解决方式

既然不能用通过传统的方式，那就要想到强大的第三方开源框架带来的便利，Spring从3.0版本开始在框架中加入了一个新的定时任务线程池配置类，即： org.springframework.scheduling.concurrent包中有一个

1ThreadPoolTaskScheduler类，它继承了抽象类 ExecutorConfigurationSupport 并实现了 AsyncListenableTaskExecutor， SchedulingTaskExecutor， TaskScheduler三个接口 ，其中实现了
2
3TaskScheduler中的一个方法：ScheduledFuture<?> schedule(Runnable task, Trigger trigger)源码：
4
5@Overridepublic ScheduledFuture<?> schedule(Runnable task, Trigger trigger) {   ScheduledExecutorService executor = getScheduledExecutor();   try {      ErrorHandler errorHandler =            (this.errorHandler != null ? this.errorHandler : TaskUtils.getDefaultErrorHandler(true));      return new ReschedulingRunnable(task, trigger, executor, errorHandler).schedule();   }   catch (RejectedExecutionException ex) {      throw new TaskRejectedException("Executor [" + executor + "] did not accept task: " + task, ex);   }}通过源码即可发现只要将对应的定时任务的线程以及包含cron表达式的 Trigger 参数传入即可按指定的周期启动定时任务。通过源码也可以发现它的线程池大小默认是1：
6
7// ScheduledThreadPoolExecutor.setRemoveOnCancelPolicy(boolean) only available on JDK 7+private static final boolean setRemoveOnCancelPolicyAvailable =      ClassUtils.hasMethod(ScheduledThreadPoolExecutor.class, "setRemoveOnCancelPolicy", boolean.class);private volatile int poolSize = 1;private volatile boolean removeOnCancelPolicy = false;private volatile ErrorHandler errorHandler;private volatile ScheduledExecutorService scheduledExecutor; 也就是说定时任务默认是单线程串行执行，如果同时需要执行多个定时任务的话，需要对线程池的大小进行配置，我配置的是线程大小是20，如下：
8
9@Bean(autowire = Autowire.BY_NAME, value = "threadPoolConfigBean")public ThreadPoolTaskScheduler taskScheduler() {    ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();    scheduler.setPoolSize(20);    return scheduler;}然后编写定时任务接口并实现：
10
11public interface Task {    /**     * 开始任务     */    String startTask();    /**     * 停止任务     */    void stopCron();    /**     * 重新触发任务     *     * @param cron     * @return     */    boolean triggerAgain(String cron);}
12
13实现类：
14
15public class CacheInfoDownloadTask implements Task {    Environment env = SpringUtils.getBean(Environment.class);    // spring上下文取bean    private ThreadPoolTaskScheduler threadPoolTaskScheduler            = (ThreadPoolTaskScheduler) SpringUtils.getBean("threadPoolConfigBean");    private CacheInfoDownloadBll cacheInfoDownloadBll            = SpringUtils.getBean(CacheInfoDownloadBll.class);    private ScheduledFuture<?> future;    private static CacheInfoDownloadTask instance;    // 通过单例向外提供唯一实例    public static synchronized CacheInfoDownloadTask getInstance() {        if (null == instance) {            instance = new CacheInfoDownloadTask();        }        return instance;    }    @Override    public String startTask() {        String taskCorn = env.getProperty("cacheInfoDownload.schedule");        future = threadPoolTaskScheduler.schedule(new CacheInfoDownloadJob(), new CronTrigger(taskCorn));        log.info("缓存信息拉取开始...执行周期:{}", taskCorn);        return "ok";    }    @Override    public void stopCron() {        if (future != null) {            future.cancel(true);        }        log.info("缓存信息拉取任务停止成功...");    }    @Override    public boolean triggerAgain(String cron) {        this.stopCron();        future = this.threadPoolTaskScheduler.schedule(new CacheInfoDownloadJob(), new CronTrigger(cron));        log.info("缓存信息拉取任务更改cron表达式后再次触发成功...执行周期:{}", cron);        return true;    }    private class CacheInfoDownloadJob implements Runnable {        @Override        public void run() {            String schoolId = env.getProperty("school.id");            boolean result = cacheInfoDownloadBll.getCacheInfo(schoolId);            if (result)                log.info("缓存信息拉取并下载任务执行成功...");            else                log.error("缓存信息拉取后存储失败...");        }    }}定时任务编写成功后，使用静态工厂模式在Spring任务启动同时启动定时任务，在修改定时任务的执行周期时，只需把调用triggerAgain(String cron)方法即可修改：
16
17@Component@Order(value = 1)public class TaskTriggerOrderConfig implements CommandLineRunner {    @Override    public void run(String... strings) throws Exception {        TaskFactory.getInstance(DOWNLOAD_TASK).startTask();    }}

SpringBoot定时任务动态修改cron表达式改变执行周期

评论区

相关推荐