實現(xiàn)定時任務(wù)的六種策略
這篇文章，我們聊聊實現(xiàn)定時任務(wù)的六種策略。
圖片
1 自定義單線程
圖片
上圖中，我們啟動一個線程，該線程無限循環(huán)執(zhí)行，每隔20毫秒執(zhí)行業(yè)務(wù)代碼。
這種方式非常簡單易用，在很多中間件中得到廣泛應(yīng)用。
2 JDK ScheduledExecutorService
ScheduledExecutorService 是 Java 標(biāo)準(zhǔn)庫提供的一個用于調(diào)度定時任務(wù)的接口。它提供了一種相對簡單的方式來執(zhí)行定時任務(wù)，不需要引入額外的庫。
圖片
在上述例子中：
- 創(chuàng)建了一個ScheduledExecutorService 實例，它使用了一個線程池，其中包含一個線程用于執(zhí)行定時任務(wù)。
- 定義了一個簡單的Runnable任務(wù)，輸出當(dāng)前時間。
- 使用scheduleAtFixedRate方法安排任務(wù)，指定了任務(wù)的啟動延遲時間和執(zhí)行間隔時間。
- 主線程等待一段時間，然后關(guān)閉ScheduledExecutorService，確保定時任務(wù)不再執(zhí)行。
這是一個基本的使用例子，你可以根據(jù)需求調(diào)整延遲時間、執(zhí)行間隔、線程池大小等參數(shù)。
ScheduleExecutorService 因其簡單易用且性能優(yōu)異，在各大開源中間件項目（比如 RocketMQ、MetaQ、Canal 等）中被廣泛的使用。
3 Spring Task
在Spring框架中，你可以使用@Scheduled注解來創(chuàng)建定時任務(wù)。以下是Spring定時任務(wù)的基本用法：
- 配置類： 創(chuàng)建一個配置類，通常使用 @EnableScheduling 注解啟用 Spring 的定時任務(wù)功能。
圖片
- 定時任務(wù)方法： 在你的服務(wù)類或組件類中創(chuàng)建一個方法，并使用 @Scheduled 注解來指定定時任務(wù)的觸發(fā)條件。
圖片
在上述例子中，@Scheduled 注解允許你指定定時任務(wù)的執(zhí)行規(guī)則，可以是固定頻率（fixedRate）、固定延遲（fixedDelay）、或者使用cron表達(dá)式。
4 Quartz
Quartz是一款 Java 開源任務(wù)調(diào)度框架。
圖片
下面我們展示如何使用：
1、添加依賴
圖片
2、Job（任務(wù)：你要做什么事）
圖片
3、Trigger（觸發(fā)器：什么時候去做）
4、scheduler（任務(wù)調(diào)度：你什么時候需要做什么事）將 job 與 Trigger 進(jìn)行整合。
下面是一個例子：
圖片
這里需要強(qiáng)調(diào)的是，Quartz 支持集群模式，持久化方式是 JDBC ，需要創(chuàng)建如下表。
圖片
Quartz 集群模式對于業(yè)務(wù)數(shù)據(jù)庫有侵入性，需要考慮業(yè)務(wù)場景慎重使用。
5 elastic-job
ElasticJob 定位為輕量級無中心化解決方案，使用 jar 的形式提供分布式任務(wù)的協(xié)調(diào)服務(wù)。
圖片
應(yīng)用內(nèi)部定義任務(wù)類，實現(xiàn) SimpleJob 接口，編寫自己任務(wù)的實際業(yè)務(wù)流程即可。
圖片
舉例：應(yīng)用A有五個任務(wù)需要執(zhí)行，分別是A，B，C，D，E。任務(wù)E需要分成四個子任務(wù)，應(yīng)用部署在兩臺機(jī)器上。
圖片
應(yīng)用A在啟動后， 5個任務(wù)通過 Zookeeper 協(xié)調(diào)后被分配到兩臺機(jī)器上，通過Quartz Scheduler 分開執(zhí)行不同的任務(wù)。
ElasticJob 從本質(zhì)上來講 ，底層任務(wù)調(diào)度還是通過 Quartz ，相比Redis分布式鎖 或者 Quartz 分布式部署 ，它的優(yōu)勢在于可以依賴 Zookeeper 這個大殺器 ，將任務(wù)通過負(fù)載均衡算法分配給應(yīng)用內(nèi)的 Quartz Scheduler容器。
6 xxl-job
XXL-JOB 是一個使用最廣泛的分布式任務(wù)調(diào)度平臺。
業(yè)務(wù)系統(tǒng)和調(diào)度平臺分開部署，我們在調(diào)度平臺上配置應(yīng)用以及其定時任務(wù)，當(dāng)任務(wù)需要執(zhí)行時，調(diào)度平臺會觸發(fā)業(yè)務(wù)系統(tǒng)的任務(wù)，業(yè)務(wù)系統(tǒng)執(zhí)行完任務(wù)之后，反饋給調(diào)度平臺任務(wù)執(zhí)行的結(jié)果。
接下來，我們使用 xxl-job 開發(fā)第一個任務(wù) “Hello World”。
1、新建任務(wù)：
登錄調(diào)度中心，點(diǎn)擊下圖所示“新建任務(wù)”按鈕，新建示例任務(wù)。然后，參考下面截圖中任務(wù)的參數(shù)配置，點(diǎn)擊保存。
圖片
圖片
2、應(yīng)用任務(wù)開發(fā)
圖片
3、觸發(fā)執(zhí)行
請點(diǎn)擊任務(wù)右側(cè) “執(zhí)行” 按鈕，可手動觸發(fā)一次任務(wù)執(zhí)行（通常情況下，通過配置Cron表達(dá)式進(jìn)行任務(wù)調(diào)度觸發(fā)）。
4、查看日志
請點(diǎn)擊任務(wù)右側(cè) “日志” 按鈕，可前往任務(wù)日志界面查看任務(wù)日志。在任務(wù)日志界面中，可查看該任務(wù)的歷史調(diào)度記錄以及每一次調(diào)度的任務(wù)調(diào)度信息、執(zhí)行參數(shù)和執(zhí)行信息。
運(yùn)行中的任務(wù)點(diǎn)擊右側(cè)的“執(zhí)行日志”按鈕，可進(jìn)入日志控制臺查看實時執(zhí)行日志。
圖片
7 寫到最后
本文整理了實現(xiàn)定時任務(wù)的六種策略，我們需要根據(jù)實際場景選擇合適的策略。
同時，我們也需要考慮：
- 是否需要任務(wù)應(yīng)用集群部署；
- 集群部署下假如出現(xiàn)并發(fā)執(zhí)行，業(yè)務(wù)是否會出現(xiàn)異常；
- 如何規(guī)避并發(fā)執(zhí)行導(dǎo)致的業(yè)務(wù)異常。
