小Hub領(lǐng)讀：

常見(jiàn)的分布式定時(shí)任務(wù)框架：elastic-job、xxl-job、quartz ，你都熟悉嗎，今天先來(lái)學(xué)一下Quartz吧！

作者：Sam Sho

https://blog.csdn.net/u012228718/article/details/90041675

見(jiàn)名知意，該篇番外主要是要解決如下幾個(gè)問(wèn)題：

1、使用 SpringBoot2.x 版本集成 Quartz

2、Quartz 的任務(wù)動(dòng)態(tài)實(shí)現(xiàn)：

• 調(diào)度任務(wù)可以通過(guò)頁(yè)面進(jìn)行新增、刪除、啟動(dòng)、暫定等操作

• 任務(wù)數(shù)據(jù)使用數(shù)據(jù)庫(kù)保存

• 任務(wù)之間實(shí)現(xiàn)簡(jiǎn)單的依賴

3、Quartz 實(shí)現(xiàn)分布式調(diào)度，使用其本身提供的基于數(shù)據(jù)庫(kù)的實(shí)現(xiàn)

SpringBoot2 集成 Quartz

1、SpringBoot 不同的版本對(duì)于 Quartz 的集成有一定的差別，本文使用 2.1.2.RELEASE 版本。其實(shí)通過(guò)分析 SpringBoot 對(duì)于 Quartz 的自動(dòng)化配置源碼，也有助于我們理解 Quartz 的使用

2、SpringBoot-2.1.2.RELEASE 版本已經(jīng)集成了對(duì)于 Quartz 的自動(dòng)化配置，其源碼路徑為 org.springframework.boot.autoconfigure.quartz

集成簡(jiǎn)單實(shí)現(xiàn)

Pom 依賴

編碼功能實(shí)現(xiàn)

1、由于 Springboot2 的自動(dòng)化配置，不需要做任何配置，直接寫 JobDetail、Trigger、Job 即可實(shí)現(xiàn)

# Job 實(shí)現(xiàn)
@DisallowConcurrentExecution
public class DemoJob extends QuartzJobBean {
    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        System.out.println('~~ DemoJob 啟動(dòng)運(yùn)行匯總~~');
    }
}
# JobDetail、Trigger Bean配置
@Configuration
public class QuartzJobConfig {
    @Bean
    public JobDetailFactoryBean jobDetailFactoryBean() {
        JobDetailFactoryBean jobDetail = new JobDetailFactoryBean();
        jobDetail.setName('DemoJob');
        jobDetail.setGroup('DemoJob_Group');
        jobDetail.setJobClass(DemoJob.class);
        jobDetail.setDurability(true);
        return jobDetail;
    }
    @Bean
    public CronTriggerFactoryBean cronTriggerFactoryBean() {
        CronTriggerFactoryBean trigger = new CronTriggerFactoryBean();
        trigger.setJobDetail(jobDetailFactoryBean().getObject());
        trigger.setCronExpression('*/10 * * * * ?');
        trigger.setName('DemoJob');
        trigger.setMisfireInstruction(0);
        return trigger;
    }
}

2、這樣就實(shí)現(xiàn)了 SpringBoot2.x 版本集成 Quartz 功能，在進(jìn)行下一步之前，我們先對(duì)自動(dòng)化配置的源碼簡(jiǎn)單分析一下。

自動(dòng)配置實(shí)現(xiàn)分析

SpringBoot 關(guān)于 Quartz 的自動(dòng)配置的類一共有 6 個(gè)，分別為：

1、 JobStoreType：是一個(gè)枚舉類，定義了 jobsStore 的類型，基于內(nèi)存和數(shù)據(jù)庫(kù)

2、 QuartzAutoConfiguration：自動(dòng)配置類，配置了 Quartz 的主要組件，如 SchedulerFactoryBean

3、 QuartzDataSource：是一個(gè)注解類。如果需要注入 Quartz 配置的數(shù)據(jù)庫(kù)操作類，需要使用此注解標(biāo)注。參考 QuartzAutoConfiguration中的用法

4、 QuartzDataSourceInitializer：該類主要用于數(shù)據(jù)源初始化后的一些操作，根據(jù)不同平臺(tái)類型的數(shù)據(jù)庫(kù)進(jìn)行選擇不同的數(shù)據(jù)庫(kù)腳本

5、 QuartzProperties：該類對(duì)應(yīng)了在 application.yml配置文件以 spring.quartz開(kāi)頭的相關(guān)配置

6、 SchedulerFactoryBeanCustomizer：在自動(dòng)配置的基礎(chǔ)上自定義配置需要實(shí)現(xiàn)的此接口。

自動(dòng)化配置分析 QuartzAutoConfiguration

1、初始化注入任務(wù)以及配置：構(gòu)造函數(shù)實(shí)現(xiàn)

• 注入了屬性配置文件類： QuartzProperties

• 注入了自定義擴(kuò)展配置： SchedulerFactoryBeanCustomizer

• 注入了 Quartz 的任務(wù)組件： JobDetail、 Trigger、 Calendar。所以我們只需要進(jìn)行 JobDetail、Trigger Bean 配置，會(huì)自動(dòng)注入進(jìn) QuartzAutoConfiguration類中，這邊是通過(guò) ObjectProvider的使用實(shí)現(xiàn)的。

2、配置 SchedulerFactoryBean 的詳細(xì)信息。這個(gè)類是一個(gè) FactoryBean。

• 配置 JobFactory，內(nèi)部設(shè)置了 applicationContext與 spring 容器結(jié)合

• 配置各種屬性，是通過(guò) QuartzProperties類實(shí)現(xiàn)

• 配置注入進(jìn)來(lái)的 JobDetail、 Trigger、 Calendar

• 配置自定配置，是通過(guò) SchedulerFactoryBeanCustomizer實(shí)現(xiàn)。這邊包括自定義，也包括基于數(shù)據(jù)庫(kù)實(shí)現(xiàn)的 JobStore配置。

@Bean
@ConditionalOnMissingBean
public SchedulerFactoryBean quartzScheduler() {
    # 配置 `JobFactory`
    SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
    SpringBeanJobFactory jobFactory = new SpringBeanJobFactory();
    jobFactory.setApplicationContext(this.applicationContext);
    schedulerFactoryBean.setJobFactory(jobFactory);
    # 開(kāi)始配置各種屬性
    if (this.properties.getSchedulerName() != null) {
        schedulerFactoryBean.setSchedulerName(this.properties.getSchedulerName());
    }
    schedulerFactoryBean.setAutoStartup(this.properties.isAutoStartup());
    schedulerFactoryBean
            .setStartupDelay((int) this.properties.getStartupDelay().getSeconds());
    schedulerFactoryBean.setWaitForJobsToCompleteOnShutdown(
            this.properties.isWaitForJobsToCompleteOnShutdown());
    schedulerFactoryBean
            .setOverwriteExistingJobs(this.properties.isOverwriteExistingJobs());
    if (!this.properties.getProperties().isEmpty()) {
        schedulerFactoryBean
                .setQuartzProperties(asProperties(this.properties.getProperties()));
    }
    # 配置 jobDetails、triggers等
    if (this.jobDetails != null && this.jobDetails.length > 0) {
        schedulerFactoryBean.setJobDetails(this.jobDetails);
    }
    if (this.calendars != null && !this.calendars.isEmpty()) {
        schedulerFactoryBean.setCalendars(this.calendars);
    }
    if (this.triggers != null && this.triggers.length > 0) {
        schedulerFactoryBean.setTriggers(this.triggers);
    }
    # 自定義配置
    customize(schedulerFactoryBean);
    return schedulerFactoryBean;
}

3、基于數(shù)據(jù)庫(kù)實(shí)現(xiàn)的 JobStore 配置，內(nèi)部類 JdbcStoreTypeConfiguration

• @ConditionalOnSingleCandidate(DataSource.class) 指定 pring 容器中有且只有一個(gè)指明的 DataSourceBean 時(shí)生效

• 通過(guò) dataSourceCustomizer方法實(shí)現(xiàn) schedulerFactoryBean的數(shù)據(jù)庫(kù)相關(guān)配置，該方法返回一個(gè) SchedulerFactoryBeanCustomizer。

• 配置 QuartzDataSourceInitializer 數(shù)據(jù)庫(kù)初始化 Bean

4、通過(guò)后置工廠處理器 DataSourceInitializerSchedulerDependencyPostProcessor 實(shí)現(xiàn)對(duì)于 QuartzDataSourceInitializer這個(gè) Bean 的依賴關(guān)系（dependsOn）

支持功能配置 QuartzProperties

1、 @ConfigurationProperties('spring.quartz') 以 spring.quartz開(kāi)頭的配置

2、SpringBoot 已經(jīng)做了相應(yīng)的默認(rèn)值處理，即使不做任何配置，也是沒(méi)有問(wèn)題的。

3、比較簡(jiǎn)單，直接貼碼。屬性的具體含義，任務(wù)調(diào)度框架（3）Quartz 簡(jiǎn)單使用

spring:
  quartz:
    scheduler-name: springboot-quartz-jdbc-dynamic
    auto-startup: false
    startup-delay: 5s
    overwrite-existing-jobs: false
    wait-for-jobs-to-complete-on-shutdown: true
    job-store-type: memory
    #    jdbc:
    #      initialize-schema: embedded
    #      schema: classpath:org/quartz/impl/jdbcjobstore/tables_@@platform@@.sql
    #      comment-prefix: --
    properties: {
      org.quartz.scheduler.instanceName: springboot-quartz-jdbc-dynamic,
      org.quartz.scheduler.instanceId: AUTO,
      org.quartz.threadPool.class: org.springframework.scheduling.quartz.SimpleThreadPoolTaskExecutor,
      org.quartz.threadPool.threadCount: 25,
      org.quartz.threadPool.threadPriority: 5,
      org.quartz.jobStore.misfireThreshold: 60000,
      #      org.quartz.jobStore.tablePrefix: QRTZ_,
      #      org.quartz.jobStore.isClustered: true,
      #      org.quartz.jobStore.clusterCheckinInterval: 20000,
      #      org.quartz.jobStore.maxMisfiresToHandleAtATime: 1,
      #      org.quartz.jobStore.txIsolationLevelSerializable: false
    }

小結(jié)

1、至此，我們完成了 SpringBoot 與 Quartz 的集成，并且簡(jiǎn)單運(yùn)行了我們的調(diào)度任務(wù)

2、簡(jiǎn)單分析了 SpringBoot 對(duì)于 Quartz 的自動(dòng)配置，由于各個(gè)版本的差別，這邊使用的是 SpringBoot-2.1.2.RELEASE

Quartz 實(shí)現(xiàn)分布式調(diào)度

回顧分析

任務(wù)調(diào)度框架（4）Quartz 分布式實(shí)現(xiàn) 已經(jīng)對(duì) Quartz 自身的分布式實(shí)現(xiàn)做了簡(jiǎn)單的介紹，這邊主要基于 SpringBoot 怎么做。

配置簡(jiǎn)單實(shí)現(xiàn)

1、上述完成的 SpringBoot 與 Quartz 的集成，可以看到有幾個(gè)先關(guān)的配置：

• job-store-type 可以選擇 JDBC完成分布式 JdbcJobStore切換

• jdbc.XXX 主要是對(duì)于初始化 SQL 的配置。樹(shù)妖是對(duì)于 quartz 提供的 11 張表的初始化 sql

• 對(duì)于 JdbcJobStore 的一些特殊配置，如表前綴、集群指定、數(shù)據(jù)庫(kù)檢查等，基于 RamJobStore時(shí)，這些是不允許配置的。

2、以上就配置好了 Quartz 實(shí)現(xiàn)分布式調(diào)度，就是這么簡(jiǎn)單

3、【注意】在嘗試的時(shí)候， jdbc.xxx配置沒(méi)有生效，個(gè)人是自己手動(dòng)初始化的表。

Quartz 的任務(wù)動(dòng)態(tài)實(shí)現(xiàn)

1、以上我們簡(jiǎn)單完成了 SpringBoot 集成與基于 JDBC 的分布式，但是我們的任務(wù)還是基于 Bean 配置的：

• 新增任務(wù)需要手動(dòng)硬編碼，增加 JobDetail、 Trigger的 Bean 配置

• 上線后的任務(wù)無(wú)法修改，需要修改代碼，停止應(yīng)用

2、所以，所謂的動(dòng)態(tài)任務(wù)主要是三個(gè)問(wèn)題：

• 任務(wù)數(shù)據(jù)使用數(shù)據(jù)庫(kù)保存，包括任務(wù)的基本信息與 trigger 信息

• 調(diào)度任務(wù)可以通過(guò)頁(yè)面進(jìn)行新增、修改、刪除、啟動(dòng)、暫停、重啟等操作

• 任務(wù)之間實(shí)現(xiàn)簡(jiǎn)單的依賴，如 A 任務(wù)依賴于 B 任務(wù)，那么 A 任務(wù)必須等到 B 任務(wù)執(zhí)行完成才會(huì)自動(dòng)執(zhí)行

數(shù)據(jù)使用數(shù)據(jù)庫(kù)保存

1、簡(jiǎn)單，把任務(wù)調(diào)度分為兩個(gè)模塊：

• 基本任務(wù)（BatchTask）與任務(wù)計(jì)劃（BatchSchedule），BatchTask 與 BatchSchedule 是一對(duì)多關(guān)系，代替 Quartz 中 jobGroup 的概念。

• 任務(wù)計(jì)劃（BatchSchedule） 中可能需要用到配置的一些參數(shù)，定義任務(wù)計(jì)劃參數(shù)（BatchScheduleParam）

2、具體的實(shí)體如下，數(shù)據(jù)庫(kù)相關(guān)表結(jié)構(gòu)略

• 基本任務(wù)（BatchTask）

public class BatchTask extends AbstractDataEntity {
    /**
     * 任務(wù)編碼：唯一
     */
    private String code;
    /**
     * 任務(wù)名稱
     */
    private String name;
    /**
     * 任務(wù)描述
     */
    private String description;
    /**
     * 前置任務(wù)
     */
    private List<BatchTask> previous;
}

• 任務(wù)計(jì)劃（BatchSchedule）

• 計(jì)劃參數(shù)（BatchScheduleParam）

public class BatchScheduleParam {
    /**
     * 任務(wù)計(jì)劃ID
     */
    private String scheduleId;
    /**
     * 任務(wù)計(jì)劃code
     */
    private String scheduleCode;
    /**
     * 參數(shù)名
     */
    private String paramName;
    /**
     * 參數(shù)值
     */
    private String paramValue;
}

3、有了這些實(shí)體，無(wú)非就是根據(jù)實(shí)體對(duì)基本任務(wù)與任務(wù)計(jì)劃做 CRUD，這個(gè)比較簡(jiǎn)單，不贅述。

任務(wù)計(jì)劃的動(dòng)態(tài)管理

手動(dòng)配置實(shí)現(xiàn)的原理

1、手動(dòng)配置是需要編碼實(shí)現(xiàn) JobDetailFactoryBean、 CronTriggerFactoryBean，然后通過(guò) SpringBoot 的自動(dòng)化配置，設(shè)置到
schedulerFactoryBean對(duì)象的對(duì)應(yīng)屬性中。

2、 SchedulerFactoryBean源碼中，通過(guò) afterPropertiesSet()方法中方法，注冊(cè)到 Scheduler對(duì)象中

• 最終核心是通過(guò) Scheduler.scheduleJob(jobDetail,trigger);添加

// Initialize the Scheduler instance...
this.scheduler = prepareScheduler(prepareSchedulerFactory());
try {
    registerListeners();
    registerJobsAndTriggers(); # 注冊(cè)JobsAndTriggers
}
protected void registerJobsAndTriggers() throws SchedulerException {
    // Register JobDetails.
    if (this.jobDetails != null) {
        for (JobDetail jobDetail : this.jobDetails) {
            addJobToScheduler(jobDetail);
        }
    }
    // Register Triggers.
    if (this.triggers != null) {
        for (Trigger trigger : this.triggers) {
            addTriggerToScheduler(trigger);
        }
    }
}
private boolean addJobToScheduler(JobDetail jobDetail) throws SchedulerException {
    if (this.overwriteExistingJobs || getScheduler().getJobDetail(jobDetail.getKey()) == null) {
        # 最終是通過(guò)Scheduler.addJob(jobDetail, true); 添加
        getScheduler().addJob(jobDetail, true);
        return true;
    }
    else {
        return false;
    }
}
private boolean addTriggerToScheduler(Trigger trigger) throws SchedulerException {
    # 最終是通過(guò)Scheduler.scheduleJob(jobDetail, trigger); 添加（只是一部分功能）
    getScheduler().scheduleJob(jobDetail, trigger);
}

動(dòng)態(tài)管理：創(chuàng)建計(jì)劃任務(wù)引擎類

1、 Scheduler 在 SpringBoot 中已經(jīng)通過(guò) SchedulerFactoryBean自動(dòng)配置好了，直接注入即可使用。 2、具體可以 參考源碼

任務(wù)狀態(tài)與計(jì)劃依賴

1、使用 JobListener實(shí)現(xiàn)，需要自定義配置的支持

public class CustomGlobalJobListener extends JobListenerSupport {
    @Override
    public String getName() {
        return this.getClass().getName();
    }
    /**
     * Scheduler 在 JobDetail 將要被執(zhí)行時(shí)調(diào)用這個(gè)方法。
     *
     * @param context
     */
    @Override
    public void jobToBeExecuted(JobExecutionContext context) {
        getLog().debug('計(jì)劃 {} ： ~~~ 【RUNNING】 更新正在運(yùn)行中狀態(tài) ~~~ ');
    }
    /**
     * Scheduler 在 JobDetail 即將被執(zhí)行，但又被 TriggerListener 否決了時(shí)調(diào)用這個(gè)方法
     *
     * @param context
     */
    @Override
    public void jobExecutionVetoed(JobExecutionContext context) {
    }
    /**
     * Scheduler 在 JobDetail 被執(zhí)行之后調(diào)用這個(gè)方法
     *
     * @param context
     * @param jobException
     */
    @Override
    public void jobWasExecuted(JobExecutionContext context, JobExecutionException jobException) {
        getLog().debug('計(jì)劃 {} ： ~~~ 【COMPLETE | ERROR】 更新已經(jīng)結(jié)束狀態(tài) ~~~ ');
        // 喚醒子任務(wù)
        batchScheduleService.notifyChildren(scheduleJob);
    }
}

2、自定義實(shí)現(xiàn)，可以實(shí)現(xiàn) SchedulerFactoryBeanCustomizer接口

3、計(jì)劃依賴：

• 如計(jì)劃有依賴其他計(jì)劃，則該計(jì)劃一般不允許手動(dòng)運(yùn)行，需要等待所依賴的計(jì)劃完成后在監(jiān)聽(tīng)器中自動(dòng)喚醒

• 目前只簡(jiǎn)單實(shí)現(xiàn)了單個(gè)計(jì)劃依賴，沒(méi)有實(shí)現(xiàn)復(fù)雜功能。后期可以擴(kuò)展：多計(jì)劃依賴，依賴排序等功能。

小結(jié)

至此，Quartz 的任務(wù)動(dòng)態(tài)實(shí)現(xiàn)已經(jīng)完成，主要可以分為三個(gè)部分：

1、任務(wù)與計(jì)劃定義，使用數(shù)據(jù)庫(kù)保存

2、動(dòng)態(tài)計(jì)劃的管理，使用 Quartz 本身的 API 實(shí)現(xiàn)

3、任務(wù)計(jì)劃狀態(tài)監(jiān)控，使用 JobListener監(jiān)聽(tīng)器實(shí)現(xiàn)

4、計(jì)劃依賴，使用 JobListener監(jiān)聽(tīng)器實(shí)現(xiàn)。

參考

1、lotso-web：使用 SpringBoot2.X 實(shí)現(xiàn) Quartz 動(dòng)態(tài)任務(wù)的分布式調(diào)度

2、源碼地址 LearningJobSchedule

（完）