Spring Task如何动态修改任务执行计划cron

小编给大家分享一下spring Task如何动态修改任务执行计划cron，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！

Spring Task 动态修改任务执行计划cron

Spring Task 能够在不重启服务的情况下，动态修改批量任务执行时间。

原理

Spring Task目前仅支持TriggerContext上修改下次执行时间（批量任务执行后回调SchedulinGConfigurer.configureTasks，让用户可以重新设置Trigger，从而动态修改下次执行时间）），这种方法的弊端就是“执行时间不能实时生效”。

为此，看了下task文档，感觉若要实现实时生效功能，必须代码里手工启动/停止Spring task任务。

Demo如下

首先，xml里不需要配置springTask相关的executor和scheduler。其次，在代码里自定义scheduler和taskReGIStrar（SpringTask启动的类）。最后，开个线程，模拟动态修改cron表达式的接口。

输出如下：（35min没有执行原task）

INFO 27-11 14:34:10,476 - Initializing ExecutorService
INFO 27-11 14:34:10,484 - nextExecutionTime: 0 35 14 * * ?
修改cron为: 0 36 14 * * ?
INFO 27-11 14:34:20,487 - Initializing ExecutorService
INFO 27-11 14:34:20,488 - nextExecutionTime: 0 36 14 * * ?
INFO 27-11 14:36:00,001 - dynamicCronTask is running...
INFO 27-11 14:36:00,001 - nextExecutionTime: 0 36 14 * * ?

Spring @Scheduled定时任务动态修改cron参数

• 在定时任务类上增加@EnableScheduling注解，并实现SchedulingConfigurer接口。（注意低版本无效）

• 设置一个静态变量cron，用于存放任务执行周期参数。

• 另辟一线程，用于模拟实际业务中外部原因修改了任务执行周期。

• 设置任务触发器，触发任务执行，其中就可以修改任务的执行周期。

Class ： SpringDynamicCornTask

package com.xindatai.ibs.lime.dycSchedul;import java.util.Date;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.context.annotation.Lazy;import org.springframework.scheduling.Trigger;import org.springframework.scheduling.TriggerContext;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.SchedulingConfigurer;import org.springframework.scheduling.config.ScheduledTaskRegistrar;import org.springframework.scheduling.support.CronTrigger;import org.springframework.stereotype.Component;@Lazy(false)@Component@EnableSchedulingpublic class SpringDynamicCornTask implements SchedulingConfigurer {    private static final Logger logger = LoggerFactory.getLogger(SpringDynamicCornTask.class);    private static String cron;    private SpringDynamicCornTask() {        cron = "0/5 * * * * ?";        // 开启新线程模拟外部更改了任务执行周期        new Thread(new Runnable() {            @Override            public void run() {                try {                    Thread.sleep(15 * 1000);                } catch (InterruptedException e) {                    e.printStackTrace();                }                cron = "0/10 * * * * ?";                System.out.println("cron change to : " + cron);            }        }).start();    }    @Override    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {        taskRegistrar.addTriggerTask(new Runnable() {            @Override            public void run() {                // 任务逻辑                logger.info("dynamicCronTask is running...");            }        }, new Trigger() {            @Override            public Date nextExecutionTime(TriggerContext triggerContext) {                // 任务触发，可修改任务的执行周期                CronTrigger trigger = new CronTrigger(cron);                Date nextExecutionTime = trigger.nextExecutionTime(triggerContext);                return nextExecutionTime;            }        });    } }

Console ：

[INFO 2017-06-01 12:26:25 SpringDynamicCornTask] - dynamicCronTask is running...
[INFO 2017-06-01 12:26:30 SpringDynamicCornTask] - dynamicCronTask is running...
[INFO 2017-06-01 12:26:35 SpringDynamicCornTask] - dynamicCronTask is running...
cron change to : 0/10 * * * * ?
[INFO 2017-06-01 12:26:40 SpringDynamicCornTask] - dynamicCronTask is running...
[INFO 2017-06-01 12:26:50 SpringDynamicCornTask] - dynamicCronTask is running...
[INFO 2017-06-01 12:27:00 SpringDynamicCornTask] - dynamicCronTask is running...

以上是“Spring Task如何动态修改任务执行计划cron”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注编程网精选频道！