Spring 定時任務(wù)簡介

Cloud Native

定時任務(wù)是業(yè)務(wù)應(yīng)用開發(fā)中非常普遍存在的場景（如：每分鐘掃描超時支付的訂單，每小時清理一次數(shù)據(jù)庫歷史數(shù)據(jù)，每天統(tǒng)計前一天的數(shù)據(jù)并生成報表等等），解決方案很多，Spring 框架提供了一種通過注解來配置定時任務(wù)的解決方案，接入非常的簡單，僅需如下兩步：

1. 在啟動類上添加注解@EnableScheduling

@SpringBootApplication
@EnableScheduling  // 添加定時任務(wù)啟動注解
public class SpringSchedulerApplication {
    public static void main(String[] args) {
        SpringApplication.run(SpringSchedulerApplication.class, args);
    }
}

2. 開發(fā)定時任務(wù) Bean 并配置相應(yīng)的定時注解@Scheduled

@Component
public class SpringScheduledProcessor {


  /**
     * 通過Cron表達(dá)式指定頻率或指定時間
     */
    @Scheduled(cron = "0/5 * * * * ?")
    public void doSomethingByCron() {
        System.out.println("do something");
    }
    
  /**
     * 固定執(zhí)行間隔時間
     */
    @Scheduled(fixedDelay = 2000)
    public void doSomethingByFixedDelay() {
        System.out.println("do something");
    }


    /**
     * 固定執(zhí)行觸發(fā)頻率
     */
    @Scheduled(fixedRate = 2000)
    public void doSomethingByFixedRate() {
        System.out.println("do something");
    } 
}

Spring 定時任務(wù)原理

Cloud Native

運(yùn)行原理

Spring 定時任務(wù)核心邏輯主要在 spring-context 中的 scheduling 包中，其主要結(jié)構(gòu)包括：

定時任務(wù)解析：通過 ScheduledTasksBeanDefinitionParser 對 XML 定義任務(wù)配置解析；也可通過 ScheduledAnnotationBeanPostProcessor對@Scheduled 注解進(jìn)行任務(wù)解析（常見模式）。

定時任務(wù)注冊登記：上述解析獲得的 Task 任務(wù)配置會被注冊登記至 ScheduledTaskRegistrar 中以備運(yùn)行使用。

任務(wù)定時運(yùn)行：完成所有任務(wù)注冊登記后，會通過 TaskScheduler 正式地定時運(yùn)行相關(guān)任務(wù)，底層通過 JDK 的 ScheduledExecutorService 運(yùn)行任務(wù)。

業(yè)務(wù)邏輯會將被包裝在 ScheduledMethodRunnable 類中，其中包含了待執(zhí)行的目標(biāo)業(yè)務(wù)對象 Bean 和業(yè)務(wù)方法，該 Runnable 對象在運(yùn)行時會被提交至 ScheduledExecutorService 調(diào)度線程池完成任務(wù)的定時運(yùn)行。

從上圖可以看到真正要運(yùn)行的業(yè)務(wù)邏輯 ScheduledMethodRunnable 會被 ReschedulingRunnable、DelegatingErrorHandlingRunnable 做了代理擴(kuò)展，這兩層代理擴(kuò)展具有如下意義：

DelegatingErrorHandlingRunnable：為業(yè)務(wù)方法運(yùn)行異常進(jìn)行包裝處理，提供了自定義異常處理機(jī)制、解決 JDK 原生定時任務(wù)執(zhí)行異常后任務(wù)失效問題。

ReschedulingRunnable：提供了擴(kuò)展的定時模式支持，可支持基于 Trigger 接口自定義實(shí)現(xiàn)獲取下次觸發(fā)時間定時調(diào)度，默認(rèn)提供的 Cron 定時通過此方式進(jìn)行擴(kuò)展實(shí)現(xiàn)。

定時模式

Spring 定時任務(wù) Task 類的模式主要可分為兩類：IntervalTask 和 TriggerTask。前者表示固定頻率間隔執(zhí)行，后者則采用 Trigger 觸發(fā)器模式實(shí)現(xiàn)定時調(diào)度，Cron 表達(dá)式配置為該模式實(shí)現(xiàn)。

FixedDelay：按固定延遲頻率執(zhí)行，任務(wù)下一次觸發(fā)時間=上一次執(zhí)行結(jié)束時間+Delay 延遲時間。

FixedRate：按固定頻率觸發(fā)執(zhí)行，任務(wù)下一次觸發(fā)時間=上一次觸發(fā)時間+Delay 延遲時間。如果上一次執(zhí)行方法不結(jié)束會阻塞下一次任務(wù)執(zhí)行。

Cron 表達(dá)式：按 Cron 表達(dá)式計算下一次觸發(fā)時間，任務(wù)下一次觸發(fā)時間=cron(上一次執(zhí)行結(jié)束時間)。

進(jìn)階擴(kuò)展

線程池運(yùn)行

默認(rèn)配置下底層運(yùn)行的線程池為單線程，單線程的運(yùn)行模型在任務(wù)量較多且觸發(fā)頻率較高的情況下，一旦某個任務(wù)發(fā)生阻塞會導(dǎo)致所有后續(xù)定時任務(wù)運(yùn)行阻斷，這對業(yè)務(wù)運(yùn)行帶來嚴(yán)重隱患。常見可采用如下方式：

配置定時執(zhí)行線程池：常見基于配置 Spring Boot 配置（spring.task.scheduling.pool.size=線程數(shù)），線程數(shù)大小取決于任務(wù)數(shù)及調(diào)度頻率合理配置。

配置異步任務(wù)：在 spring context 中的 scheduling 模塊下提供了@EnableAsync 和@Async，可用于開啟任務(wù)異步執(zhí)行，實(shí)現(xiàn)定時調(diào)度線程池非阻塞運(yùn)行。該模式下存在一些不足之處：異常處理需要走異步調(diào)用的 AsyncUncaughtExceptionHandler 異常處理接口實(shí)現(xiàn)，同步/異步定時任務(wù)異常處理機(jī)制不統(tǒng)一，另外異步模式增加了業(yè)務(wù)應(yīng)用的線程開銷。

@Scheduled(fixedDelay = 2000)
@Async
public void test() {
    System.out.println(DateUtil.now()+ " test.");
}

異常統(tǒng)一處理

定時任務(wù)運(yùn)行可設(shè)置統(tǒng)一異常處理，基于 ErrorHandler 接口開發(fā)對應(yīng)異常處理實(shí)現(xiàn)類。對應(yīng)的異常實(shí)現(xiàn)處理類需要注入到核心的 ThreadPoolTaskScheduler 中，用戶可以通過自定義 TaskSchedulerCustomizer 方式來實(shí)現(xiàn) ErrorHandler 自定義異常處理 Bean 注入至 ThreadPoolTaskScheduler 中。

@Component
public class DemoTaskSchedulerCustomizer implements TaskSchedulerCustomizer {
    @Override
    public void customize(ThreadPoolTaskScheduler taskScheduler) {
        taskScheduler.setErrorHandler(new DemoErrorHandler());
    }


    private class DemoErrorHandler implements ErrorHandler {
        @Override
        public void handleError(Throwable throwable) {
            System.out.println("異常統(tǒng)一處理.");
        }
    }
}

原生 Spring 定時任務(wù)在企業(yè)中遇到的問題

Cloud Native

任務(wù)重復(fù)執(zhí)行

Spring 定時任務(wù)，只要有注解就會執(zhí)行，在分布式場景下，所有機(jī)器代碼一致，會導(dǎo)致同一個任務(wù)在多臺機(jī)器上重復(fù)執(zhí)行。一般的解決方案是搶鎖觸發(fā)，分布式鎖實(shí)現(xiàn)形式可采用 DB、ZK、Redis 等方式。

示例代碼如下：

@Component
@EnableScheduling
public class MyTask {
    /**
     * 每分鐘的第30秒跑一次
     */
    @Scheduled(cron = "30 * * * * ?")
    public void task1() throws Exception {
        String lockName = "task1";
        if (tryLock(lockName)) {
            System.out.println("hello cron");
            releaseLock(lockName);
        } else {
            return;
        }
    }
    private boolean tryLock(String lockName) {
        //TODO
        return true;
    }
    
    private void releaseLock(String lockName) {
        //TODO
    }
}

如上圖所示，當(dāng)任務(wù)觸發(fā)時 3 個 server 會對任務(wù)搶鎖，僅獲得任務(wù)鎖的 server 才能執(zhí)行對應(yīng)任務(wù)業(yè)務(wù)邏輯。當(dāng)前的這個設(shè)計，仔細(xì)一點(diǎn)的同學(xué)可以發(fā)現(xiàn)，其實(shí)還是有可能導(dǎo)致任務(wù)重復(fù)執(zhí)行的。比如任務(wù)執(zhí)行的非?？?，A 這臺機(jī)器搶到鎖，執(zhí)行完任務(wù)后很快就釋放鎖了。B 這臺機(jī)器后搶鎖，還是會搶到鎖，再執(zhí)行一遍任務(wù)。

無管控?zé)o運(yùn)維

原生 Spring 定時任務(wù)沒有控制臺，無法動態(tài)的新增和修改定時任務(wù)，如果要修改定時任務(wù)的配置（比如每分鐘跑一次改成每小時跑一次），必須修改代碼重新發(fā)布應(yīng)用。同時原生Spring定時任務(wù)也沒有運(yùn)維操作，不支持運(yùn)行一次任務(wù)，任務(wù)失敗了也不支持重跑任務(wù)。

如果要自研的可視化控制臺來實(shí)現(xiàn)整套任務(wù)可視化管控體系，需要一定的前后端研發(fā)成本和服務(wù)部署成本投入。對于需要自建的用戶而言，可參考以下需求功能進(jìn)行自有平臺建設(shè)：

任務(wù)的可視化動態(tài)配置

任務(wù)執(zhí)行運(yùn)行詳細(xì)信息的可視化查看

任務(wù)執(zhí)行日志、執(zhí)行調(diào)用鏈、調(diào)度觸發(fā)的可視化查詢分析

業(yè)務(wù)應(yīng)用間任務(wù)信息配置權(quán)限隔離

無業(yè)務(wù)失敗通知能力

對于完整企業(yè)級定時任務(wù)運(yùn)用方案中，報警通知能力必不可少，任務(wù)跑失敗了需要及時通知到用戶，否則可能產(chǎn)生故障。

原生 Spring 定時任務(wù)不支持報警通知能力，如果要自研，可以參考上一章節(jié)中《異常統(tǒng)一處理》對任務(wù)失敗的信息進(jìn)行收集，構(gòu)建相應(yīng)的異常處理機(jī)制（包括對接各類報警平臺進(jìn)行異常消息通知處理，定義異常等級和類別進(jìn)行不同的通知策略），然后進(jìn)行定時任務(wù)報警通知。

無在線排查分析能力

定時任務(wù)在運(yùn)行過程中會存在各種各樣的問題，比如：執(zhí)行失敗、執(zhí)行耗時、執(zhí)行卡住等，這些都需要在后期實(shí)際運(yùn)維去定位快速分析。在對應(yīng)分析過程中沒有高效在線排查能力的話將遇到很多棘手的問題：

集群中任務(wù)對應(yīng)時間點(diǎn)是跑在哪個機(jī)器上無從可知

需要在大量的業(yè)務(wù)應(yīng)用日志中去檢索對應(yīng)時點(diǎn)的定時任務(wù)執(zhí)行日志，需要自行對接日志服務(wù)改善

如果任務(wù)涉及多個跨服務(wù)調(diào)用，無法定位執(zhí)行異常點(diǎn)或執(zhí)行耗時點(diǎn)，需要自建全鏈路追蹤來支持

阿里云 Spring 定時任務(wù)企業(yè)級解決方案

Cloud Native

接下來主要講下如何利用公有云上任務(wù)調(diào)度 SchedulerX 輕松接入基于 Spring 開發(fā)的定時任務(wù)。前面聊了基于 Spring 原生功能在使用過程中面臨的問題及需要自行處理解決的相關(guān)方案，可以看到僅針對企業(yè)級最基礎(chǔ)的運(yùn)用場景下就需要花費(fèi)較多的改造投入及相關(guān)服務(wù)后續(xù)運(yùn)維投入。通過接入 SchedulerX 任務(wù)調(diào)度平臺，原本 Spring 定時任務(wù)使用者可無縫且 0 改造獲得企業(yè)級運(yùn)用所需能力，同時降低了自研部署運(yùn)維定時服務(wù)相關(guān)組件的技術(shù)成本。

如何接入

對于 SchedulerX 新用戶而言接入僅需三步（參考附件接入手冊）：

依賴 SchedulerX 的 Spring Boot 版 SDK 完成調(diào)度平臺接入（版本>=1.7.2，老用戶僅升級 SDK 版本即可）

配置文件添加配置項，配置開啟后 Spring 定時調(diào)度器將不運(yùn)行相關(guān)任務(wù)（未配置情況下，不會主動接管原 Spring 定時任務(wù)運(yùn)行，在配置開啟前不會影響原本定時任務(wù)業(yè)務(wù)運(yùn)行）

# 配置表示由SchedulerX接管Spring定時任務(wù)運(yùn)行
spring.schedulerx2.task.scheduling.scheduler=schedulerx

控制臺上在對應(yīng)應(yīng)用分組下創(chuàng)建任務(wù)配置定時觸發(fā)。也可以選擇開啟自動同步任務(wù)配置方式（可選）

# 自動同步Spring定時任務(wù)至調(diào)度平臺，無需單獨(dú)手動創(chuàng)建（默認(rèn)不開啟）
spring.schedulerx2.task.scheduling.sync=true

接入優(yōu)勢

白屏管控和運(yùn)維

提供白屏控制臺可以動態(tài)新增、修改、啟用、禁用任務(wù)，支持運(yùn)行一次、原地重跑、重刷數(shù)據(jù)、停止任務(wù)、標(biāo)記成功等運(yùn)維操作。

可視化在線排查問題

支持執(zhí)行記錄查看、執(zhí)行業(yè)務(wù)日志查詢、執(zhí)行全鏈路追蹤。

豐富的報警通知

SchedulerX 提供豐富的報警通知能力，支持短信、電話、郵件、webhook 報警，支持報警聯(lián)系人組和報警歷史，可白屏動態(tài)配置。

其他優(yōu)勢

無改造成本的平臺接入方案。

無需額外獨(dú)立運(yùn)維調(diào)度服務(wù)平臺或其他第三方組件服務(wù)。

任務(wù)運(yùn)行在集群環(huán)境中具備穩(wěn)定高可靠支持，規(guī)避了原生框架存在的重復(fù)執(zhí)行問題，具備故障自動轉(zhuǎn)移能力。

在企業(yè)內(nèi)多個團(tuán)隊可共享一套平臺使用，通過命名空間和應(yīng)用分組實(shí)現(xiàn)各團(tuán)隊任務(wù)配置數(shù)據(jù)隔離及環(huán)境隔離。

總結(jié)

Cloud Native

本文主要從 Spring 定時任務(wù)的運(yùn)行機(jī)制進(jìn)行剖析闡述，并對如何擴(kuò)展框架原生能力以滿足企業(yè)級生產(chǎn)環(huán)境運(yùn)行定時任務(wù)所需各種場景提出了相應(yīng)的建議，用戶可作參考構(gòu)建自己內(nèi)部定時任務(wù)方案。同時就阿里云上提供的任務(wù)調(diào)度服務(wù)如何接入 Spring 定時任務(wù)的運(yùn)行進(jìn)行講解，并簡單展示了接入后所帶來的企業(yè)級能力。最后歡迎有定時任務(wù)業(yè)務(wù)需求用戶可先通過基礎(chǔ)免費(fèi)額度體驗(yàn)感受云上服務(wù)帶來便捷。

審核編輯：湯梓紅