Quartz作业调度入门

摘要: 本文记录、介绍了如何搭建一个简单的Quartz作业调度程序，这里采用quartz.properties文件配置，使用简单触发器触发的方式。入门为主，力求简单。

先贴出一些优秀的参考资料：

Quartz Quick Start Guide

用 Quartz 进行作业调度

Quartz 是个开源的作业调度框架，为在 Java 应用程序中进行作业调度提供了简单却强大的机制，其托管在github的地址为：https://github.com/quartz-scheduler/quartz。

一.引入Quartz的jar包

我们一贯采用maven的方式来引入jar包，包括quartz和logback（方便看日志），pom文件里的配置为：

<dependencies>
<!-- quartz -->
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.1</version>
</dependency>

<!-- log -->
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.1.0</version>
</dependency>
</dependencies>

二.配置quartz.properties文件

Quartz的优点之一是没有Spring也可以使用，这里就采用quartz.properties配置文件的方式，Quartz with Spring的方式不在本文讨论范围内。以下是最基本的配置：

org.quartz.scheduler.instanceName = MyScheduler
org.quartz.threadPool.threadCount = 3
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

其中，org.quartz.scheduler.instanceName配置调度器的名称，这里为MyScheduler；

org.quartz.threadPool.threadCount是线程池中job的数目，即允许同时运行的job的最大数目，这是是3；

org.quartz.jobStore.class指定Quartz的数据（job及trigger的信息）存储位置，RamJobStore指内存。

三.程序代码

package prep.qing.great.job;

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

public class QuartzTest {

public static void main(String[] args) {
try {
// 从StdSchedulerFactory工厂中获取一个任务调度器
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

// 启动调度器
scheduler.start();

// 关闭调度器
scheduler.shutdown();
} catch (SchedulerException e) {
e.printStackTrace();
}
}
}

运行之后，控制台输出

14:14:37.168 [main] INFO org.quartz.impl.StdSchedulerFactory - Using default implementation for ThreadExecutor
14:14:37.181 [main] INFO org.quartz.simpl.SimpleThreadPool - Job execution threads will use class loader of thread: main
14:14:37.199 [main] INFO o.quartz.core.SchedulerSignalerImpl - Initialized Scheduler Signaller of type: class org.quartz.core.SchedulerSignalerImpl
14:14:37.200 [main] INFO org.quartz.core.QuartzScheduler - Quartz Scheduler v.2.2.1 created.
14:14:37.201 [main] INFO org.quartz.simpl.RAMJobStore - RAMJobStore initialized.
14:14:37.202 [main] INFO org.quartz.core.QuartzScheduler - Scheduler meta-data: Quartz Scheduler (v2.2.1) 'DefaultQuartzScheduler' with instanceId 'NON_CLUSTERED'
Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
NOT STARTED.
Currently in standby mode.
Number of jobs executed: 0
Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 10 threads.
Using job-store 'org.quartz.simpl.RAMJobStore' - which does not support persistence. and is not clustered.

14:14:37.202 [main] INFO org.quartz.impl.StdSchedulerFactory - Quartz scheduler 'DefaultQuartzScheduler' initialized from default resource file in Quartz package: 'quartz.properties'
14:14:37.202 [main] INFO org.quartz.impl.StdSchedulerFactory - Quartz scheduler version: 2.2.1
14:14:37.203 [main] INFO org.quartz.core.QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED started.
14:14:37.203 [main] INFO org.quartz.core.QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED shutting down.
14:14:37.203 [DefaultQuartzScheduler_QuartzSchedulerThread] DEBUG o.quartz.core.QuartzSchedulerThread - batch acquisition of 0 triggers
14:14:37.203 [main] INFO org.quartz.core.QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED paused.
14:14:37.203 [main] DEBUG org.quartz.simpl.SimpleThreadPool - Shutting down threadpool...
14:14:37.203 [main] DEBUG org.quartz.simpl.SimpleThreadPool - Shutdown of threadpool complete.
14:14:37.203 [main] INFO org.quartz.core.QuartzScheduler - Scheduler DefaultQuartzScheduler_$_NON_CLUSTERED shutdown complete.

上面的例子比较简单，只有调度器，并没有执行作业。我们知道，Quartz 调度包的两个基本单元是作业和触发器。作业 是能够调度的可执行任务，触发器 提供了对作业的调度。

下面我们编写一个作业，用于输出当前时间，与这个job的jobName和所属的jobGroup。

package prep.qing.great.job;

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

import java.text.SimpleDateFormat;
import java.util.Date;

public class FirstJob implements Job {

@Override
public void execute(JobExecutionContext context) throws JobExecutionException {

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
System.out.println("(" + context.getJobDetail().getKey().getName() + ","
+ context.getJobDetail().getKey().getGroup() + ") run at "
+ sdf.format(new Date())
);
}
}

上面的示例，通过实现

org.quartz.job

接口，覆盖

execute(JobExecutionContext context)

方法，构建了一个简单的作业。

接下来，我们可以在之前QuartzTest的start()和shutdown()函数中增加作业的调度和触发器等。

package prep.qing.great.job;

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

import java.util.concurrent.TimeUnit;

public class QuartzTest {
public static void main(final String[] args) {
try {

// 从StdSchedulerFactory工厂中获取一个任务调度器
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

// 启动调度器
scheduler.start();

// 具体任务
JobDetail job = JobBuilder.newJob(FirstJob.class).withIdentity("job1", "group1").build();

// 定义Trigger，使得job现在就运行，并每隔5s中运行一次，重复
SimpleScheduleBuilder simpleSchedule = SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(5).repeatForever();

Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1")
.startNow().withSchedule(simpleSchedule).build();

// 交由Scheduler安排触发
scheduler.scheduleJob(job, trigger);

// 为观察程序运行，此设置主程序睡眠3分钟才继续往下运行(因下一个步骤是“关闭Scheduler”)
try {
TimeUnit.MINUTES.sleep(3);
} catch (InterruptedException e) {
e.printStackTrace();
}

// 关闭调度器
scheduler.shutdown();

} catch (SchedulerException e) {
e.printStackTrace();
}
}
}