2019-01-18 16:43:31 2228瀏覽
今天扣丁學(xué)堂Java培訓(xùn)老師給大家介紹一下關(guān)于springboottask實現(xiàn)動態(tài)創(chuàng)建定時任務(wù)的詳細介紹,首先在SpringBoot項目中,通過@EnableScheduling可啟用Spring自帶的定時任務(wù)支持,在通過@Scheduled注解定義定時任務(wù),但是通過注解只能編寫固定時間的定時任務(wù),無法動態(tài)調(diào)整定時間隔,可通過實現(xiàn)SchedulingConfigurer接口實現(xiàn)動態(tài)定時任務(wù)注冊。
package org.cent.demo.scanner.schedule; import lombok.AllArgsConstructor; import lombok.Data; import lombok.extern.slf4j.Slf4j; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.Trigger; 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 java.util.Arrays; import java.util.List; /** * @author: cent * @email: 292462859@qq.com * @date: 2019/1/16. * @description: */ @Configuration @EnableScheduling @Slf4j public class DynamicSchedule implements SchedulingConfigurer { /** * 測試數(shù)據(jù),實際可從數(shù)據(jù)庫獲取 */ private List<Task> tasks = Arrays.asList( new Task(1, "任務(wù)1", "*/30 * * * * *"), new Task(2, "任務(wù)2", "*/30 * * * * *"), new Task(3, "任務(wù)3", "*/30 * * * * *"), new Task(4, "任務(wù)4", "*/30 * * * * *"), new Task(5, "任務(wù)5", "*/30 * * * * *"), new Task(6, "任務(wù)6", "*/30 * * * * *"), new Task(7, "任務(wù)7", "*/30 * * * * *"), new Task(8, "任務(wù)8", "*/30 * * * * *"), new Task(9, "任務(wù)9", "*/30 * * * * *"), new Task(10, "任務(wù)10", "*/30 * * * * *") ); @Override public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) { tasks.forEach(task -> { //任務(wù)執(zhí)行線程 Runnable runnable = () -> log.info("execute task {}", task.getId()); //任務(wù)觸發(fā)器 Trigger trigger = triggerContext -> { //獲取定時觸發(fā)器,這里可以每次從數(shù)據(jù)庫獲取最新記錄,更新觸發(fā)器,實現(xiàn)定時間隔的動態(tài)調(diào)整 CronTrigger cronTrigger = new CronTrigger(task.getCron()); return cronTrigger.nextExecutionTime(triggerContext); }; //注冊任務(wù) scheduledTaskRegistrar.addTriggerTask(runnable, trigger); }); } @Data @AllArgsConstructor static class Task { /** * 主鍵ID */ private int id; /** * 任務(wù)名稱 */ private String name; /** * cron表達式 */ private String cron; } }
【關(guān)注微信公眾號獲取更多學(xué)習(xí)資料】
查看更多關(guān)于“Java開發(fā)資訊”的相關(guān)文章>>