暂无图片
暂无图片
暂无图片
暂无图片
暂无图片

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

程序员众推 2021-05-27
902

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


文章转载自程序员众推,如果涉嫌侵权,请发送邮件至:contact@modb.pro进行举报,并提供相关证据,一经查实,墨天轮将立刻删除相关内容。

评论