SpringBoot如何動態(tài)修改Scheduled(系統(tǒng)啟動默認執(zhí)行,動態(tài)修改)
SpringBoot 動態(tài)修改Scheduled
場景:
可配置的 Scheduled 執(zhí)行時間,正常的 Scheduled 是在項目啟動的時候固定死的,沒辦法根據(jù)調用后臺代碼自動更新 Scheduled 執(zhí)行時間
例如:
系統(tǒng)啟動 讀取時間 Cron : 0 0 3 * * ? ,通過執(zhí)行后臺方法 可以動態(tài)配置 Cron 時間格式,并且清楚掉原本執(zhí)行任務,執(zhí)行新的設置定時任務時間
1、根據(jù) ThreadPoolTaskScheduler 、ScheduledFuture 類 動態(tài)修改定時任務(ThreadPoolTaskScheduler 這個類 不能使用@Autowired ,直接定義成員變量 )
private ThreadPoolTaskScheduler threadPoolTaskScheduler; private ScheduledFuture<?> future;
2、動態(tài)修改 Scheduled 后臺方法邏輯(object 是 Runnable 實現(xiàn)類 需要執(zhí)行的定時邏輯,放到run 線程方法內)
threadPoolTaskScheduler = new ThreadPoolTaskScheduler(); threadPoolTaskScheduler.initialize(); if(future!=null){ future.cancel(true); } future=threadPoolTaskScheduler.schedule(object,new CronTrigger("需要Cron時間格式字符串") );
以上邏輯 ----------------------- 就可以實現(xiàn) 動態(tài) Scheduled 配置
以下邏輯 ----------------------- 配置項目啟動 自動讀取 DB Cron 設置定時
1、@Order 并實現(xiàn) CommandLineRunner 類 重寫方法 run
@Override public void run(String... args) throws Exception { logger.info("系統(tǒng)啟動 默認設置對賬任務 時間"); //獲取目前DB 設置的對賬時間 GetBillTimeResp time = systemConfigService.getTime(); //獲取Cron時間格式字符串 String timeCron = billTimeCronFormat(time.getBillTime()); logger.info("時間為:"+timeCron); //Scheduler 設置每天執(zhí)行。。。 threadPoolTaskScheduler = new ThreadPoolTaskScheduler(); threadPoolTaskScheduler.initialize(); future=threadPoolTaskScheduler.schedule(object,new CronTrigger("DB Cron時間格式字符串")); }
SpringBoot項目@Scheduled讀取動態(tài)參數(shù)
1、基于@Scheduled可配置開發(fā)
application.propertites: read.timer.parmas=0 0/1 * * * *
定時類:
@Component public class ScheduledService { Logger logger= LoggerFactory.getLogger(ScheduledService.class); @Scheduled(cron = "${read.timer.parmas}") public void readConfigTable(){ logger.info("*****.read.timer.parmas"); } }
啟動類:
@SpringBootApplication @EnableScheduling //必須 public class DataApplication { public static void main(String[] args) { SpringApplication.run(DataApplication.class,args); } }
2、基于代碼實現(xiàn)
(1)核心代碼
@Component @EnableScheduling public class TestScheduledParams implements SchedulingConfigurer{ Logger logger= LoggerFactory.getLogger(TestScheduledParams.class); public static String DEFAULT_CORN="0/3 * * * * *"; //##動態(tài)傳參要給默認值。 public static String corn=DEFAULT_CORN; @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.addTriggerTask(new Runnable() { @Override public void run() { // logger.info("定時任務邏輯"); } }, new Trigger() { @Override public Date nextExecutionTime(TriggerContext triggerContext) { //任務觸發(fā),可修改任務的執(zhí)行周期 CronTrigger cronTrigger = new CronTrigger(corn); Date date = cronTrigger.nextExecutionTime(triggerContext); return date; } }); } }
(2)其他類或方法動態(tài)傳參賦值
TestScheduledParams.corn="0/20 * * * * *"
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關文章
去掉 IDEA 中 mybatis配置文件的局部背景顏色(圖解)
這篇文章通過圖文并茂的形式給大家介紹了去掉IntelliJ IDEA 中 mybatis配置文件的局部背景顏色及mybatis 對應的 xml 文件警告的方法圖解,需要的朋友可以參考下2018-09-09Mybatis的SqlRunner執(zhí)行流程實現(xiàn)
MyBatis提供了一個用于操作數(shù)據(jù)庫的SqlRunner工具類,對JDBC做了很好的封裝,本文主要介紹了Mybatis的SqlRunner執(zhí)行流程實現(xiàn),具有一定的參考價值,感興趣的可以了解一下2023-10-10Java Collection和Collections的區(qū)別
本文主要介紹了Java Collection和Collections的區(qū)別,Collection?是表示集合的接口,而?Collections?是對集合進行操作的工具類,下面就來介紹一下具體用法,感興趣的可以了解一下2023-12-12SpringBoot+mybatis+thymeleaf實現(xiàn)登錄功能示例
這篇文章主要介紹了SpringBoot+mybatis+thymeleaf實現(xiàn)登錄功能示例,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-07-07Springboot項目實現(xiàn)將類從@ComponentScan中排除
這篇文章主要介紹了Springboot項目實現(xiàn)將類從@ComponentScan中排除,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-11-11