作者：yizhiwazi 鏈接：https://www.jianshu.com/p/d160f2536de7

序言：創(chuàng)建定時(shí)任務(wù)非常簡(jiǎn)單，主要有兩種創(chuàng)建方式：
一、基于注解(@Scheduled)
二、基于接口（SchedulingConfigurer）. 前者相信大家都很熟悉，但是實(shí)際使用中我們往往想從數(shù)據(jù)庫(kù)中讀取指定時(shí)間來(lái)動(dòng)態(tài)執(zhí)行定時(shí)任務(wù)，這時(shí)候基于接口的定時(shí)任務(wù)就大派用場(chǎng)了。

一、靜態(tài)定時(shí)任務(wù)（基于注解）

基于注解來(lái)創(chuàng)建定時(shí)任務(wù)非常簡(jiǎn)單，只需幾行代碼便可完成。

@Scheduled 除了支持靈活的參數(shù)表達(dá)式cron之外，還支持簡(jiǎn)單的延時(shí)操作，例如 fixedDelay ，fixedRate 填寫(xiě)相應(yīng)的毫秒數(shù)即可。

@Configuration?//1.主要用于標(biāo)記配置類(lèi)，兼?zhèn)銫omponent的效果。 @EnableScheduling?//?2.開(kāi)啟定時(shí)任務(wù) public?class?SimpleScheduleConfig?{//3.添加定時(shí)任務(wù)@Scheduled(cron?=?"0/5?*?*?*?*??")private?void?configureTasks()?{System.err.println("執(zhí)行定時(shí)任務(wù)1:?"?+?LocalDateTime.now());} }

Cron表達(dá)式參數(shù)分別表示：
秒（0~59） 例如0/5表示每5秒
分（0~59）
時(shí)（0~23）
月的某天（0~31） 需計(jì)算
月（0~11）
周幾（ 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT）

啟動(dòng)應(yīng)用，可以看到控制臺(tái)的信息如下：

誠(chéng)然，使用Scheduled 確實(shí)很方便，但缺點(diǎn)是當(dāng)我們調(diào)整了執(zhí)行周期的時(shí)候，需要重啟應(yīng)用才能生效，這多少有些不方便。為了達(dá)到實(shí)時(shí)生效的效果，可以使用接口來(lái)完成定時(shí)任務(wù)。

二、動(dòng)態(tài)定時(shí)任務(wù)（基于接口）

為了演示效果，這里選用 Mysql數(shù)據(jù)庫(kù) 和 Mybatis 來(lái)查詢(xún)和調(diào)整定時(shí)任務(wù)的執(zhí)行周期，然后觀察定時(shí)任務(wù)的執(zhí)行情況。

1.引入依賴(lài)

????<!--依賴(lài)管理?--><dependencies><dependency><!--添加Web依賴(lài)?--><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><!--添加Mybatis依賴(lài)?--><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>1.3.1</version></dependency><dependency><!--添加MySql依賴(lài)?--><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope></dependency><dependency><!--添加Test依賴(lài)?--><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency></dependencies>

2.添加數(shù)據(jù)庫(kù)記錄

在Navicat 連接本地?cái)?shù)據(jù)庫(kù)，隨便打開(kāi)查詢(xún)窗口，然后執(zhí)行腳本內(nèi)容，如下：

DROP?DATABASE?IF?EXISTS?`socks`; CREATE?DATABASE?`socks`; USE?`SOCKS`; DROP?TABLE?IF?EXISTS?`cron`; CREATE?TABLE?`cron`??(`cron_id`?varchar(30),`cron`?varchar(30)? ); INSERT?INTO?`cron`?VALUES?('1',?'0/5?*?*?*?*??');

image

然后在項(xiàng)目中的application.yml 添加數(shù)據(jù)源：

#application.yml?配置如下： spring:datasource:url:?jdbc:mysql://localhost:3306/socks?useSSL=falseusername:?rootpassword:?root

3.創(chuàng)建定時(shí)器

數(shù)據(jù)庫(kù)準(zhǔn)備好數(shù)據(jù)之后，我們編寫(xiě)定時(shí)任務(wù)，注意這里添加的是TriggerTask，目的是循環(huán)讀取我們?cè)跀?shù)據(jù)庫(kù)設(shè)置好的執(zhí)行周期，以及執(zhí)行相關(guān)定時(shí)任務(wù)的內(nèi)容。具體代碼如下：

@Configuration @EnableScheduling public?class?CompleteScheduleConfig?implements?SchedulingConfigurer?{@Mapperpublic?interface?CronMapper?{@Select("select?cron?from?cron?limit?1")String?getCron();}@Autowired@SuppressWarnings("all")CronMapper?cronMapper;/***?執(zhí)行定時(shí)任務(wù).*/@Overridepublic?void?configureTasks(ScheduledTaskRegistrar?taskRegistrar)?{taskRegistrar.addTriggerTask(//1.添加任務(wù)內(nèi)容(Runnable)()?->?System.out.println("執(zhí)行定時(shí)任務(wù)2:?"?+?LocalDateTime.now().toLocalTime()),//2.設(shè)置執(zhí)行周期(Trigger)triggerContext?->?{//2.1?從數(shù)據(jù)庫(kù)獲取執(zhí)行周期String?cron?=?cronMapper.getCron();//2.2?合法性校驗(yàn).if?(StringUtils.isEmpty(cron))?{//?Omitted?Code?..}//2.3?返回執(zhí)行周期(Date)return?new?CronTrigger(cron).nextExecutionTime(triggerContext);});}}

4. 動(dòng)態(tài)修改執(zhí)行周期

啟動(dòng)應(yīng)用后，查看控制臺(tái)，打印時(shí)間是我們預(yù)期的每5秒一次：

image

然后打開(kāi)Navicat ，將執(zhí)行周期修改為每1秒執(zhí)行一次，如圖：

image

查看控制臺(tái)，發(fā)現(xiàn)執(zhí)行周期已經(jīng)改變，并且不需要我們重啟應(yīng)用，十分方便。如圖：

image

添加我私人微信

置頂或星標(biāo)公眾號(hào)，第一時(shí)間接收小海熱文

方法如下

總結(jié)

以上是生活随笔為你收集整理的一篇文章搞定，SpringBoot 创建定时任务的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。