目录
-
Spring Task 动态修改任务执行计划cron
- 原理
- Demo如下
-
Spring @Scheduled定时任务动态修改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
?| 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 |
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...
以上为个人经验，希望能给大家一个参考，也希望大家多多支持服务器之家。
原文链接：https://blog.csdn.net/JJ_LIJIN/article/details/78644985
如果您对该产品感兴趣，请填写办理（客服微信：xiaoxiongyidong）
发表评论
◎欢迎参与讨论，请在这里发表您的看法、交流您的观点。