Spring Task 动态修改cron Spring Task 动态修改任务执行计划cron方式
叠影 人气:0Spring 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; /** * Spring动态周期定时任务 在不停应用的情况下更改任务执行周期 * * @author Liang * * 2017年6月1日 */ @Lazy(false) @Component @EnableScheduling public 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...
以上为个人经验,希望能给大家一个参考,也希望大家多多支持。
加载全部内容