页面

分类

取法其上，得乎其中

Springboot 集成 Quartz 实现动态配置任务和持久化任务

概述

在前天的博文中记录了学习的 Quartz 这个定时框架的简单操作，接下来我们就要学习将其整合进入 Springboot。

实际上我们想对其整合需要配置很多东西，但是 Springboot 为我们封装了一个启动器，所以我们就不需要配置了。

回到主题，我们为什么要实现「动态配置任务」呢？ 因为这样我们就可以实现在某一个客户端进行管理对应的任务的管理。比如，之前的例子中我们叙述了「花呗账单提醒」这样一个需求。那么如果某个月我们不想给用户提醒这个账单了呢？

难道我们要去改动代码？怎么可能。所有我们需要实现动态配置这样的需求，其实也就是实现「管理调度器」，然后编写对应的接口而已。

那么什么是「持久化任务」呢？ 简单的说，比如我们想要添加一个「任务1」来让调度器去执行，然后调度器会自动将这个任务的相关信息存入数据库之中。即使当前系统重启，Quartz 启动之后也会第一时间去运行「任务1」，因为在执行的时候我们把它存放到数据库之中了。

使用

pom

值得说明的是，后面的数据库驱动和 Druid 都是为了后面的持久化任务而配置的，如果不需要持久化可以省略。

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

注解形式运行 Job

如果我们拥有一些无论如何都要启动的任务，我们可以直接通过注解将其启动。如下列代码所示。我们只需要将其注册为组件然后在类上加入「@EnableScheduling」注解，方法加上「@Scheduled(「Corn表达式」)」即可实现此需求。

@Component
@EnableScheduling
public class DefaultJobService {

    @Scheduled(cron = "*/2 * * * * ?")
    public void test(){
        System.out.println(new Date());
    }

}

动态配置

首先我们可以直接通过注入拿到「调度器」。

@Autowired
private Scheduler scheduler;

然后就可以直接根据调度器去修改就行了。之后配合 controller 层让其去调用即可。

public boolean start(String name, String group, String cron, Class clazz) {
    try {
        JobDetail jobDetail = JobBuilder.newJob(clazz).withIdentity(name, group).build();
        CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(cron);
        CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(name, group)
                .withSchedule(cronScheduleBuilder).build();
        scheduler.scheduleJob(jobDetail, cronTrigger);
        scheduler.start();
        return true;
    } catch (SchedulerException e) {
        return false;
    }
}

public boolean stop(String name, String group) {
    try {
        scheduler.pauseJob(new JobKey(name, group));
        return true;
    } catch (SchedulerException e) {
        return false;
    }
}

public boolean resume(String name, String group){
    try {
        scheduler.resumeJob(new JobKey(name, group));
        return true;
    } catch (SchedulerException e) {
        return false;
    }
}

public boolean delete(String name, String group){
    try {
        scheduler.deleteJob(new JobKey(name, group));
        return true;
    } catch (SchedulerException e) {
        return false;
    }
}

持久化配置

在上诉中我们知道，所谓持久化其实就是将任务存储进数据库之中，那么它怎么知道它应该存储到那个表，又到那个表查？so,Quartz 官方给我们提供了一段 SQL语句让我们去建表。

DROP DATABASE IF EXISTS quartz;
CREATE DATABASE quartz DEFAULT CHARACTER SET utf8;
USE quartz;

DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS;
DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS;
DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE;
DROP TABLE IF EXISTS QRTZ_LOCKS;
DROP TABLE IF EXISTS QRTZ_SIMPLE_TRIGGERS;
DROP TABLE IF EXISTS QRTZ_SIMPROP_TRIGGERS;
DROP TABLE IF EXISTS QRTZ_CRON_TRIGGERS;
DROP TABLE IF EXISTS QRTZ_BLOB_TRIGGERS;
DROP TABLE IF EXISTS QRTZ_TRIGGERS;
DROP TABLE IF EXISTS QRTZ_JOB_DETAILS;
DROP TABLE IF EXISTS QRTZ_CALENDARS;

CREATE TABLE QRTZ_JOB_DETAILS
  (
    SCHED_NAME VARCHAR(120) NOT NULL,
    JOB_NAME  VARCHAR(100) NOT NULL,
    JOB_GROUP VARCHAR(100) NOT NULL,
    DESCRIPTION VARCHAR(250) NULL,
    JOB_CLASS_NAME   VARCHAR(250) NOT NULL,
    IS_DURABLE VARCHAR(1) NOT NULL,
    IS_NONCONCURRENT VARCHAR(1) NOT NULL,
    IS_UPDATE_DATA VARCHAR(1) NOT NULL,
    REQUESTS_RECOVERY VARCHAR(1) NOT NULL,
    JOB_DATA BLOB NULL,
    PRIMARY KEY (SCHED_NAME,JOB_NAME,JOB_GROUP)
);

CREATE TABLE QRTZ_TRIGGERS
  (
    SCHED_NAME VARCHAR(120) NOT NULL,
    TRIGGER_NAME VARCHAR(100) NOT NULL,
    TRIGGER_GROUP VARCHAR(100) NOT NULL,
    JOB_NAME  VARCHAR(100) NOT NULL,
    JOB_GROUP VARCHAR(100) NOT NULL,
    DESCRIPTION VARCHAR(250) NULL,
    NEXT_FIRE_TIME BIGINT(13) NULL,
    PREV_FIRE_TIME BIGINT(13) NULL,
    PRIORITY INTEGER NULL,
    TRIGGER_STATE VARCHAR(16) NOT NULL,
    TRIGGER_TYPE VARCHAR(8) NOT NULL,
    START_TIME BIGINT(13) NOT NULL,
    END_TIME BIGINT(13) NULL,
    CALENDAR_NAME VARCHAR(100) NULL,
    MISFIRE_INSTR SMALLINT(2) NULL,
    JOB_DATA BLOB NULL,
    PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    FOREIGN KEY (SCHED_NAME,JOB_NAME,JOB_GROUP)
        REFERENCES QRTZ_JOB_DETAILS(SCHED_NAME,JOB_NAME,JOB_GROUP)
);

CREATE TABLE QRTZ_SIMPLE_TRIGGERS
  (
    SCHED_NAME VARCHAR(120) NOT NULL,
    TRIGGER_NAME VARCHAR(100) NOT NULL,
    TRIGGER_GROUP VARCHAR(100) NOT NULL,
    REPEAT_COUNT BIGINT(7) NOT NULL,
    REPEAT_INTERVAL BIGINT(12) NOT NULL,
    TIMES_TRIGGERED BIGINT(10) NOT NULL,
    PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
        REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
);

CREATE TABLE QRTZ_CRON_TRIGGERS
  (
    SCHED_NAME VARCHAR(120) NOT NULL,
    TRIGGER_NAME VARCHAR(100) NOT NULL,
    TRIGGER_GROUP VARCHAR(100) NOT NULL,
    CRON_EXPRESSION VARCHAR(100) NOT NULL,
    TIME_ZONE_ID VARCHAR(80),
    PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
        REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
);

CREATE TABLE QRTZ_SIMPROP_TRIGGERS
  (          
    SCHED_NAME VARCHAR(120) NOT NULL,
    TRIGGER_NAME VARCHAR(100) NOT NULL,
    TRIGGER_GROUP VARCHAR(100) NOT NULL,
    STR_PROP_1 VARCHAR(512) NULL,
    STR_PROP_2 VARCHAR(512) NULL,
    STR_PROP_3 VARCHAR(512) NULL,
    INT_PROP_1 INT NULL,
    INT_PROP_2 INT NULL,
    LONG_PROP_1 BIGINT NULL,
    LONG_PROP_2 BIGINT NULL,
    DEC_PROP_1 NUMERIC(13,4) NULL,
    DEC_PROP_2 NUMERIC(13,4) NULL,
    BOOL_PROP_1 VARCHAR(1) NULL,
    BOOL_PROP_2 VARCHAR(1) NULL,
    PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) 
    REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
);

CREATE TABLE QRTZ_BLOB_TRIGGERS
  (
    SCHED_NAME VARCHAR(120) NOT NULL,
    TRIGGER_NAME VARCHAR(100) NOT NULL,
    TRIGGER_GROUP VARCHAR(100) NOT NULL,
    BLOB_DATA BLOB NULL,
    PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
    FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
        REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
);

CREATE TABLE QRTZ_CALENDARS
  (
    SCHED_NAME VARCHAR(120) NOT NULL,
    CALENDAR_NAME  VARCHAR(100) NOT NULL,
    CALENDAR BLOB NOT NULL,
    PRIMARY KEY (SCHED_NAME,CALENDAR_NAME)
);

CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS
  (
    SCHED_NAME VARCHAR(120) NOT NULL,
    TRIGGER_GROUP  VARCHAR(100) NOT NULL, 
    PRIMARY KEY (SCHED_NAME,TRIGGER_GROUP)
);

CREATE TABLE QRTZ_FIRED_TRIGGERS
  (
    SCHED_NAME VARCHAR(120) NOT NULL,
    ENTRY_ID VARCHAR(95) NOT NULL,
    TRIGGER_NAME VARCHAR(100) NOT NULL,
    TRIGGER_GROUP VARCHAR(100) NOT NULL,
    INSTANCE_NAME VARCHAR(100) NOT NULL,
    FIRED_TIME BIGINT(13) NOT NULL,
    SCHED_TIME BIGINT(13) NOT NULL,
    PRIORITY INTEGER NOT NULL,
    STATE VARCHAR(16) NOT NULL,
    JOB_NAME VARCHAR(100) NULL,
    JOB_GROUP VARCHAR(100) NULL,
    IS_NONCONCURRENT VARCHAR(1) NULL,
    REQUESTS_RECOVERY VARCHAR(1) NULL,
    PRIMARY KEY (SCHED_NAME,ENTRY_ID)
);

CREATE TABLE QRTZ_SCHEDULER_STATE
  (
    SCHED_NAME VARCHAR(120) NOT NULL,
    INSTANCE_NAME VARCHAR(100) NOT NULL,
    LAST_CHECKIN_TIME BIGINT(13) NOT NULL,
    CHECKIN_INTERVAL BIGINT(13) NOT NULL,
    PRIMARY KEY (SCHED_NAME,INSTANCE_NAME)
);

CREATE TABLE QRTZ_LOCKS
  (
    SCHED_NAME VARCHAR(120) NOT NULL,
    LOCK_NAME  VARCHAR(40) NOT NULL, 
    PRIMARY KEY (SCHED_NAME,LOCK_NAME)
);

commit;

执行完毕后，在「application.yml」中加入以下配置。

spring:
  datasource:
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/quartz?useSSL=false&useUnicode=true
    username: root
    password: 123456
  quartz:
      jdbc:
        #  初始化Quartz表结构,项目第一次启动配置程always,然后改成never 否则已生成的job会被初始化掉
        initialize-schema: never
      #   作业存储类型
      job-store-type: jdbc
      #   调度程序的名称
      scheduler-name: hrCleanScheduler
      properties:
        org:
          quartz:
            scheduler:
              instanceName: etlCleanScheduler
              instanceId: AUTO
            jobStore:
              #数据保存方式为持久化
              class: org.quartz.impl.jdbcjobstore.JobStoreTX
              driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
              #Quartz表前缀
              tablePrefix: QRTZ_
              #是否加入集群
              isClustered: false
              clusterCheckinInterval: 10000
              useProperties: false
            #            调度器线程池配置
            threadPool:
              class: org.quartz.simpl.SimpleThreadPool
              #线程数
              threadCount: 20
              #线程优先级
              threadPriority: 5
              threadsInheritContextClassLoaderOfInitializingThread: true

自此，便配置完毕。接下来 Quartz 会自动进行持久化。

值得注意的是，如果配置完毕后提示「无法找到JDBC」请在项目中加入「JDBC」库或「Mybatis」或其他框架。

Springboot 集成 Quartz 实现动态配置任务和持久化任务

https://ku-m.cn/index.php/archives/470/

作者

KuM

发布时间

2021-02-08

许可协议

CC BY 4.0

标签： SpringBoot Quratz

本页的评论功能已关闭