Spring Boot 2.x基礎教程：使用@Scheduled實現定時任務
我們在編寫Spring Boot應用中經常會遇到這樣的場景，比如：我需要定時地傳送一些簡訊、郵件之類的操作，也可能會定時地檢查和監控一些標誌、引數等。
建立定時任務
在Spring Boot中編寫定時任務是非常簡單的事，下面通過例項介紹如何在Spring Boot中建立定時任務，實現每過5秒輸出一下當前時間。
- 在Spring Boot的主類中加入
@EnableScheduling註解，啟用定時任務的配置
@SpringBootApplication @EnableScheduling public class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); } }
- 建立定時任務實現類
@Component
public class ScheduledTasks {
private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
@Scheduled(fixedRate = 5000)
public void reportCurrentTime() {
log.info("現在時間：" + 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 : 現在時間：14:57:01 2021-07-13 14:57:06.412 INFO 34836 --- [ scheduling-1] com.didispace.chapter71.ScheduledTasks : 現在時間：14:57:06 2021-07-13 14:57:11.413 INFO 34836 --- [ scheduling-1] com.didispace.chapter71.ScheduledTasks : 現在時間：14:57:11 2021-07-13 14:57:16.413 INFO 34836 --- [ scheduling-1] com.didispace.chapter71.ScheduledTasks : 現在時間：14:57:16
@Scheduled詳解
在上面的入門例子中，使用了@Scheduled(fixedRate = 5000) 註解來定義每過5秒執行的任務。對於@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表示式來配置執行規則
- zone：cron表示式解析時使用的時區
- fixedDelay：上一次執行結束到下一次執行開始的間隔時間（單位：ms）
- fixedDelayString：上一次任務執行結束到下一次執行開始的間隔時間，使用java.time.Duration#parse解析
- fixedRate：以固定間隔執行任務，即上一次任務執行開始到下一次執行開始的間隔時間（單位：ms），若在排程任務執行時，上一次任務還未執行完畢，會加入worker佇列，等待上一次執行完成後立即執行下一次任務
- fixedRateString：與fixedRate邏輯一致,只是使用java.time.Duration#parse解析
- initialDelay：首次任務執行的延遲時間
- initialDelayString：首次任務執行的延遲時間,使用java.time.Duration#parse解析
思考與進階
是不是這樣實現定時任務很簡單呢？那麼繼續思考一下這種實現方式是否存在什麼弊端呢？
可能初學者不太容易發現問題，但如果你已經有一定的線上專案經驗的話，問題也是顯而易見的：這種模式實現的定時任務缺少在叢集環境下的協調機制。
什麼意思呢？假設，我們要實現一個定時任務，用來每天網上統計某個資料然後累加到原始資料上。我們開發測試的時候不會有問題，因為都是單程序在執行的。但是，當我們把這樣的定時任務部署到生產環境時，為了更高的可用性，啟動多個例項是必須的。此時，時間一到，所有啟動的例項就會同時開始執行這個任務。那麼問題也就出現了，因為有累加操作，最終我們的結果就會出現問題。
解決這樣問題的方式很多種，比較通用的就是採用分散式鎖的方式，讓同類任務之前的時候以分散式鎖的方式來控制執行順序，比如：使用Redis、Zookeeper等具備分散式鎖功能的中介軟體配合就能很好的幫助我們來協調這類任務在叢集模式下的執行規則。
除此之外，那麼你還有什麼好方法來解決嗎？留言說說你的看法吧！不要走開，本系列教程《Spring Boot 2.x基礎教程》持續更新中哦！。學習過程中如遇困難，建議加入Spring技術交流群，參與交流與討論，更好的學習與進步！
程式碼示例
本文的完整工程可以檢視下面倉庫中的chapter7-1目錄：
- Github：https://github.com/dyc87112/SpringBoot-Learning/
- Gitee：https://gitee.com/didispace/SpringBoot-Learning/
**如果您覺得本文不錯，歡迎Star支援，您的關注是我堅持的動力！
歡迎關注我的公眾號：程式猿DD，分享外面看不到的乾貨與思考！