在spring boot項目中，可以通過@EnableScheduling注解和@Scheduled注解實現(xiàn)定時任務(wù)，也可以通過SchedulingConfigurer接口來實現(xiàn)定時任務(wù)。但是這兩種方式不能動態(tài)添加、刪除、啟動、停止任務(wù)。

要實現(xiàn)動態(tài)增刪啟停定時任務(wù)功能，比較廣泛的做法是集成Quartz框架。但是本人的開發(fā)原則是：在滿足項目需求的情況下，盡量少的依賴其它框架，避免項目過于臃腫和復(fù)雜。

查看spring-context這個jar包中org.springframework.scheduling.ScheduledTaskRegistrar這個類的源代碼，發(fā)現(xiàn)可以通過改造這個類就能實現(xiàn)動態(tài)增刪啟停定時任務(wù)功能。

添加執(zhí)行定時任務(wù)的線程池配置類

@Configuration??
public?class?SchedulingConfig?{??
????@Bean??
????public?TaskScheduler?taskScheduler()?{??
????????ThreadPoolTaskScheduler?taskScheduler?=?new?ThreadPoolTaskScheduler();??
????????//?定時任務(wù)執(zhí)行線程池核心線程數(shù)??
????????taskScheduler.setPoolSize(4);??
????????taskScheduler.setRemoveOnCancelPolicy(true);??
????????taskScheduler.setThreadNamePrefix("TaskSchedulerThreadPool-");??
????????return?taskScheduler;??
????}??
}??
添加ScheduledFuture的包裝類。ScheduledFuture是ScheduledExecutorService定時任務(wù)線程池的執(zhí)行結(jié)果。

public?final?class?ScheduledTask?{??
??
????volatile?ScheduledFuture?future;??
??
????/**??
?????*?取消定時任務(wù)??
?????*/??
????public?void?cancel()?{??
????????ScheduledFuture?future?=?this.future;??
????????if?(future?!=?null)?{??
????????????future.cancel(true);??
????????}??
????}??
}??
添加Runnable接口實現(xiàn)類，被定時任務(wù)線程池調(diào)用，用來執(zhí)行指定bean里面的方法。

public?class?SchedulingRunnable?implements?Runnable?{??
??
????private?static?final?Logger?logger?=?LoggerFactory.getLogger(SchedulingRunnable.class);??
??
????private?String?beanName;??
??
????private?String?methodName;??
??
????private?String?params;??
??
????public?SchedulingRunnable(String?beanName,?String?methodName)?{??
????????this(beanName,?methodName,?null);??
????}??
??
????public?SchedulingRunnable(String?beanName,?String?methodName,?String?params)?{??
????????this.beanName?=?beanName;??
????????this.methodName?=?methodName;??
????????this.params?=?params;??
????}??
??
????@Override??
????public?void?run()?{??
????????logger.info("定時任務(wù)開始執(zhí)行?- bean：{}，方法：{}，參數(shù)：{}",?beanName,?methodName,?params);??
????????long?startTime?=?System.currentTimeMillis();??
??
????????try?{??
????????????Object?target?=?SpringContextUtils.getBean(beanName);??
??
????????????Method?method?=?null;??
????????????if?(StringUtils.isNotEmpty(params))?{??
????????????????method?=?target.getClass().getDeclaredMethod(methodName,?String.class);??
????????????}?else?{??
????????????????method?=?target.getClass().getDeclaredMethod(methodName);??
????????????}??
??
????????????ReflectionUtils.makeAccessible(method);??
????????????if?(StringUtils.isNotEmpty(params))?{??
????????????????method.invoke(target,?params);??
????????????}?else?{??
????????????????method.invoke(target);??
????????????}??
????????}?catch?(Exception?ex)?{??
????????????logger.error(String.format("定時任務(wù)執(zhí)行異常?- bean：%s，方法：%s，參數(shù)：%s ",?beanName,?methodName,?params),?ex);??
????????}??
??
????????long?times?=?System.currentTimeMillis()?-?startTime;??
????????logger.info("定時任務(wù)執(zhí)行結(jié)束?- bean：{}，方法：{}，參數(shù)：{}，耗時：{}?毫秒",?beanName,?methodName,?params,?times);??
????}??
??
????@Override??
????public?boolean?equals(Object?o)?{??
????????if?(this?==?o)?return?true;??
????????if?(o?==?null?||?getClass()?!=?o.getClass())?return?false;??
????????SchedulingRunnable?that?=?(SchedulingRunnable)?o;??
????????if?(params?==?null)?{??
????????????return?beanName.equals(that.beanName)?