Spring Task 動態(tài)修改任務執(zhí)行計劃cron方式
Spring Task 動態(tài)修改任務執(zhí)行計劃cron
Spring Task 能夠在不重啟服務的情況下,動態(tài)修改批量任務執(zhí)行時間。
原理
Spring Task目前僅支持TriggerContext上修改下次執(zhí)行時間(批量任務執(zhí)行后回調SchedulingConfigurer.configureTasks,讓用戶可以重新設置Trigger,從而動態(tài)修改下次執(zhí)行時間)),這種方法的弊端就是“執(zhí)行時間不能實時生效”。
為此,看了下task文檔,感覺若要實現實時生效功能,必須代碼里手工啟動/停止Spring task任務。
Demo如下
首先,xml里不需要配置springTask相關的executor和scheduler。其次,在代碼里自定義scheduler和taskRegistrar(SpringTask啟動的類)。最后,開個線程,模擬動態(tài)修改cron表達式的接口。
輸出如下:(35min沒有執(zhí)行原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定時任務動態(tài)修改cron參數
- 在定時任務類上增加@EnableScheduling注解,并實現SchedulingConfigurer接口。(注意低版本無效)
- 設置一個靜態(tài)變量cron,用于存放任務執(zhí)行周期參數。
- 另辟一線程,用于模擬實際業(yè)務中外部原因修改了任務執(zhí)行周期。
- 設置任務觸發(fā)器,觸發(fā)任務執(zhí)行,其中就可以修改任務的執(zhí)行周期。
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動態(tài)周期定時任務 在不停應用的情況下更改任務執(zhí)行周期
*
* @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 * * * * ?";
// 開啟新線程模擬外部更改了任務執(zhí)行周期
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) {
// 任務觸發(fā),可修改任務的執(zhí)行周期
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...
以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
jackson使用@JsonSerialize格式化BigDecimal解決.00不顯示問題
這篇文章主要介紹了jackson使用@JsonSerialize格式化BigDecimal解決.00不顯示問題,本文直接給出實現代碼,需要的朋友可以參考下2015-02-02
MyBatis的mapper.xml文件中入參和返回值的實現
這篇文章主要介紹了MyBatis的mapper.xml文件中入參和返回值的實現方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2023-01-01
關于@ResponseBody 默認輸出的誤區(qū)的解答
這篇文章主要介紹了關于@ResponseBody 默認輸出的誤區(qū)的解答,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-04-04
詳解SpringMVC中設置靜態(tài)資源不被攔截的問題
這篇文章主要介紹了詳解SpringMVC中設置靜態(tài)資源不被攔截的問題,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-02-02

