QuartzScheduler

官方网站：http://www.quartz-scheduler.org Github：https://github.com/quartz-scheduler/quartz

Quatz 是一个特性丰富的，开源的任务调度库，它几乎可以嵌入所有的 Java 程序，从很小的独立应用程序到大型商业系统。Quartz 可以用来创建成百上千的简单的或者复杂的任务，这些任务可以用来执行任何程序可以做的事情。Quartz 拥有很多企业级的特性，包括支持 JTA 事务和集群。

Quartz 是一个老牌的任务调度系统，98 年构思，01 年发布到 sourceforge。现在更新比较慢，因为已经非常成熟了。Quartz 的目的就是让任务调度更加简单，开发人员只需要关注业务即可。他是用 Java 语言编写的（也有.NET 的版本）。Java 代码能做的任何事情，Quartz 都可以调度。

特点：

精确到毫秒级别的调度
可以独立运行，也可以集成到容器中
支持事务（JobStoreCMT ）
支持集群
支持持久化

Quartz的基本使用

引入依赖：

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

编写代码：

// 创建调度器，用于调度任务，调度器内部拥有一个任务计划表，调度器在这个表里面对各个job任务进行时间分配
SchedulerFactory sfact = new StdSchedulerFactory();
Scheduler schedule = sfact.getScheduler();
// 创建TestJob，用于定义调度程序具体执行的工作内容
public class TestJob implements Job{

    public void execute(JobExecutionContext arg0) throws JobExecutionException {
            
            Date date=new Date();
            SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            System.out.print("now:"+sf.format(date));

    }
}
// 创建JobDetail的实例，对job进行进一步封装，增加一些原信息，比如name和group；还可以传一些kv参数给job
JobDetail jobDetail1 = JobBuilder.newJob((Class<? extends Job>) TestJob.class) //定义Job类为TestJob类
                .withIdentity("myjob1", "group1") //定义name、group
                .build();
// 创建触发器，触发器是一个时间规则
CronTrigger trigger1 =(CronTrigger) TriggerBuilder.newTrigger()
                .withIdentity("trigger1", "group1")
                .withSchedule(CronScheduleBuilder.cronSchedule("0 0 10 ? * MON")) //每周一造成10点执行
                .build();
// 给调度器的计划表增加一条计划，让jobDetail1在trigger1时间点运行任务
schedule.scheduleJob(jobDetail1, trigger1);

// 启动调度器开始执行任务
schedule.start();

Quartz的体系结构

Trigger

触发器是用于触发任务的时间规则，Trigger类使用TriggerBuilder构建，Trigger 接口在 Quartz 有 4 个继承的子接口：

子接口

描述

特点

SimpleTrigger

简单触发器

固定时刻或时间间隔，毫秒

CalendarIntervalTrigger

基于日历的触发器

比简单触发器更多时间单位，支持非固定时间的触发，例如一年可能 365/366，一个月可能 28/29/30/31

DailyTimeIntervalTrigger

基于日期的触发器

每天的某个时间

CronTrigger

基于 Cron 表达式的触发器

JobDetail

JobDetail代表一个具体的任务，他由JobBuilder构建。JobBuilder使用关联对象Job（任务模板）以及JobDataMap 模板参数，具体构建一个任务对象。

Scheduler

调度器由SchedulerFactory创建，创建出的调度器都是单例的。调度器调度任务需要两个对象：JobDetail和Trigger，调度器会在对应的时间点执行任务。

Scheduler中的方法主要分为三大类：

操作调度器本身，例如调度器的启动start()、调度器的关闭shutdown()。
操作Trigger，例如pauseTriggers()、resumeTrigger()。
操作Job，例如scheduleJob()、unscheduleJob()、rescheduleJob()

Listener

Listener是用于监听任务生命周期的监听器。他通过观察者模式，监听Scheduler、Trigger、JobDeatil。

通常使用Listener监听任务的执行状态，然后做出相关的业务操作或者通知。

TriggerListener

方法

作用或执行实际

getName()

返回监听器的名称

triggerFired()

Trigger 被触发，Job 上的 execute() 方法将要被执行时，Scheduler 就调用这个方法

vetoJobExecution()

在 Trigger 触发后，Job 将要被执行时由 Scheduler 调用这个方法。TriggerListener 给了一个选择去否决 Job 的执行。假如这个方法返回 true，这个 Job 将不会为此次 Trigger 触发而得到执行

triggerMisfired()

Trigger 错过触发时调用

triggerComplete()

Trigger 被触发并且完成了 Job 的执行时，Scheduler 调用这个方法

JobListener

SchedulerListener

JobStore

RAMJobStore

JDBCJobStore

Quartz的配置文件

org.quartz.core 包下，有一个默认的配置文件，quartz.properties。当我们没有定义一个同名的配置文件的时候，就会使用默认配置文件里面的配置，他的默认配置如下：

org.quartz.scheduler.instanceName: DefaultQuartzScheduler 
org.quartz.scheduler.rmi.export: false 
org.quartz.scheduler.rmi.proxy: false 
org.quartz.scheduler.wrapJobExecutionInUserTransaction: false org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool 
org.quartz.threadPool.threadCount: 10 
org.quartz.threadPool.threadPriority: 5 org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true org.quartz.jobStore.misfireThreshold: 60000 
org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore

如果要修改上述中的配置，可以在resource下，建立一个同包名，同文件名的配置文件，以覆盖默认的配置。

上一页任务调度下一页Elastic-Job

最后更新于9个月前

这有帮助吗？