springboot2.x基础教程：集成Quartz分布式任务调度

前面介绍了SpringBoot自带@Scheduled注解的使用，但是在实际项目中程序通常部署成集群，这样造成同一个任务会执行多次。另外@Scheduled的任务不能进行界面管理。本文介绍如何使用Quartz将任务持久化到数据库，进行分布式的任务调度。

引入依赖

<dependency>
 <groupId>org.springframework.boot</groupId>
 <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

Quartz配置

spring:
  quartz:
    properties:
      org:
        quartz:
          scheduler:
            instanceName: clusteredScheduler #调度器实例名称
            instanceId: AUTO #调度器实例编号自动生成
          jobStore:
            class: org.quartz.impl.jdbcjobstore.JobStoreTX #持久化方式配置
            driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate #持久化方式配置数据驱动，MySQL数据库
            tablePrefix: qrtz_ #quartz相关数据表前缀名
            isClustered: true #开启分布式部署
            clusterCheckinInterval: 10000 #分布式节点有效性检查时间间隔，单位：毫秒
            useProperties: false #配置是否使用
          threadPool:
            class: org.quartz.simpl.SimpleThreadPool #线程池实现类
            threadCount: 10 #执行最大并发线程数量
            threadPriority: 5 #线程优先级
            threadsInheritContextClassLoaderOfInitializingThread: true #配置是否启动自动加载数据库内的定时任务，默认true
    job-store-type: jdbc
    overwrite-existing-jobs: true

Quartz SpringBoot使用

DataCheckJob继承 Job重写execute方法，这里与springboot2.x集成,需要注入DataMapper Bean,直接使用@Autowired强制注入,或者使用构造函数注入即可，其他低版本的则会出现bean注入不了的情况。需要自己实现AdaptableJobFactory注入bean

@Slf4j
public class DataCheckJob implements QuartzJobBean {
  @Autowired
  DataMapper dataMapper;
  @Override
  public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
    dataMapper.check();
  }
}

配置DataCheckJob与任务的触发器。

@Configuration
public class JobConfig {
  @Bean
  public JobDetail dataCheckJobDetail(){
    return JobBuilder.newJob(DataCheckJob.class).storeDurably().build();
  }
  @Bean
  public Trigger dataCheckTrigger(){
    return TriggerBuilder.newTrigger().forJob(dataCheckJobDetail()).withIdentity("DataCheckJob")
        .withSchedule(CronScheduleBuilder.cronSchedule("0 37 11 ? * *")).build();
  }
}

Quartz表说明

qrtz_blob_triggers

自定义的triggers使用blog类型进行存储，非自定义的triggers不会存放在此表中，Quartz提供的triggers包括：CronTrigger，CalendarIntervalTrigger， DailyTimeIntervalTrigger以及SimpleTrigger，这几个trigger信息会保存在后面的几张表中；

qrtz_cron_triggers

存放CronTrigger类型的触发器实例

qrtz_simple_triggers

存储SimpleTrigger

qrtz_simprop_triggers

存储CalendarIntervalTrigger和DailyTimeIntervalTrigger两种类型的触发器

qrtz_fired_triggers

存储已经触发的trigger相关信息，trigger随着时间的推移状态发生变化，直到最后trigger执行完成，从表中被删除。

相同的trigger和task，每触发一次都会创建一个实例；从刚被创建的ACQUIRED状态，到EXECUTING状态，最后执行完从数据库中删除。

qrtz_triggers

存储定义的trigger，和qrtz_fired_triggers存放的不一样，不管trigger触发了多少次都只有一条记录，TRIGGER_STATE用来标识当前trigger的状态

qrtz_job_details

存储jobDetails信息，相关信息在定义的时候指定。

qrtz_calendars

Quartz为我们提供了日历的功能，可以自己定义一个时间段，可以控制触发器在这个时间段内触发或者不触发；现在提供6种类型：AnnualCalendar，CronCalendar，DailyCalendar，HolidayCalendar，MonthlyCalendar，WeeklyCalendar；

qrtz_paused_trigger_grps

存放暂停的触发器

qrtz_scheduler_state

存储所有节点的scheduler，会定期检查scheduler是否失效，启动多个scheduler。

qrtz_locks

Quartz提供的锁表，为多个节点调度提供分布式锁，实现分布式调度，默认有2个锁。 STATE_ACCESS主要用在scheduler定期检查是否失效的时候，保证只有一个节点去处理已经失效的scheduler； TRIGGER_ACCESS主要用在TRIGGER被调度的时候，保证只有一个节点去执行调度；