quartz mysql索引_Quartz数据库表分析

谁借莪１个温暖的怀抱￠ 2023-01-12 01:59 149阅读 0赞

前言

上一篇文章Spring整合Quartz分布式调度介绍了Quartz通过数据库的方式来实现分布式调度，通过使用数据库来存储trigger，job等信息，可以在停服重启的时候重新加载上次trigger的状态，保证了完整性；另一方面通过数据库来实现锁机制来实现分布式调度；Quartz默认提供了11张表，本文将对这几张表做简要的分析。

表信息

1.qrtz\_blob\_triggers

2.qrtz\_cron\_triggers

3.qrtz\_simple\_triggers

4.qrtz\_simprop\_triggers

5.qrtz\_fired\_triggers

6.qrtz\_triggers

7.qrtz\_job\_details

8.qrtz\_calendars

9.qrtz\_paused\_trigger\_grps

10.qrtz\_scheduler\_state

11.qrtz\_locks

共11张表，前6张都是关于各种triggers的信息，后面包括job，悲观锁，调度状态等信息；相关表操作在类StdJDBCDelegate中，相关sql语句在StdJDBCConstants中；

1.qrtz\_blob\_triggers

自定义的triggers使用blog类型进行存储，非自定义的triggers不会存放在此表中，Quartz提供的triggers包括：CronTrigger，CalendarIntervalTrigger，

DailyTimeIntervalTrigger以及SimpleTrigger，这几个trigger信息会保存在后面的几张表中；

2.qrtz\_cron\_triggers

存储CronTrigger，这也是我们使用最多的触发器，在配置文件中做如下配置，即可在qrtz\_cron\_triggers生成记录：

class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">

class="org.springframework.scheduling.quartz.JobDetailFactoryBean">

表达式指定了每隔6秒执行一次，然后指定了要执行的task，task指定了要执行的业务，运行之后可以查看数据表：

mysql> select \* from qrtz\_cron\_triggers;

\+-------------+------------------+----------------+-----------------+---------------+

\+-------------+------------------+----------------+-----------------+---------------+

\+-------------+------------------+----------------+-----------------+---------------+

myScheduler是在定义SchedulerFactoryBean时指定的名称，其他字段都可以在上面的配置中找到；

3.qrtz\_simple\_triggers

存储SimpleTrigger，在配置文件中做如下配置，即可在qrtz\_simple\_triggers生成记录：

class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">

class="org.springframework.scheduling.quartz.JobDetailFactoryBean">

指定了开始延迟时间，重复间隔时间已经重复的次数限制，查看表如下：

mysql> select \* from qrtz\_simple\_triggers;

\+-------------+--------------------+------------------+--------------+-----------------+-----------------+

\+-------------+--------------------+------------------+--------------+-----------------+-----------------+

| myScheduler | firstSimpleTrigger | firstSimpleGroup | 5 | 2000 | 1 |

\+-------------+--------------------+------------------+--------------+-----------------+-----------------+

TIMES\_TRIGGERED用来记录执行了多少次了，此值被定义在SimpleTriggerImpl中，每次执行+1，这里定义的REPEAT\_COUNT=5，实际情况会执行6次，具体可以查看SimpleTriggerImpl源码：

public Date getFireTimeAfter(Date afterTime) \{

if (complete) \{

return null;

if ((timesTriggered > repeatCount)

&& (repeatCount != REPEAT\_INDEFINITELY)) \{

return null;

......

timesTriggered默认值为0，当timesTriggered > repeatCount停止trigger，所以会执行6次，当执行完毕之后此记录会被删除；

4.qrtz\_simprop\_triggers

存储CalendarIntervalTrigger和DailyTimeIntervalTrigger两种类型的触发器，使用CalendarIntervalTrigger做如下配置：

class="org.springframework.scheduling.quartz.JobDetailFactoryBean">

CalendarIntervalTrigger没有对应的FactoryBean，直接设置实现类CalendarIntervalTriggerImpl；指定的重复周期是1，默认单位是天，也就是每天执行一次，查看表如下：

mysql> select \* from qrtz\_simprop\_triggers;

\+-------------+--------------------+--------------------+------------+---------------+------------+------------+------------+-------------+-------------+------------+------------+-------------+-------------+

| myScheduler | calendarTriggerKey | firstCalendarGroup | DAY | Asia/Shanghai | NULL | 1 | 1 | 0 | 0 | NULL | NULL | 0 | 0 |

提供了3个string类型的参数，2个int类型的参数，2个long类型的参数，2个decimal类型的参数以及2个boolean类型的参数；具体每个参数是什么含义，根据不同的trigger类型存放各自的参数；

5.qrtz\_fired\_triggers

存储已经触发的trigger相关信息，trigger随着时间的推移状态发生变化，直到最后trigger执行完成，从表中被删除；已SimpleTrigger为例重复3次执行，查询表：

mysql> select \* from qrtz\_fired\_triggers;

\+-------------+----------------------------------------+--------------------+------------------+---------------------------+---------------+---------------+----------+-----------+-----------------+-----------+------------------+-------------------+

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

6.qrtz\_triggers

存储定义的trigger，以上定义的三个triggers为例，分别是：firstSimpleTrigger，firstCalendarTrigger和firstCronTrigger，运行之后查看数据库：

mysql> select \* from qrtz\_triggers;

\+-------------+--------------------+--------------------+-------------------+-----------+-------------+----------------+----------------+----------+---------------+--------------+---------------+----------+---------------+---------------+----------+

和qrtz\_fired\_triggers存放的不一样，不管trigger触发了多少次都只有一条记录，TRIGGER\_STATE用来标识当前trigger的状态；firstCalendarTask每天执行一次，执行完之后一直是WAITING状态；firstCronTrigger每6秒执行一次状态是ACQUIRED状态；firstSimpleTrigger重复执行6次后状态为COMPLETE，并且会被删除；

7.qrtz\_job\_details

存储jobDetails信息，相关信息在定义的时候指定，如上面定义的JobDetailFactoryBean，查询数据库：

mysql> select \* from qrtz\_job\_details;

\+-------------+-------------------+-----------+-------------+-----------------------------------------+------------+------------------+----------------+-------------------+----------+

\+-------------+-------------------+-----------+-------------+-----------------------------------------+------------+------------------+----------------+-------------------+----------+

| myScheduler | firstCalendarTask | DEFAULT | NULL | zh.maven.SQuartz.task.CalendarFirstTask | 0 | 0 | 0 | 0 | |

| myScheduler | firstSimpleTask | DEFAULT | NULL | zh.maven.SQuartz.task.SimpleFirstTask | 0 | 0 | 0 | 0 | |

| myScheduler | firstTask | DEFAULT | NULL | zh.maven.SQuartz.task.FirstTask | 0 | 0 | 0 | 0 | |

\+-------------+-------------------+-----------+-------------+-----------------------------------------+------------+------------------+----------------+-------------------+----------+

JOB\_DATA存放的就是定义task时指定的jobDataMap属性，所以此属性需要实现Serializable接口，方便持久化到数据库；

8.qrtz\_calendars

Quartz为我们提供了日历的功能，可以自己定义一个时间段，可以控制触发器在这个时间段内触发或者不触发；现在提供6种类型：AnnualCalendar，CronCalendar，DailyCalendar，HolidayCalendar，MonthlyCalendar，WeeklyCalendar；以下使用CronCalendar为例：

class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">

class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

定义了一个排除每隔5秒的CronCalendar，然后在firstCronTrigger中指定了calendarName，并且需要在SchedulerFactoryBean中定义calendars；因为firstCronTrigger每6秒执行一次，而CronCalendar排除每隔5秒，所以会出现firstCronTrigger在第5次触发的时候需要等待12秒，结果如下：

20180419 15:09:06---start FirstService

20180419 15:09:08---end FirstService

20180419 15:09:12---start FirstService

20180419 15:09:14---end FirstService

20180419 15:09:18---start FirstService

20180419 15:09:20---end FirstService

20180419 15:09:24---start FirstService

20180419 15:09:26---end FirstService

20180419 15:09:36---start FirstService

20180419 15:09:38---end FirstService

查询保存在数据中的CronCalendar：

mysql> select \* from qrtz\_calendars;

\+-------------+---------------+----------+

| SCHED\_NAME | CALENDAR\_NAME | CALENDAR |

\+-------------+---------------+----------+

| myScheduler | firstCalendar | |

\+-------------+---------------+----------+

CALENDAR存放的是CronCalendar序列化之后的数据；

9.qrtz\_paused\_trigger\_grps

存放暂停掉的触发器，测试手动暂停firstCronTrigger，代码如下：

public class App \{

public static void main(String\[\] args) \{

final AbstractApplicationContext context = new ClassPathXmlApplicationContext("quartz.xml");

final StdScheduler scheduler = (StdScheduler) context.getBean("scheduler");

try \{

Thread.sleep(4000);

scheduler.pauseTriggers(GroupMatcher.triggerGroupEquals("firstCronGroup"));

\} catch (Exception e) \{

e.printStackTrace();

启动之后延迟4秒后暂停firstCronTrigger，这里传递的参数group，然后查看数据库：

mysql> select \* from qrtz\_paused\_trigger\_grps;

\+-------------+----------------+

| SCHED\_NAME | TRIGGER\_GROUP |

\+-------------+----------------+

| myScheduler | firstCronGroup |

\+-------------+----------------+

因为已经入库，所以重启之后firstCronGroup还是处于暂停状态，firstCronTrigger不会运行；

10.qrtz\_scheduler\_state

存储所有节点的scheduler，会定期检查scheduler是否失效，启动多个scheduler，查询数据库：

mysql> select \* from qrtz\_scheduler\_state;

\+-------------+---------------------------+-------------------+------------------+

\+-------------+---------------------------+-------------------+------------------+

| myScheduler | NJD9YZGJ2-PC1524209095408 | 1524209113973 | 1000 |

| myScheduler | NJD9YZGJ2-PC1524209097649 | 1524209113918 | 1000 |

\+-------------+---------------------------+-------------------+------------------+

记录了最后最新的检查时间，在quartz.properties中设置了CHECKIN\_INTERVAL为1000，也就是每秒检查一次；

11.qrtz\_locks

Quartz提供的锁表，为多个节点调度提供分布式锁，实现分布式调度，默认有2个锁：

mysql> select \* from qrtz\_locks;

\+-------------+----------------+

| SCHED\_NAME | LOCK\_NAME |

\+-------------+----------------+

| myScheduler | STATE\_ACCESS |

| myScheduler | TRIGGER\_ACCESS |

\+-------------+----------------+

STATE\_ACCESS主要用在scheduler定期检查是否失效的时候，保证只有一个节点去处理已经失效的scheduler；

TRIGGER\_ACCESS主要用在TRIGGER被调度的时候，保证只有一个节点去执行调度；

总结

本文对这11张表做了简要的分析，介绍了每张表具体是用来存储什么的，并且给了简单的实例；其实如果要实现一个trigger的管理系统，其实也就是对这几张表的维护。

quartz mysql索引_Quartz数据库表分析

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 SpringBoot 集成 Quartz + MySQL

相关 quartz mysql索引_Quartz数据库表分析

相关 Quartz 源码分析

相关 quartz

相关 quartz学习-quartz框架依赖表脚本

相关 quartz

相关 quartz

相关 quartz(一)、quartz 数据库表

相关 quartz

相关 Quartz