SpringBoot整合Quartz实现任务定时

秒速五厘米 2023-10-06 10:38 148阅读 0赞

### SpringBoot整合Quartz实现任务定时 ###

> 前言:由于我们本项目选用的Springboot来整合Quartz，官方给我们提供了启动器所以很简单。在以前的版本我们想要使用Quartz需要引入的依赖如下:

<dependency>  
        <groupId>org.quartz-scheduler</groupId>  
        <artifactId>quartz</artifactId>  
        <version>2.2.3</version>  
    </dependency> 
    <dependency>  
        <groupId>org.quartz-scheduler</groupId>  
        <artifactId>quartz-jobs</artifactId>  
        <version>2.2.3</version>  
    </dependency>

> 按以上的方式来使用Quartz的话，或需要我们创建很多的配置类:`Job`的工厂类等。  
> 但是现在我们有了官方的启动器，依赖如下：

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

> 此时我们不需要配置很多配置类，只需要在我们的`application.yaml`文件中配置必要的信息就ok了。

--------------------

1、建项目、加依赖、搞配置  
**创建我们的springboot项目，并加入所需依赖**

![format_png][]

**由于需要数据库操作,加入如下依赖**

<dependency>
         <groupId>mysql</groupId>
         <artifactId>mysql-connector-java</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
         <groupId>org.projectlombok</groupId>
          <artifactId>lombok</artifactId>
          <optional>true</optional>
    </dependency>
    <dependency>
          <groupId>com.alibaba</groupId>
          <artifactId>druid</artifactId>
          <version>1.1.16</version>
    </dependency>
    
    <dependency>
         <groupId>com.baomidou</groupId>
         <artifactId>mybatis-plus-boot-starter</artifactId>
         <version>3.2.0</version>
    </dependency>

**配置基本配置**

spring:
      quartz:
        auto-startup: true
        properties:
          org:
            quartz:
              scheduler:
                instanceName: clusteredScheduler
                instanceId: AUTO
              jobStore:
                class: org.quartz.impl.jdbcjobstore.JobStoreCMT
                driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
                tablePrefix: QRTZ_
                isClustered: true
                clusterCheckinInterval: 10000
                useProperties: false
              threadPool:
                class: org.quartz.simpl.SimpleThreadPool
                threadCount: 20
                threadPriority: 5
                threadsInheritContextClassLoaderOfInitializingThread: true
        job-store-type: jdbc
        wait-for-jobs-to-complete-on-shutdown: true
          datasource:
        type: com.alibaba.druid.pool.DruidDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://localhost:3306/quartz?useUnicode=true&useSSL=false&characterEncoding=utf8&serverTimezone=UTC&allowPublicKeyRetrieval=true
        username: root
        password: root
        initialSize: 20
        minIdle: 5
        timeBetweenEvictionRunsMillis: 60000
        minEvictableIdleTimeMillis: 30000
        testWhileIdle: true
        filters: stat,wall,sl4j
        connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000

### quartz详细说明及api的使用 ###

*涉及表说明*

qrtz_calendars :存储quartz的calendar日历信息.
        qrtz_cron_triggers :存储cron trigger，包括cron表达式和时区信息。
        qrtz_fired_triggers :存储与已触发的trigger相关的状态信息，以及相联job的执行信息
        qrtz_job_details :存储每一个已配置的job的详细信息
        qrtz_locks :存储程序的非观锁的信息(假如使用了悲观锁)
        qrtz_paused_trigger_grps :存储已暂停的trigger组的信息
        qrtz_scheduler_state :存储少量的有关 scheduler的状态信息，和别的 scheduler 实例         qrtz_simple_triggers :存储简单的 trigger，包括重复次数，间隔，以及已触的次数
        qrtz_simprop_triggers
        qrtz_triggers :存储已配置的 trigger的信息

*表属性说明*

qrtz\_calendars表

qrtz\_cron\_triggers表

qrtz\_fired\_triggers表

<table> 
 <thead> 
  <tr> 
   <th align="center">字段中文名</th> 
   <th align="center">字段英文名</th> 
   <th align="center">数据类型</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center">计划名称</td> 
   <td align="center">SCHED_NAME</td> 
   <td align="center">VARCHAR2(120)</td> 
  </tr> 
  <tr> 
   <td align="center">组标识</td> 
   <td align="center">ENTRY_ID</td> 
   <td align="center">VARCHAR2(95)</td> 
  </tr> 
  <tr> 
   <td align="center">触发器名称</td> 
   <td align="center">TRIGGER_NAME</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">触发器组</td> 
   <td align="center">TRIGGER_GROUP</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">当前实例的名称</td> 
   <td align="center">INSTANCE_NAME</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">当前执行时间</td> 
   <td align="center">FIRED_TIME</td> 
   <td align="center">NUMBER(13)</td> 
  </tr> 
  <tr> 
   <td align="center">计划时间</td> 
   <td align="center">SCHED_TIME</td> 
   <td align="center">NUMBER(13)</td> 
  </tr> 
  <tr> 
   <td align="center">权重</td> 
   <td align="center">PRIORITY</td> 
   <td align="center">NUMBER</td> 
  </tr> 
  <tr> 
   <td align="center">状态</td> 
   <td align="center">STATE</td> 
   <td align="center">VARCHAR2(16)</td> 
  </tr> 
  <tr> 
   <td align="center">作业名称</td> 
   <td align="center">JOB_NAME</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">作业组</td> 
   <td align="center">JOB_GROUP</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">是否并行</td> 
   <td align="center">IS_NONCONCURRENT</td> 
   <td align="center">VARCHAR2(1)</td> 
  </tr> 
  <tr> 
   <td align="center">是否要求唤醒</td> 
   <td align="center">REQUESTS_RECOVERY</td> 
   <td align="center">VARCHAR2(1)</td> 
  </tr> 
 </tbody> 
</table>

qrtz\_job\_details表

<table> 
 <thead> 
  <tr> 
   <th align="center">字段中文名</th> 
   <th align="center">字段英文名</th> 
   <th align="center">数据类型</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center">调度名称</td> 
   <td align="center">SCHED_NAME</td> 
   <td align="center">VARCHAR2(120)</td> 
  </tr> 
  <tr> 
   <td align="center">job的名字</td> 
   <td align="center">JOB_NAME</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">job的所属组的名</td> 
   <td align="center">JOB_GROUP</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">相关介绍</td> 
   <td align="center">DESCRIPTION</td> 
   <td align="center">VARCHAR2(250)</td> 
  </tr> 
  <tr> 
   <td align="center">job实现类的完全</td> 
   <td align="center">JOB_CLASS_NAME</td> 
   <td align="center">VARCHAR2(250)</td> 
  </tr> 
  <tr> 
   <td align="center">是否持久化</td> 
   <td align="center">IS_DURABLE</td> 
   <td align="center">VARCHAR2(1)</td> 
  </tr> 
  <tr> 
   <td align="center">是否并发</td> 
   <td align="center">IS_NONCONCURRENT</td> 
   <td align="center">VARCHAR2(1)</td> 
  </tr> 
  <tr> 
   <td align="center">是否更新数据</td> 
   <td align="center">IS_UPDATE_DATA</td> 
   <td align="center">VARCHAR2(1)</td> 
  </tr> 
  <tr> 
   <td align="center">是否接受恢复执行</td> 
   <td align="center">REQUESTS_RECOVERY</td> 
   <td align="center">VARCHAR2(1)</td> 
  </tr> 
  <tr> 
   <td align="center">存放持久job对象</td> 
   <td align="center">JOB_DATA</td> 
   <td align="center">BLOB</td> 
  </tr> 
 </tbody> 
</table>

qrtz\_locks表

qrtz\_paused\_trigger\_grps表

qrtz\_scheduler\_state表

qrtz\_simple\_triggers表

qrtz\_triggers表

<table> 
 <thead> 
  <tr> 
   <th align="center">字段中文名</th> 
   <th align="center">字段英文名</th> 
   <th align="center">数据类型</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="center">计划名称</td> 
   <td align="center">SCHED_NAME</td> 
   <td align="center">VARCHAR2(120)</td> 
  </tr> 
  <tr> 
   <td align="center">触发器名称</td> 
   <td align="center">TRIGGER_NAME</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">触发器组</td> 
   <td align="center">TRIGGER_GROUP</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">作业名称</td> 
   <td align="center">JOB_NAME</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">作业组</td> 
   <td align="center">JOB_GROUP</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">描述</td> 
   <td align="center">DESCRIPTION</td> 
   <td align="center">VARCHAR2(250)</td> 
  </tr> 
  <tr> 
   <td align="center">下次执行时间</td> 
   <td align="center">NEXT_FIRE_TIME</td> 
   <td align="center">NUMBER(13)</td> 
  </tr> 
  <tr> 
   <td align="center">前一次执行时间</td> 
   <td align="center">PREV_FIRE_TIME</td> 
   <td align="center">NUMBER(13)</td> 
  </tr> 
  <tr> 
   <td align="center">优先权</td> 
   <td align="center">PRIORITY</td> 
   <td align="center">NUMBER</td> 
  </tr> 
  <tr> 
   <td align="center">触发器状态</td> 
   <td align="center">TRIGGER_STATE</td> 
   <td align="center">VARCHAR2(16)</td> 
  </tr> 
  <tr> 
   <td align="center">触发器类型</td> 
   <td align="center">TRIGGER_TYPE</td> 
   <td align="center">VARCHAR2(8)</td> 
  </tr> 
  <tr> 
   <td align="center">开始时间</td> 
   <td align="center">START_TIME</td> 
   <td align="center">NUMBER(13)</td> 
  </tr> 
  <tr> 
   <td align="center">结束时间</td> 
   <td align="center">END_TIME</td> 
   <td align="center">NUMBER(13)</td> 
  </tr> 
  <tr> 
   <td align="center">日历名称</td> 
   <td align="center">CALENDAR_NAME</td> 
   <td align="center">VARCHAR2(200)</td> 
  </tr> 
  <tr> 
   <td align="center">失败次数</td> 
   <td align="center">MISFIRE_INSTR</td> 
   <td align="center">NUMBER</td> 
  </tr> 
  <tr> 
   <td align="center">作业数据</td> 
   <td align="center">JOB_DATA</td> 
   <td align="center">BLOB</td> 
  </tr> 
 </tbody> 
</table>

Quartz api使用说明我们下一篇文章继续来聊！！！！！！如有收获请关注微信公众号！！！

![微信公众号][format_png 1]

[format_png]: https://imgconvert.csdnimg.cn/aHR0cDovL3FhczU1dTVxbC5ia3QuY2xvdWRkbi5jb20vaW1nL3NwcmluZy1ib290LXF1YXJ0ei5wbmc?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9jZG4uanNkZWxpdnIubmV0L2doL3RyaXVtcGh4eC9teS1pbWFnZXMtaG9zdC9pbWcvJUU1JTg1JUFDJUU0JUJDJTk3JUU1JThGJUI3MS5qcGVn?x-oss-process=image/format,png