這篇文章，我們聊聊實現定時任務的六種策略。

1. 自定義單線程

上圖中，我們啟動一個線程，該線程無限循環執行，每隔20毫秒執行業務代碼。

這種方式非常簡單易用，在很多中間件中得到廣泛應用。

2. JDK ScheduledExecutorService

ScheduledExecutorService 是 Java 標準庫提供的一個用于調度定時任務的接口。它提供了一種相對簡單的方式來執行定時任務，不需要引入額外的庫。

在上述例子中：

• 創建了一個ScheduledExecutorService 實例，它使用了一個線程池，其中包含一個線程用于執行定時任務。
• 定義了一個簡單的Runnable任務，輸出當前時間。
• 使用scheduleAtFixedRate方法安排任務，指定了任務的啟動延遲時間和執行間隔時間。
• 主線程等待一段時間，然后關閉ScheduledExecutorService，確保定時任務不再執行。

這是一個基本的使用例子，你可以根據需求調整延遲時間、執行間隔、線程池大小等參數。

ScheduleExecutorService 因其簡單易用且性能優異，在各大開源中間件項目（比如 RocketMQ、MetaQ、Canal 等）中被廣泛的使用。

3. Spring Task

在Spring框架中，你可以使用@Scheduled注解來創建定時任務。以下是Spring定時任務的基本用法：

(1) 配置類： 創建一個配置類，通常使用 @EnableScheduling 注解啟用 Spring 的定時任務功能。

(2) 定時任務方法： 在你的服務類或組件類中創建一個方法，并使用 @Scheduled 注解來指定定時任務的觸發條件。

在上述例子中，@Scheduled 注解允許你指定定時任務的執行規則，可以是固定頻率（fixedRate）、固定延遲（fixedDelay）、或者使用cron表達式。

4. Quartz

Quartz是一款 Java 開源任務調度框架。

下面我們展示如何使用：

(1) 添加依賴

(2) Job（任務：你要做什么事）

(3) Trigger（觸發器：什么時候去做）

(4) scheduler（任務調度：你什么時候需要做什么事）將 job 與 Trigger 進行整合。

下面是一個例子：

這里需要強調的是，Quartz 支持集群模式，持久化方式是 JDBC ，需要創建如下表。

Quartz 集群模式對于業務數據庫有侵入性，需要考慮業務場景慎重使用。

5. elastic-job

ElasticJob 定位為輕量級無中心化解決方案，使用 jar 的形式提供分布式任務的協調服務。

應用內部定義任務類，實現 SimpleJob 接口，編寫自己任務的實際業務流程即可。

舉例：應用A有五個任務需要執行，分別是A，B，C，D，E。任務E需要分成四個子任務，應用部署在兩臺機器上。

應用A在啟動后， 5個任務通過 Zookeeper 協調后被分配到兩臺機器上，通過Quartz Scheduler 分開執行不同的任務。

ElasticJob 從本質上來講 ，底層任務調度還是通過 Quartz ，相比Redis分布式鎖 或者 Quartz 分布式部署 ，它的優勢在于可以依賴 Zookeeper 這個大殺器 ，將任務通過負載均衡算法分配給應用內的 Quartz Scheduler容器。

6. xxl-job

XXL-JOB 是一個使用最廣泛的分布式任務調度平臺。

業務系統和調度平臺分開部署，我們在調度平臺上配置應用以及其定時任務，當任務需要執行時，調度平臺會觸發業務系統的任務，業務系統執行完任務之后，反饋給調度平臺任務執行的結果。

接下來，我們使用 xxl-job 開發第一個任務 “Hello World”。

(1) 新建任務：

登錄調度中心，點擊下圖所示“新建任務”按鈕，新建示例任務。然后，參考下面截圖中任務的參數配置，點擊保存。

(2) 應用任務開發

(3) 觸發執行

請點擊任務右側 “執行” 按鈕，可手動觸發一次任務執行（通常情況下，通過配置Cron表達式進行任務調度觸發）。

(4) 查看日志

請點擊任務右側 “日志” 按鈕，可前往任務日志界面查看任務日志。在任務日志界面中，可查看該任務的歷史調度記錄以及每一次調度的任務調度信息、執行參數和執行信息。

運行中的任務點擊右側的“執行日志”按鈕，可進入日志控制臺查看實時執行日志。

7. 寫到最后

本文整理了實現定時任務的六種策略，我們需要根據實際場景選擇合適的策略。

同時，我們也需要考慮：

• 是否需要任務應用集群部署；
• 集群部署下假如出現并發執行，業務是否會出現異常；
• 如何規避并發執行導致的業務異常。