Spring Boot 2.x基礎(chǔ)教程：使用@Scheduled實(shí)現(xiàn)定時(shí)任務(wù)
我們?cè)诰帉?xiě)Spring Boot應(yīng)用中經(jīng)常會(huì)遇到這樣的場(chǎng)景，比如：我需要定時(shí)地發(fā)送一些短信、郵件之類(lèi)的操作，也可能會(huì)定時(shí)地檢查和監(jiān)控一些標(biāo)志、參數(shù)等。
創(chuàng)建定時(shí)任務(wù)
在Spring Boot中編寫(xiě)定時(shí)任務(wù)是非常簡(jiǎn)單的事，下面通過(guò)實(shí)例介紹如何在Spring Boot中創(chuàng)建定時(shí)任務(wù)，實(shí)現(xiàn)每過(guò)5秒輸出一下當(dāng)前時(shí)間。
在Spring Boot的主類(lèi)中加入 @EnableScheduling注解，啟用定時(shí)任務(wù)的配置
@SpringBootApplication
@EnableScheduling
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
創(chuàng)建定時(shí)任務(wù)實(shí)現(xiàn)類(lèi)
@Component
public class ScheduledTasks {
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
@Scheduled(fixedRate = 5000)
public void reportCurrentTime() {
log.info("現(xiàn)在時(shí)間：" + dateFormat.format(new Date()));
}
}
運(yùn)行程序，控制臺(tái)中可以看到類(lèi)似如下輸出，定時(shí)任務(wù)開(kāi)始正常運(yùn)作了。
2021-07-13 14:56:56.413 INFO 34836 --- [ main] c.d.chapter71.Chapter71Application : Started Chapter71Application in 1.457 seconds (JVM running for 1.835)
2021-07-13 14:57:01.411 INFO 34836 --- [ scheduling-1] com.didispace.chapter71.ScheduledTasks : 現(xiàn)在時(shí)間：14:57:01
2021-07-13 14:57:06.412 INFO 34836 --- [ scheduling-1] com.didispace.chapter71.ScheduledTasks : 現(xiàn)在時(shí)間：14:57:06
2021-07-13 14:57:11.413 INFO 34836 --- [ scheduling-1] com.didispace.chapter71.ScheduledTasks : 現(xiàn)在時(shí)間：14:57:11
2021-07-13 14:57:16.413 INFO 34836 --- [ scheduling-1] com.didispace.chapter71.ScheduledTasks : 現(xiàn)在時(shí)間：14:57:16
@Scheduled詳解
在上面的入門(mén)例子中，使用了@Scheduled(fixedRate = 5000) 注解來(lái)定義每過(guò)5秒執(zhí)行的任務(wù)。對(duì)于@Scheduled的使用，我們從源碼里看看有哪些配置：
@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Repeatable(Schedules.class)
public @interface Scheduled {
String CRON_DISABLED = ScheduledTaskRegistrar.CRON_DISABLED;
String cron() default "";
String zone() default "";
long fixedDelay() default -1;
String fixedDelayString() default "";
long fixedRate() default -1;
String fixedRateString() default "";
long initialDelay() default -1;
String initialDelayString() default "";
}
這些具體配置信息的含義如下：
cron：通過(guò)cron表達(dá)式來(lái)配置執(zhí)行規(guī)則 zone：cron表達(dá)式解析時(shí)使用的時(shí)區(qū) fixedDelay：上一次執(zhí)行結(jié)束到下一次執(zhí)行開(kāi)始的間隔時(shí)間（單位：ms） fixedDelayString：上一次任務(wù)執(zhí)行結(jié)束到下一次執(zhí)行開(kāi)始的間隔時(shí)間，使用java.time.Duration#parse解析 fixedRate：以固定間隔執(zhí)行任務(wù)，即上一次任務(wù)執(zhí)行開(kāi)始到下一次執(zhí)行開(kāi)始的間隔時(shí)間（單位：ms），若在調(diào)度任務(wù)執(zhí)行時(shí)，上一次任務(wù)還未執(zhí)行完畢，會(huì)加入worker隊(duì)列，等待上一次執(zhí)行完成后立即執(zhí)行下一次任務(wù) fixedRateString：與fixedRate邏輯一致,只是使用java.time.Duration#parse解析 initialDelay：首次任務(wù)執(zhí)行的延遲時(shí)間 initialDelayString：首次任務(wù)執(zhí)行的延遲時(shí)間,使用java.time.Duration#parse解析
思考與進(jìn)階
是不是這樣實(shí)現(xiàn)定時(shí)任務(wù)很簡(jiǎn)單呢？那么繼續(xù)思考一下這種實(shí)現(xiàn)方式是否存在什么弊端呢？
可能初學(xué)者不太容易發(fā)現(xiàn)問(wèn)題，但如果你已經(jīng)有一定的線(xiàn)上項(xiàng)目經(jīng)驗(yàn)的話(huà)，問(wèn)題也是顯而易見(jiàn)的：這種模式實(shí)現(xiàn)的定時(shí)任務(wù)缺少在集群環(huán)境下的協(xié)調(diào)機(jī)制。
什么意思呢？假設(shè)，我們要實(shí)現(xiàn)一個(gè)定時(shí)任務(wù)，用來(lái)每天網(wǎng)上統(tǒng)計(jì)某個(gè)數(shù)據(jù)然后累加到原始數(shù)據(jù)上。我們開(kāi)發(fā)測(cè)試的時(shí)候不會(huì)有問(wèn)題，因?yàn)槎际菃芜M(jìn)程在運(yùn)行的。但是，當(dāng)我們把這樣的定時(shí)任務(wù)部署到生產(chǎn)環(huán)境時(shí)，為了更高的可用性，啟動(dòng)多個(gè)實(shí)例是必須的。此時(shí)，時(shí)間一到，所有啟動(dòng)的實(shí)例就會(huì)同時(shí)開(kāi)始執(zhí)行這個(gè)任務(wù)。那么問(wèn)題也就出現(xiàn)了，因?yàn)橛欣奂硬僮鳎罱K我們的結(jié)果就會(huì)出現(xiàn)問(wèn)題。
解決這樣問(wèn)題的方式很多種，比較通用的就是采用分布式鎖的方式，讓同類(lèi)任務(wù)之前的時(shí)候以分布式鎖的方式來(lái)控制執(zhí)行順序，比如：使用Redis、Zookeeper等具備分布式鎖功能的中間件配合就能很好的幫助我們來(lái)協(xié)調(diào)這類(lèi)任務(wù)在集群模式下的執(zhí)行規(guī)則。
代碼示例
本文的完整工程可以查看下面?zhèn)}庫(kù)中的chapter7-1目錄：
Github：https://github.com/dyc87112/SpringBoot-Learning/tree/master/2.x Gitee：https://gitee.com/didispace/SpringBoot-Learning/tree/master/2.x
如果您覺(jué)得本文不錯(cuò)，歡迎Star支持，您的關(guān)注是我堅(jiān)持的動(dòng)力！
除此之外，那么你還有什么好方法來(lái)解決嗎？留言說(shuō)說(shuō)你的看法吧！不要走開(kāi)，本系列教程《Spring Boot 2.x基礎(chǔ)教程》持續(xù)更新中哦！。
學(xué)習(xí)過(guò)程中如遇困難，建議加入Spring技術(shù)交流群，參與交流與討論，更好的學(xué)習(xí)與進(jìn)步！關(guān)注下方公眾號(hào)，回復(fù)”加群“就可以啦！
往期推薦