侧边栏壁纸
博主头像
小武哥博主等级

专注做好每一件小事。

  • 累计撰写 45 篇文章
  • 累计创建 58 个标签
  • 累计收到 3 条评论

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

小武哥
2021-05-27 / 0 评论 / 0 点赞 / 393 阅读 / 3,020 字 / 正在检测是否收录...
温馨提示:
本文最后更新于 2021-07-02,若内容或图片失效,请留言反馈。部分素材来自网络,若不小心影响到您的利益,请联系我们删除。

前面介绍了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类型的触发器实例

image-20210202161444906

qrtz_simple_triggers

存储SimpleTrigger

qrtz_simprop_triggers

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

qrtz_fired_triggers

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

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

image-20210202161713557

qrtz_triggers

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

image-20210202162029477

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被调度的时候,保证只有一个节点去执行调度;

Quartz表手动生成

实际在使用Quartz过程中数据库中的表通常因为权限不能够自动生成,通常配置initialize-schema为never。

spring.quartz.jdbc.initialize-schema=never|always

在quartz的jar的org/quartz/impl/jdbcjobstore包中有对应各种关系数据库的数据库生成脚本。有时候默认的quartz-sql对于最新的数据库,比如oracle19c不能很好兼容,需要我们自己修改对应SQL语句。文章末尾给出oracle19c兼容脚本。

image-20210702102315196

0

评论区