Quartz任务调度框架（1）

2021-04-25 13:32:48 阅读：221 来源： 互联网

标签：存储 Quartz 框架 triggers 任务调度 Trigger quartz org qrtz

Quartz任务调度框架

一、简介

1.介绍

Quartz是功能强大的开源作业调度库，几乎可以集成到任何Java应用程序中-从最小的独立应用程序到最大的电子商务系统。Quartz可用于创建简单或复杂的计划，以执行数以万计，数以万计的工作。任务定义为标准Java组件的作业，它们实际上可以执行您可以编写的所有内容。Quartz Scheduler包含许多企业级功能，例如对JTA事务和集群的支持。Quartz是免费使用的。

2.定时器种类

SimpleTrigger，CronTirgger，DateIntervalTrigger，NthIncludedDayTrigger和Calendar 类（ org.quartz.Calendar）。

最常用的：

SimpleTrigger：用来触发只执行一次或者在给定时间触发并且触发N次且每次执行延迟一定时间的任务。

CronTrigger：按照日历触发，例如“每个周五”，每个月10号上午10.15

3.存储方式

RAMJobStore(随机存储内存)和JDBCJobStore(数据库存储)

对比

4.表关系和解释

表关系

解释

qrzt_blob_triggers	tigger作为Blob类型存储（用户trigger用户用jdbc创建他们自己定制的tigger类型，jobStore并不知道如何存储实例的时候）
qrzt_calendars	以Blob类型存储Quartz的日历信息，quartz可配置一个日历来指定一个时间范围
qrzt_cron_triggers	存储Corn Trigger,包括Corn表达式和时区信息
qrtz_fired_triggers	存储已经触发的Trigger相关的状态信息，以及相关联Job的执行信息
qrtz_job_details	存储每一个已经配置的job的详细信息
qrtz_locks	存储程序的悲观锁的信息（如果使用了悲观锁）
qrtz_paused_trigger_graps	存储已经暂停的Trigger组的信息
qrtz_scheduler_state	存储了少量的有关Scheduler的状态信息，和别的Scheduler实例（假如是用作一个集群）
qrtz_simple_triggers	存储简单的trigger，包括重复次数，间隔，以及触发的次数
qrtz_triggers	存储已经配置的trigger信息
qrzt_simprop_triggers	存储简单触发器的信息

5.核心类和关系

核心类

QuartzSchedulerThread ：负责执行向QuartzScheduler注册的触发Trigger的工作的线程。

ThreadPool：Scheduler使用一个线程池作为任务运行的基础设施，任务通过共享线程池中的线程提供运行效率。

QuartzSchedulerResources：包含创建QuartzScheduler实例所需的所有资源（JobStore，ThreadPool等）。

SchedulerFactory ：提供用于获取调度程序实例的客户端可用句柄的机制。

JobStore：通过类实现的接口，这些类要为org.quartz.core.QuartzScheduler的使用提供一个org.quartz.Job和org.quartz.Trigger存储机制。作业和触发器的存储应该以其名称和组的组合为唯一性。QuartzScheduler ：这是Quartz的核心，它是org.quartz.Scheduler接口的间接实现，包含调度org.quartz.Jobs，注册org.quartz.JobListener实例等的方法。

Scheduler ：这是Quartz Scheduler的主要接口，代表一个独立运行容器。调度程序维护JobDetails和触发器的注册表。一旦注册，调度程序负责执行作业，当他们的相关联的触发器触发（当他们的预定时间到达时）。

Trigger ：具有所有触发器通用属性的基本接口，描述了job执行的时间出发规则。 - 使用TriggerBuilder实例化实际触发器。JobDetail ：传递给定作业实例的详细信息属性。 JobDetails将使用JobBuilder创建/定义。

Job：要由表示要执行的“作业”的类实现的接口。只有一个方法 void execute(jobExecutionContext context)(jobExecutionContext 提供调度上下文各种信息，运行时数据保存在jobDataMap中)Job有个子接口StatefulJob ,代表有状态任务。有状态任务不可并发，前次任务没有执行完，后面任务处于阻塞。

关系

一个job可以绑定多个Trigger,但是一个Trigger只能绑定一个job

6.配置文件

quartz.properties

//调度标识名集群中每一个实例都必须使用相同的名称（区分特定的调度器实例）

org.quartz.scheduler.instanceName：DefaultQuartzScheduler

//ID设置为自动获取每一个必须不同（所有调度器实例中是唯一的）

org.quartz.scheduler.instanceId ：AUTO

//数据保存方式为持久化

org.quartz.jobStore.class ：org.quartz.impl.jdbcjobstore.JobStoreTX

//表的前缀

org.quartz.jobStore.tablePrefix ： QRTZ_

//设置为TRUE不会出现序列化非字符串类到 BLOB 时产生的类版本问题

org.quartz.jobStore.useProperties ： true

//加入集群 true 为集群 false不是集群

org.quartz.jobStore.isClustered ： false

//调度实例失效的检查时间间隔

org.quartz.jobStore.clusterCheckinInterval：20000

//容许的最大作业延长时间

org.quartz.jobStore.misfireThreshold ：60000

//ThreadPool 实现的类名

org.quartz.threadPool.class：org.quartz.simpl.SimpleThreadPool

//线程数量

org.quartz.threadPool.threadCount ： 10

//线程优先级 org.quartz.threadPool.threadPriority ： 5（threadPriority 属性的最大值是常量 java.lang.Thread.MAX_PRIORITY，等于10。最小值为常量 java.lang.Thread.MIN_PRIORITY，为1）

//自创建父线程

org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread： true

//数据库别名 org.quartz.jobStore.dataSource ： qzDS

//设置数据源

org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver

org.quartz.dataSource.qzDS.URL:jdbc:mysql://localhost:3306/quartz

org.quartz.dataSource.qzDS.user:root org.quartz.dataSource.qzDS.password:123456

org.quartz.dataSource.qzDS.maxConnection:10

7.JDBC插入表顺序

主要的JDBC操作类，执行sql顺序。

Simple_trigger ：插入顺序qrtz_job_details —> qrtz_triggers —> qrtz_simple_triggers qrtz_fired_triggers

Cron_Trigger：插入顺序qrtz_job_details —> qrtz_triggers —> qrtz_cron_triggers qrtz_fired_triggers

二、示例

package com.hgc.zm;

import lombok.extern.slf4j.Slf4j;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

import java.util.Date;

/**
 * @author zm
 * @version 1.0
 * @date 2021/4/25 11:58
 */
@Slf4j
public class RAMQuartz {


    public static void main(String[] args) throws SchedulerException {

        //1.创建Scheduler的工厂
        SchedulerFactory sf = new StdSchedulerFactory();
        //2.从工厂中获取调度器实例
        Scheduler scheduler = sf.getScheduler();


        //3.创建JobDetail
        JobDetail jb = JobBuilder.newJob(RAMJob.class)
                .withDescription("this is a ram job") //job的描述
                .withIdentity("ramJob", "ramGroup") //job 的name和group
                .build();
        //任务运行的时间，SimpleSchedle类型触发器有效
        long time=  System.currentTimeMillis() + 3*1000L; //3秒后启动任务
        Date statTime = new Date(time);
        //4.创建Trigger
        //使用SimpleScheduleBuilder或者CronScheduleBuilder
        Trigger t = TriggerBuilder.newTrigger()
                .withDescription("this is a trigger")
                .withIdentity("ramTrigger", "ramTriggerGroup")
                //.withSchedule(SimpleScheduleBuilder.simpleSchedule())
                .startAt(statTime)  //默认当前时间启动
                .withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ?")) //2秒执行一次
                .build();

        //5.注册任务和定时器
        scheduler.scheduleJob(jb, t);

        //6.启动 调度器
        scheduler.start();
        log.info("启动时间 ： " + new Date());
    }
}


package com.hgc.zm;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

/**
 * @author zm
 * @version 1.0
 * @date 2021/4/25 12:42
 */
public class RAMJob implements Job {
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        System.err.println("Say hello to Quartz " + System.currentTimeMillis());
    }
}

标签：存储,Quartz,框架,triggers,任务调度,Trigger,quartz,org,qrtz
来源： https://www.cnblogs.com/zhangmeng0726/p/14699910.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9