我們在編寫Spring Boot應用中經(jīng)常會遇到這樣的場景，比如：我需要定時地發(fā)送一些短信、郵件之類的操作，也可能會定時地檢查和監(jiān)控一些標志、參數(shù)等。

創(chuàng)建定時任務

在Spring Boot中編寫定時任務是非常簡單的事，下面通過實例介紹如何在Spring Boot中創(chuàng)建定時任務，實現(xiàn)每過5秒輸出一下當前時間。

在Spring Boot的主類中加入@EnableScheduling注解，啟用定時任務的配置

@SpringBootApplication@EnableSchedulingpublic class Application {public static void main(String[] args) {SpringApplication.run(Application.class, args);}}

創(chuàng)建定時任務實現(xiàn)類

@Componentpublic class ScheduledTasks { private static final SimpleDateFormat dateFormat = new SimpleDateFormat('HH:mm:ss'); @Scheduled(fixedRate = 5000) public void reportCurrentTime() {log.info('現(xiàn)在時間：' + dateFormat.format(new Date())); }}

運行程序，控制臺中可以看到類似如下輸出，定時任務開始正常運作了。

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)在時間：14:57:012021-07-13 14:57:06.412 INFO 34836 --- [ scheduling-1] com.didispace.chapter71.ScheduledTasks : 現(xiàn)在時間：14:57:062021-07-13 14:57:11.413 INFO 34836 --- [ scheduling-1] com.didispace.chapter71.ScheduledTasks : 現(xiàn)在時間：14:57:112021-07-13 14:57:16.413 INFO 34836 --- [ scheduling-1] com.didispace.chapter71.ScheduledTasks : 現(xiàn)在時間：14:57:16

@Scheduled詳解

在上面的入門例子中，使用了@Scheduled(fixedRate = 5000) 注解來定義每過5秒執(zhí)行的任務。對于@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：通過cron表達式來配置執(zhí)行規(guī)則 zone：cron表達式解析時使用的時區(qū) fixedDelay：上一次執(zhí)行結(jié)束到下一次執(zhí)行開始的間隔時間（單位：ms） fixedDelayString：上一次任務執(zhí)行結(jié)束到下一次執(zhí)行開始的間隔時間，使用java.time.Duration#parse解析 fixedRate：以固定間隔執(zhí)行任務，即上一次任務執(zhí)行開始到下一次執(zhí)行開始的間隔時間（單位：ms），若在調(diào)度任務執(zhí)行時，上一次任務還未執(zhí)行完畢，會加入worker隊列，等待上一次執(zhí)行完成后立即執(zhí)行下一次任務 fixedRateString：與fixedRate邏輯一致,只是使用java.time.Duration#parse解析 initialDelay：首次任務執(zhí)行的延遲時間 initialDelayString：首次任務執(zhí)行的延遲時間,使用java.time.Duration#parse解析思考與進階

是不是這樣實現(xiàn)定時任務很簡單呢？那么繼續(xù)思考一下這種實現(xiàn)方式是否存在什么弊端呢？

可能初學者不太容易發(fā)現(xiàn)問題，但如果你已經(jīng)有一定的線上項目經(jīng)驗的話，問題也是顯而易見的：這種模式實現(xiàn)的定時任務缺少在集群環(huán)境下的協(xié)調(diào)機制。

什么意思呢？假設，我們要實現(xiàn)一個定時任務，用來每天網(wǎng)上統(tǒng)計某個數(shù)據(jù)然后累加到原始數(shù)據(jù)上。我們開發(fā)測試的時候不會有問題，因為都是單進程在運行的。但是，當我們把這樣的定時任務部署到生產(chǎn)環(huán)境時，為了更高的可用性，啟動多個實例是必須的。此時，時間一到，所有啟動的實例就會同時開始執(zhí)行這個任務。那么問題也就出現(xiàn)了，因為有累加操作，最終我們的結(jié)果就會出現(xiàn)問題。

解決這樣問題的方式很多種，比較通用的就是采用分布式鎖的方式，讓同類任務之前的時候以分布式鎖的方式來控制執(zhí)行順序，比如：使用Redis、Zookeeper等具備分布式鎖功能的中間件配合就能很好的幫助我們來協(xié)調(diào)這類任務在集群模式下的執(zhí)行規(guī)則。

代碼示例

本文的完整工程可以查看下面?zhèn)}庫中的chapter7-1目錄：

Github：https://github.com/dyc87112/SpringBoot-Learning/

Gitee：https://gitee.com/didispace/SpringBoot-Learning/

到此這篇關于Spring Boot 2.x基礎教程之使用@Scheduled實現(xiàn)定時任務的方法的文章就介紹到這了,更多相關Spring Boot 2.x定時任務內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持好吧啦網(wǎng)！