Java 定時任務

還沒真正的遇到使用定時任務的場景，不管怎么說先學起來

1. 定時任務

很多情況下任務並非需要立即執行，而是需要往后或定期執行，這不可能人工去操作，所以定時任務就出現了。項目中肯定會用到使用定時任務的情況，筆者就需要定時去拉取埋點數據

使用定時任務的情況：

• 每周末凌晨備份數據
• 觸發條件 5 分鍾后發送郵件通知
• 30 分鍾未支付取消訂單
• 每 1 小時去拉取數據
• ......

2. Thread實現

筆試中首次遇到定時任務急急忙忙想出來的方法

2.1 使用

public class ThreadSchedule { public static void main(String[] args) { // 5 秒后執行任務 int interval = 1000 * 5; // 新線程執行 new Thread(() -> { try { Thread.sleep(interval); System.out.println("執行定時任務"); } catch (InterruptedException e) { e.printStackTrace(); } }).start(); } } 

2.2 分析

• 定時不准確，因依賴底層硬件，Windows誤差為10微妙
• System.currentTimeMillis() 依賴系統硬件，還會受網絡時間同步修改
• System.nanoTime() 依賴 JVM 的運行納秒數，並不受同步影響，適用於計算准確的時間差
• 但計算當前日期還是要使用 currentTimeMillis 的格林威治時間，而 nanoTime 計算 JVM 運行時間不准確

3. java.util.Timer

Timer 負責執行計划功能，會啟動一個后台線程，而 TimerTask 負責任務邏輯

3.1 使用

public class TimeSchedule { public static void main(String[] args) { // 啟動一個守護線程 Timer timer = new Timer(); // 定時任務 TimerTask timerTask = new TimerTask() { @Override public void run() { System.out.println("執行定時任務"); } }; long delay = 0; // 延遲執行 long period = 1000 * 5; // 間隔 timer.scheduleAtFixedRate(timerTask, 1, period); // timer.cancel(); 可取消 } } 

3.2 分析

// new Timer() 最終的構造函數會啟動一個線程 public Timer(String name) { thread.setName(name); thread.start(); } // 這個線程里面封裝了一個 Queue 優先級隊列，該線程會去隊列里不停執行里面的任務 class TimerThread extends Thread { private TaskQueue queue; TimerThread(TaskQueue queue) { this.queue = queue; } } // 這個隊列里面存放了各種 TimerTask 定時的任務邏輯 class TaskQueue { private TimerTask[] queue = new TimerTask[128]; } 

• 只有一個單線程執行，所以是串行執行
• 某個任務執行時間較長會阻塞后面預定執行的任務，所以時間並不准確
• 線程報錯后續的定時任務直接停止

4. ScheduledExecutorService

java.util.concurrent中的工具類，是一個多線程的定時器

4.1 使用

public class ExecutorSchedule { public static void main(String[] args) { // 定時任務 Runnable runnable = new Runnable() { @Override public void run() { System.out.println("執行定時任務"); } }; // 線程池執行 long delay = 0; // 延遲執行 long period = 1000 * 5; // 間隔 ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor(); service.scheduleAtFixedRate(runnable, delay, period, TimeUnit.MILLISECONDS); } 

筆者最常用的一個定時操作了，之前還寫過定時的探測任務

5. Spring的定時任務

需要開啟定時功能@EnableScheduling

@Component public class SpringSchedule { // cron 表達式，每秒執行一次 @Scheduled(cron = "*/1 * * * * ?") public void springSchedule(){ System.out.println("執行定時任務"); } } 

底層是 ScheduledThreadPoolExecutor 線程池，和上面的 ScheduledExecutorService 是同根同源

6. XXL-JOB

xxl-job 是個人維護的分布式任務調度框架（國人寫的，有詳細的中文文檔），分為 調度中心 和 執行器。執行器就是定時任務，而調度中心則負責管理調用這些定時任務，調度中心也可以存儲定時任務通過腳本形式（Java 是 Grovvy）免編譯地實時下發到各服務中執行。最重要的是有 UI 界面，用戶友好的體驗

6.1 建立數據庫

xxl-job 的存儲是基於數據庫的，相對比 quartz 可保存在內存和數據庫有一點性能影響。首先第一步就是要建庫，在 xxl-job 官網有 SQL 語句 tables_xxl_job.sql，直接執行即可建庫建表

6.2 部署 xxl-job-admin 調度中心

從 Git 上拉取最新的代碼，然后編譯根模塊，填好 admin 模塊的數據庫地址等，即可啟動這個調度中心（支持 Docker 部署，更加方便）

6.3 創建定時任務

在需要定時任務的服務中 引入依賴、添加配置、創建定時任務

6.3.1 依賴

<!-- xxl-job-core --> <dependency> <groupId>com.xuxueli</groupId> <artifactId>xxl-job-core</artifactId> <version>${project.parent.version}</version> </dependency> 

6.3.2 基本配置

# xxl-job admin address xxl.job.admin.addresses=http://xxx.xxx.xxx:8080/xxl-job-admin  # xxl-job executor appname xxl.job.executor.appname=xxl-job-executor-demo 

6.3.3 定時任務

@Component public class MyJob { @XxlJob("MyJob") public void MyJob() throws Exception { // 執行器日志記錄 XxlJobHelper.log("myjob is execute"); // 定時任務邏輯 System.out.println("myjob is executing"); // default success } } 

6.4 執行定時任務

進入調度中心新建一個任務，然后執行定時任務即可（使用的是 RPC 遠程過程調用）

6.5 遇到的問題

默認執行器是自動注冊到調度中心的，但是時常進去的地址有問題而導致執行失敗，所以要手動錄入執行器的地址

6.6 分析

作為輕量級的分布式定時任務，有 UI 界面簡單方便使用，而且對代碼沒什么侵入性，已經能滿足大部分項目的需求了，筆者如果要用定時任務也會首選 xxl-job