结合源码分析在 Quartz 的集群模式中,比较核心的数据库表是哪些?

本文主要是介绍结合源码分析在 Quartz 的集群模式中,比较核心的数据库表是哪些?,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

引言

核心数据表

1. QRTZ_JOB_DETAILS

2. QRTZ_TRIGGERS

3. QRTZ_CRON_TRIGGERS

4. QRTZ_SIMPLE_TRIGGERS

5. QRTZ_SCHEDULER_STATE

源码中的关系示例


引言

        在 Quartz 的集群模式中,核心的数据库表是至关重要的,它们共同协作确保任务调度的信息被正确地管理和同步。主要的表包括 QRTZ_JOB_DETAILS, QRTZ_TRIGGERS, QRTZ_CRON_TRIGGERS, QRTZ_SIMPLE_TRIGGERS, 以及 QRTZ_SCHEDULER_STATE。接下来,我将详细解释这些表之间的关系,并结合源码来分析它们的作用。

核心数据表

1. QRTZ_JOB_DETAILS

这个表存储每个作业的详细信息,它是定义作业的基础。包括:

  • SCHED_NAME:调度器实例的名字。
  • JOB_NAMEJOB_GROUP:标识作业的唯一键。
  • JOB_CLASS_NAME:指定执行作业的 Java 类。
  • IS_DURABLEIS_NONCONCURRENTIS_UPDATE_DATAREQUESTS_RECOVERY:这些列定义作业的性质,如是否持久化、是否避免并发执行等。

2. QRTZ_TRIGGERS

这个表存储所有触发器的基本信息,每个触发器都关联到一个作业。它是调度作业执行的核心。

  • SCHED_NAME:与作业详细信息表中的调度器名称对应。
  • TRIGGER_NAMETRIGGER_GROUP:标识触发器的唯一键。
  • JOB_NAMEJOB_GROUP:与 QRTZ_JOB_DETAILS 表的作业名和组名对应,表明该触发器要触发的作业。
  • DESCRIPTIONNEXT_FIRE_TIMEPREV_FIRE_TIMEPRIORITY:提供触发器的额外信息和调度计划。

3. QRTZ_CRON_TRIGGERS

这个表专门存储使用 Cron 表达式的触发器信息,是 QRTZ_TRIGGERS 的一个扩展,仅适用于 Cron 触发器。

  • SCHED_NAMETRIGGER_NAMETRIGGER_GROUP:与 QRTZ_TRIGGERS 表中的对应列相匹配,确保关联。
  • CRON_EXPRESSION:定义了触发规则的 Cron 表达式。
  • TIME_ZONE_ID:Cron 表达式计算的时区。

4. QRTZ_SIMPLE_TRIGGERS

类似于 QRTZ_CRON_TRIGGERS,这个表存储的是简单触发器的信息,适用于具有固定间隔重复执行的触发器。

  • SCHED_NAMETRIGGER_NAMETRIGGER_GROUP:与 QRTZ_TRIGGERS 表中的对应列相匹配。
  • REPEAT_COUNTREPEAT_INTERVALTIMES_TRIGGERED:定义触发器执行的次数、间隔和已触发次数。

5. QRTZ_SCHEDULER_STATE

这个表为集群模式提供了节点管理的功能,记录每个实例的状态和心跳。

  • SCHED_NAME:调度器的名字。
  • INSTANCE_NAME:集群中的实例名称。
  • LAST_CHECKIN_TIME:最后一次检入时间。
  • CHECKIN_INTERVAL:检查间隔时间。

源码中的关系示例

        在 Quartz 的源码中,特别是在 org.quartz.impl.jdbcjobstore 包中的 JobStoreSupport 类,提供了如何利用这些表的示例。例如,当调度器尝试获取即将执行的触发器时,它会查询 QRTZ_TRIGGERSQRTZ_CRON_TRIGGERSQRTZ_SIMPLE_TRIGGERS 表,以确定下一次触发时间并加载相关的作业详情:

public List<OperableTrigger> acquireNextTriggers(final long noLaterThan, int maxCount, long timeWindow) throws JobPersistenceException {return executeInLock((isLockOnSelect()) ? LOCK_TRIGGER_ACCESS : null,new TransactionCallback<List<OperableTrigger>>() {public List<OperableTrigger> execute(Connection conn) throws JobPersistenceException {...// 此处代码演示如何根据触发时间等参数查询触发器表List<OperableTrigger> triggers = getDelegate().selectTriggersForExecution(...);return triggers;}});
}

        这些表之间的关系确保了 Quartz 能够高效地协调各种调度任务,特别是在多节点集群环境中,确保所有的调度信息能够被正确管理和同步。

这篇关于结合源码分析在 Quartz 的集群模式中,比较核心的数据库表是哪些?的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/945639

相关文章

Java线程池核心参数原理及使用指南

《Java线程池核心参数原理及使用指南》本文详细介绍了Java线程池的基本概念、核心类、核心参数、工作原理、常见类型以及最佳实践,通过理解每个参数的含义和工作原理,可以更好地配置线程池,提高系统性能,... 目录一、线程池概述1.1 什么是线程池1.2 线程池的优势二、线程池核心类三、ThreadPoolE

Springboot请求和响应相关注解及使用场景分析

《Springboot请求和响应相关注解及使用场景分析》本文介绍了SpringBoot中用于处理HTTP请求和构建HTTP响应的常用注解,包括@RequestMapping、@RequestParam... 目录1. 请求处理注解@RequestMapping@GetMapping, @PostMappin

Spring Boot Interceptor的原理、配置、顺序控制及与Filter的关键区别对比分析

《SpringBootInterceptor的原理、配置、顺序控制及与Filter的关键区别对比分析》本文主要介绍了SpringBoot中的拦截器(Interceptor)及其与过滤器(Filt... 目录前言一、核心功能二、拦截器的实现2.1 定义自定义拦截器2.2 注册拦截器三、多拦截器的执行顺序四、过

MySQL快速复制一张表的四种核心方法(包括表结构和数据)

《MySQL快速复制一张表的四种核心方法(包括表结构和数据)》本文详细介绍了四种复制MySQL表(结构+数据)的方法,并对每种方法进行了对比分析,适用于不同场景和数据量的复制需求,特别是针对超大表(1... 目录一、mysql 复制表(结构+数据)的 4 种核心方法(面试结构化回答)方法 1:CREATE

Python中4大日志记录库比较的终极PK

《Python中4大日志记录库比较的终极PK》日志记录框架是一种工具,可帮助您标准化应用程序中的日志记录过程,:本文主要介绍Python中4大日志记录库比较的相关资料,文中通过代码介绍的非常详细,... 目录一、logging库1、优点2、缺点二、LogAid库三、Loguru库四、Structlogphp

JavaWeb项目创建、部署、连接数据库保姆级教程(tomcat)

《JavaWeb项目创建、部署、连接数据库保姆级教程(tomcat)》:本文主要介绍如何在IntelliJIDEA2020.1中创建和部署一个JavaWeb项目,包括创建项目、配置Tomcat服务... 目录简介:一、创建项目二、tomcat部署1、将tomcat解压在一个自己找得到路径2、在idea中添加

Go语言实现桥接模式

《Go语言实现桥接模式》桥接模式是一种结构型设计模式,它将抽象部分与实现部分分离,使它们可以独立地变化,本文就来介绍一下了Go语言实现桥接模式,感兴趣的可以了解一下... 目录简介核心概念为什么使用桥接模式?应用场景案例分析步骤一:定义实现接口步骤二:创建具体实现类步骤三:定义抽象类步骤四:创建扩展抽象类步

Python结合Free Spire.PDF for Python实现PDF页面旋转

《Python结合FreeSpire.PDFforPython实现PDF页面旋转》在日常办公或文档处理中,我们经常会遇到PDF页面方向错误的问题,本文将分享如何用Python结合FreeSpir... 目录基础实现:单页PDF精准旋转完整代码代码解析进阶操作:覆盖多场景旋转需求1. 旋转指定角度(90/27

MySQL MHA集群详解(数据库高可用)

《MySQLMHA集群详解(数据库高可用)》MHA(MasterHighAvailability)是开源MySQL高可用管理工具,用于自动故障检测与转移,支持异步或半同步复制的MySQL主从架构,本... 目录mysql 高可用方案:MHA 详解与实战1. MHA 简介2. MHA 的组件组成(1)MHA

C++ scoped_ptr 和 unique_ptr对比分析

《C++scoped_ptr和unique_ptr对比分析》本文介绍了C++中的`scoped_ptr`和`unique_ptr`,详细比较了它们的特性、使用场景以及现代C++推荐的使用`uni... 目录1. scoped_ptr基本特性主要特点2. unique_ptr基本用法3. 主要区别对比4. u