结合源码分析在 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

相关文章

SQL Server修改数据库名及物理数据文件名操作步骤

《SQLServer修改数据库名及物理数据文件名操作步骤》在SQLServer中重命名数据库是一个常见的操作,但需要确保用户具有足够的权限来执行此操作,:本文主要介绍SQLServer修改数据... 目录一、背景介绍二、操作步骤2.1 设置为单用户模式(断开连接)2.2 修改数据库名称2.3 查找逻辑文件名

SQL Server数据库死锁处理超详细攻略

《SQLServer数据库死锁处理超详细攻略》SQLServer作为主流数据库管理系统,在高并发场景下可能面临死锁问题,影响系统性能和稳定性,这篇文章主要给大家介绍了关于SQLServer数据库死... 目录一、引言二、查询 Sqlserver 中造成死锁的 SPID三、用内置函数查询执行信息1. sp_w

Redis Cluster模式配置

《RedisCluster模式配置》:本文主要介绍RedisCluster模式配置,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录分片 一、分片的本质与核心价值二、分片实现方案对比 ‌三、分片算法详解1. ‌范围分片(顺序分片)‌2. ‌哈希分片3. ‌虚

Python包管理工具核心指令uvx举例详细解析

《Python包管理工具核心指令uvx举例详细解析》:本文主要介绍Python包管理工具核心指令uvx的相关资料,uvx是uv工具链中用于临时运行Python命令行工具的高效执行器,依托Rust实... 目录一、uvx 的定位与核心功能二、uvx 的典型应用场景三、uvx 与传统工具对比四、uvx 的技术实

MyBatis Plus 中 update_time 字段自动填充失效的原因分析及解决方案(最新整理)

《MyBatisPlus中update_time字段自动填充失效的原因分析及解决方案(最新整理)》在使用MyBatisPlus时,通常我们会在数据库表中设置create_time和update... 目录前言一、问题现象二、原因分析三、总结:常见原因与解决方法对照表四、推荐写法前言在使用 MyBATis

Python主动抛出异常的各种用法和场景分析

《Python主动抛出异常的各种用法和场景分析》在Python中,我们不仅可以捕获和处理异常,还可以主动抛出异常,也就是以类的方式自定义错误的类型和提示信息,这在编程中非常有用,下面我将详细解释主动抛... 目录一、为什么要主动抛出异常?二、基本语法:raise关键字基本示例三、raise的多种用法1. 抛

github打不开的问题分析及解决

《github打不开的问题分析及解决》:本文主要介绍github打不开的问题分析及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、找到github.com域名解析的ip地址二、找到github.global.ssl.fastly.net网址解析的ip地址三

java中Optional的核心用法和最佳实践

《java中Optional的核心用法和最佳实践》Java8中Optional用于处理可能为null的值,减少空指针异常,:本文主要介绍java中Optional核心用法和最佳实践的相关资料,文中... 目录前言1. 创建 Optional 对象1.1 常规创建方式2. 访问 Optional 中的值2.1

Mysql的主从同步/复制的原理分析

《Mysql的主从同步/复制的原理分析》:本文主要介绍Mysql的主从同步/复制的原理分析,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录为什么要主从同步?mysql主从同步架构有哪些?Mysql主从复制的原理/整体流程级联复制架构为什么好?Mysql主从复制注意

java -jar命令运行 jar包时运行外部依赖jar包的场景分析

《java-jar命令运行jar包时运行外部依赖jar包的场景分析》:本文主要介绍java-jar命令运行jar包时运行外部依赖jar包的场景分析,本文给大家介绍的非常详细,对大家的学习或工作... 目录Java -jar命令运行 jar包时如何运行外部依赖jar包场景:解决:方法一、启动参数添加: -Xb