久久r热视频,国产午夜精品一区二区三区视频,亚洲精品自拍偷拍,欧美日韩精品二区

您的位置:首頁技術(shù)文章
文章詳情頁

SpringBoot如何動態(tài)修改Scheduled(系統(tǒng)啟動默認執(zhí)行,動態(tài)修改)

瀏覽:5日期:2023-02-27 08:01:52
SpringBoot 動態(tài)修改Scheduled場景:

可配置的 Scheduled 執(zhí)行時間,正常的 Scheduled 是在項目啟動的時候固定死的,沒辦法根據(jù)調(diào)用后臺代碼自動更新 Scheduled 執(zhí)行時間

例如:

系統(tǒng)啟動 讀取時間 Cron : 0 0 3 * * ? ,通過執(zhí)行后臺方法 可以動態(tài)配置 Cron 時間格式,并且清楚掉原本執(zhí)行任務(wù),執(zhí)行新的設(shè)置定時任務(wù)時間

1、根據(jù) ThreadPoolTaskScheduler 、ScheduledFuture 類 動態(tài)修改定時任務(wù)(ThreadPoolTaskScheduler 這個類 不能使用@Autowired ,直接定義成員變量 )

private ThreadPoolTaskScheduler threadPoolTaskScheduler;private ScheduledFuture<?> future;

2、動態(tài)修改 Scheduled 后臺方法邏輯(object 是 Runnable 實現(xiàn)類 需要執(zhí)行的定時邏輯,放到run 線程方法內(nèi))

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 設(shè)置定時

1、@Order 并實現(xiàn) CommandLineRunner 類 重寫方法 run

@Override public void run(String... args) throws Exception {logger.info('系統(tǒng)啟動 默認設(shè)置對賬任務(wù) 時間');//獲取目前DB 設(shè)置的對賬時間GetBillTimeResp time = systemConfigService.getTime();//獲取Cron時間格式字符串String timeCron = billTimeCronFormat(time.getBillTime());logger.info('時間為:'+timeCron);//Scheduler 設(shè)置每天執(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 * * * *

定時類:

@Componentpublic 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@EnableSchedulingpublic 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('定時任務(wù)邏輯'); }}, new Trigger() { @Override public Date nextExecutionTime(TriggerContext triggerContext) {//任務(wù)觸發(fā),可修改任務(wù)的執(zhí)行周期CronTrigger cronTrigger = new CronTrigger(corn);Date date = cronTrigger.nextExecutionTime(triggerContext);return date; }}); }}

(2)其他類或方法動態(tài)傳參賦值

TestScheduledParams.corn='0/20 * * * * *'

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持好吧啦網(wǎng)。

標(biāo)簽: Spring
主站蜘蛛池模板: 三原县| 南平市| 宣城市| 延庆县| 会理县| 驻马店市| 苗栗市| 黎城县| 应城市| 衡阳市| 晋江市| 绥棱县| 应城市| 宁国市| 扎鲁特旗| 太原市| 鄂伦春自治旗| 茂名市| 海淀区| 怀来县| 延边| 许昌县| 若羌县| 榕江县| 建宁县| 北辰区| 呼伦贝尔市| 库伦旗| 香港 | 南丰县| 突泉县| 海林市| 綦江县| 鄂尔多斯市| 沙洋县| 渝中区| 龙胜| 建瓯市| 沙洋县| 叶城县| 道真|