SpringBoot：集成Quartz实现持久化定时接口调用任务

缺乏、安全感 2024-03-22 12:22 6阅读 0赞

![format_png][]

## 一、基本概念 ##

Quartz 是功能强大的开源作业调度库，几乎可以集成到任何 Java 应用程序中，从最小的独立应用程序到最大的电子商务系统。Quartz 可用于创建简单或复杂的计划，以执行数以万计的工作；可以执行您编写的所有内容。

Spring Boot 官方也对 Quartz 调度器进行了集成，Spring boot 官网文档：Quartz Scheduler，Java JDK 也带有 计时器 Timer 以及 定时执行服务 ScheduledExecutorService ，Spring 也提供了 @Scheduled 执行定时任务。

> 如果实际环境中定时任务过多，处理频繁，建议适应第三方封装的调度框架，因为定时器操作底层都是多线程的操作，任务的启动、暂停、恢复、删除、实质是线程的启动、暂停、中断、唤醒等操作。

## 二、Quartz-scheduler 的核心流程 ##

![format_png 1][]

**Scheduler - 调度器**

1、Scheduler 用来对 Trigger 和 Job 进行管理，Trigger 和 JobDetail 可以注册到 Scheduler 中，两者在 Scheduler 中都拥有自己的唯一的组(group)和名称(name)用来进行彼此的区分，Scheduler 可以通过任务组和名称来对 Trigger 和 JobDetail 进行管理。

2、每个 Scheduler 都有一个 SchedulerContext，用来保存 Scheduler 的上下文数据，Job 和 Trigger 都可以获取其中的信息。

3、Scheduler 是由 SchedulerFactory 创建，它有两个实现：DirectSchedulerFactory 、StdSchdulerFactory ，前者可以用来在代码里定制 Schduler 参数，后者直接读取 classpath 下的 quartz.properties（不存在就都使用默认值）配置来实例化 Scheduler。

**Job - 任务**

1、Job 是一个任务接口，开发者可以实现该接口定义自己的任务，JobExecutionContext 中提供了调度上下文的各种信息。

2、Job 中的任务有可能并发执行，例如任务的执行时间过长，而每次触发的时间间隔太短，则会导致任务会被并发执行。如果是并发执行，就需要一个数据库锁去避免一个数据被多次处理。可以在 execute（）方法上添加 @DisallowConcurrentExecution 注解解决这个问题。

**JobDetail - 任务详情**

1、JobDetail 对象是在将 job 注册到 scheduler 时，由客户端程序创建的，它包含 job 的各种属性设置，以及用于存储 job 实例状态信息的 JobDataMap。

2、JobDetail 由 JobBuilder 创建/定义，Quartz 不存储 Job 的实际实例，但是允许通过使用 JobDetail 定义一个实例。

3、Job 有一个与其关联的名称和组，应该在单个 Scheduler 中唯一标识它们。

4、一个 Trigger(触发器) 只能对应一个 Job（任务），但是一个 Job 可以对应多个 Trigger。JobDetal 与 Trigger 一对多

**Trigger - 触发器**

1、Trigger 用于触发 Job 的执行。TriggerBuilder 用于定义/构建触发器实例。

2、Trigger也有一个相关联的 JobDataMap，用于给Job传递一些触发相关的参数。

3、Quartz自带了各种不同类型的 Trigger，最常用的主要是SimpleTrigger和CronTrigger。

**JobDataMap**

1、JobDataMap 实现了 JDK 的 Map 接口，可以以 Key-Value 的形式存储数据。

2、JobDetail、Trigger 实现类中都定义 JobDataMap 成员变量及其 getter、setter 方法，可以用来设置参数信息，Job 执行 execute() 方法的时候，JobExecutionContext 可以获取到 JobDataMap 中的信息。

## 三、实践 ##

### 1、新建一个quartz-service服务 ###

![format_png 2][]

添加依赖：

<modelVersion>4.0.0</modelVersion>
    
        <groupId>org.example</groupId>
        <artifactId>quartz-servicer</artifactId>
        <version>1.0.0</version>
    
        <properties>
            <maven.compiler.source>11</maven.compiler.source>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <maven.compiler.target>11</maven.compiler.target>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
                <version>2.7.5</version>
            </dependency>
            
            
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>2.0.19</version>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-quartz</artifactId>
                <version>2.5.4</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>8.0.31</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
                <version>2.7.3</version>
            </dependency>
    
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.2.14</version>
                <exclusions>
                    <exclusion>
                        <artifactId>spring-boot-autoconfigure</artifactId>
                        <groupId>org.springframework.boot</groupId>
                    </exclusion>
                </exclusions>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    复制代码

### 2、配置数据源相关链接 ###

quartz需要单据的数据库，所以需要单据创建一个库来给quartz使用，我新建了一个scheduler的库，详细信息官方参考[quartz-scheduler][]/**[quartz][]**

![format_png 3][]

#1 保存已经触发的触发器状态信息
    DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS;
    #2 存放暂停掉的触发器表表
    DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS;
    #3 调度器状态表
    DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE;
    #4 存储程序的悲观锁的信息(假如使用了悲观锁)
    DROP TABLE IF EXISTS QRTZ_LOCKS;
    #5 简单

[format_png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/d980fbae02914543a8ee2744c6c87b91.png
[format_png 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/4b5513ad6c0f4382affda850725c089e.png
[format_png 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/5d31a197923147439eb23f3ea5afd9f5.png
[quartz-scheduler]: https://link.juejin.cn/?target=https%3A%2F%2Fgithub.com%2Fquartz-scheduler
[quartz]: https://link.juejin.cn/?target=https%3A%2F%2Fgithub.com%2Fquartz-scheduler%2Fquartz
[format_png 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/f79d6ee1335f4a55940f21d2dda8a152.png