Biegral Blog

（二）Quartz配置详解

（三）Quartz持久化

一、Quartz概述

Quartz是一个完全由Java编写的开源作业调度框架，为在Java应用程序中进行作业调度提供了简单却强大的机制。Quartz允许开发人员根据一定的时间间隔来调度作业。我学一样东西，从来都是从实践出发，边用边学，用起来自然就学会了。

二、使用Quartz

1、Quartz Jar

我推荐大家使用Maven来加入Jar依赖，方便而且可以对依赖有效地管理。

<dependency>
<span style="white-space:pre">	</span><groupId>org.quartz-scheduler</groupId>
	<artifactId>quartz</artifactId>
	<version>2.2.1</version>
</dependency>

我们开发不光要考虑功能的实现，还要考虑效率、耦合程度与开闭性等问题，可根据实际情况应用恰当的设计模式。回归正题：

下面这个例子很好的覆盖了Quartz最重要的4个基本要素（考验英语水平的时候到了~(>_<)~）：

Scheduler：调度器，所有的作业调度都是由它控制。

Trigger： 触发器，定义触发的条件。例子中，它的类型是CronTrigger，是常见的几种触发器类型中最强大、最灵活的一类，但不要害怕，它并不是很复杂，只是多了一个Cron表达式，会在下面说到。

JobDetail： 任务细节，定义作业的标识与携带的数据。

Job：执行类，实现org.quartz.Job的接口，实现excute方法，作为作业执行体。

注意：作业真正的执行逻辑是在Job实现类中，为什么设计成JobDetail + Job结构，不直接使用Job？这是因为作业是有可能并发执行，如果Scheduler直接调度Job，就会存在对同一个Job实例并发访问的问题。而JobDetail + Job 方式，sheduler每次执行都会根据JobDetail创建一个新的Job实例，这样就可以规避并发访问的问题。

实现类代码（测试绝对可用，jar包正确导入，复制两个类，即可运行^_^）：

<span style="font-size:14px;">public class JobExcuteClass implements org.quartz.Job{
	//实现excute方法
	@Override
	public void execute(JobExecutionContext context) {
		//通过context上下文对象获得map中的Job数据
		JobDataMap map = context.getJobDetail().getJobDataMap();
		String jobName = (String)map.get("jobName");
		System.out.println(jobName + "执行");
	}
}</span>

<span style="font-size:14px;">public class JobUtil {

	//声明调度器对象
	private static Scheduler scheduler = null;
	//Job组名
	public static String GroupName = "JobsGroup";
	
	//创建调度器对象
	private static Scheduler createScheduler() throws SchedulerException { 
		SchedulerFactory schedulerFactory = new StdSchedulerFactory();
		return schedulerFactory.getScheduler();
	}
	
	//为调度器添加调度任务
	public static void addJod(String jobName) throws SchedulerException{
		//用于给Job实现类的excute方法传递数据
		JobDataMap map = new JobDataMap();
		map.put("jobName", jobName);
		//创建JobDetail对象
		//设定Job执行类，设定Job标识，设定数据map
		JobDetail myJob = newJob(JobExcuteClass.class)
				.withIdentity(jobName, GroupName)
				.usingJobData(map)
				.build();
		//执行策略，Cron表达式，代表十秒执行一次
		String strategy = "0/10 0/1 0/1 1/1 * ?";
		//创建触发器，应用策略
		CronTrigger trigger = newTrigger()
				.withSchedule(cronSchedule(strategy))
				.build();
		//创建调度器对象
		scheduler = createScheduler();
		//启动调度器
		scheduler.start();
		//将myJob对象与trigger对象加入调度器
		scheduler.scheduleJob(myJob, trigger);
	}

	//停止调度任务
	public static void removeJob(String jobName) throws SchedulerException {
		//Job标识对象
		JobKey key = new JobKey(jobName, GroupName);
		//注意这里一定要再次创建调度器对象，否则涉及持久化时，会抛出空指针异常
		scheduler = createScheduler();
		//从调度器中移除任务
		scheduler.deleteJob(key);
	}	
	
	//test
	public static void main(String[] args) throws SchedulerException{
		JobUtil.addJod("testQuartz");
	}
}</span>

透过实例看本质，可以总结出Quartz的工作原理（转自熔岩大神的博客，说的比较好理解）：

1、scheduler是一个计划调度器容器（总部），容器里面可以盛放众多的JobDetail和trigger，当容器启动后，里面的每个JobDetail都会根据trigger按部就班自动去执行。
 
2、JobDetail是一个可执行的工作，它本身可能是有状态的。
 
3、Trigger代表一个调度参数的配置，什么时候去调。
 
4、当JobDetail和Trigger在scheduler容器上注册后，形成了装配好的作业（JobDetail和Trigger所组成的一对儿），就可以伴随容器启动而调度执行了。
 
5、scheduler是个容器，容器中有一个线程池，用来并行调度执行每个作业，这样可以提高容器效率。
 
6、将上述的结构用一个图来表示，如下：
 

关于Trigger实现类（转载自：http://www.cnblogs.com/drift-ice/p/3817269.html，这篇文章里还有很多Quartz组件详解、写的很详细，就不赘述了）

Quartz有以下几种Trigger实现:

SimpleTrigger

指定从某一个时间开始，以一定的时间间隔（单位是毫秒）执行的任务。

它适合的任务类似于：9:00 开始，每隔1小时，执行一次。

它的属性有：

• repeatInterval 重复间隔
• repeatCount 重复次数。实际执行次数是 repeatCount+1。因为在startTime的时候一定会执行一次。** 下面有关repeatCount 属性的都是同理。　**

例子：

simpleSchedule()
        .withIntervalInHours(1) //每小时执行一次
        .repeatForever() //次数不限
        .build();

simpleSchedule()
    .withIntervalInMinutes(1) //每分钟执行一次
    .withRepeatCount(10) //次数为10次
    .build();

CalendarIntervalTrigger

类似于SimpleTrigger，指定从某一个时间开始，以一定的时间间隔执行的任务。 但是不同的是SimpleTrigger指定的时间间隔为毫秒，没办法指定每隔一个月执行一次（每月的时间间隔不是固定值），而CalendarIntervalTrigger支持的间隔单位有秒，分钟，小时，天，月，年，星期。

相较于SimpleTrigger有两个优势：1、更方便，比如每隔1小时执行，你不用自己去计算1小时等于多少毫秒。 2、支持不是固定长度的间隔，比如间隔为月和年。但劣势是精度只能到秒。

它适合的任务类似于：9:00 开始执行，并且以后每周 9:00 执行一次

它的属性有:

• interval 执行间隔
• intervalUnit 执行间隔的单位（秒，分钟，小时，天，月，年，星期）

例子:

calendarIntervalSchedule()
    .withIntervalInDays(1) //每天执行一次
    .build();

calendarIntervalSchedule()
    .withIntervalInWeeks(1) //每周执行一次
    .build();

DailyTimeIntervalTrigger

指定每天的某个时间段内，以一定的时间间隔执行任务。并且它可以支持指定星期。

它适合的任务类似于：指定每天9:00 至 18:00 ，每隔70秒执行一次，并且只要周一至周五执行。

它的属性有:

• startTimeOfDay 每天开始时间
• endTimeOfDay 每天结束时间
• daysOfWeek 需要执行的星期
• interval 执行间隔
• intervalUnit 执行间隔的单位（秒，分钟，小时，天，月，年，星期）
• repeatCount 重复次数

例子:

dailyTimeIntervalSchedule()
    .startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0)) //第天9：00开始
    .endingDailyAt(TimeOfDay.hourAndMinuteOfDay(16, 0)) //16：00 结束 
    .onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五执行
    .withIntervalInHours(1) //每间隔1小时执行一次
    .withRepeatCount(100) //最多重复100次（实际执行100+1次）
    .build();

dailyTimeIntervalSchedule()
    .startingDailyAt(TimeOfDay.hourAndMinuteOfDay(9, 0)) //第天9：00开始
    .endingDailyAfterCount(10) //每天执行10次，这个方法实际上根据 startTimeOfDay+interval*count 算出 endTimeOfDay
    .onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五执行
    .withIntervalInHours(1) //每间隔1小时执行一次
    .build();

CronTrigger

适合于更复杂的任务，它支持类型于Linux Cron的语法（并且更强大）。基本上它覆盖了以上三个Trigger的绝大部分能力（但不是全部）—— 当然，也更难理解。

它适合的任务类似于：每天0:00,9:00,18:00各执行一次。

它的属性只有:

• Cron表达式。但这个表示式本身就够复杂了。下面会有说明。

例子：

cronSchedule("0 0/2 8-17 * * ?") // 每天8:00-17:00，每隔2分钟执行一次
    .build();

cronSchedule("0 30 9 ? * MON") // 每周一，9:30执行一次
.build();

weeklyOnDayAndHourAndMinute(MONDAY,9, 30) //等同于 0 30 9 ? * MON 
    .build();

Cron表达式

星号()：可用在所有字段中，表示对应时间域的每一个时刻，例如， 在分钟字段时，表示“每分钟”；

问号（?）：该字符只在日期和星期字段中使用，它通常指定为“无意义的值”，相当于点位符；

减号(-)：表达一个范围，如在小时字段中使用“10-12”，则表示从10到12点，即10,11,12；

逗号(,)：表达一个列表值，如在星期字段中使用“MON,WED,FRI”，则表示星期一，星期三和星期五；

斜杠(/)：x/y表达一个等步长序列，x为起始值，y为增量步长值。如在分钟字段中使用0/15，则表示为0,15,30和45秒，而5/15在分钟字段中表示5,20,35,50，你也可以使用*/y，它等同于0/y；

L：该字符只在日期和星期字段中使用，代表“Last”的意思，但它在两个字段中意思不同。L在日期字段中，表示这个月份的最后一天，如一月的31号，非闰年二月的28号；如果L用在星期中，则表示星期六，等同于7。但是，如果L出现在星期字段里，而且在前面有一个数值X，则表示“这个月的最后X天”，例如，6L表示该月的最后星期五；

W：该字符只能出现在日期字段里，是对前导日期的修饰，表示离该日期最近的工作日。例如15W表示离该月15号最近的工作日，如果该月15号是星期六，则匹配14号星期五；如果15日是星期日，则匹配16号星期一；如果15号是星期二，那结果就是15号星期二。但必须注意关联的匹配日期不能够跨月，如你指定1W，如果1号是星期六，结果匹配的是3号星期一，而非上个月最后的那天。W字符串只能指定单一日期，而不能指定日期范围；

LW组合：在日期字段可以组合使用LW，它的意思是当月的最后一个工作日；

井号(#)：该字符只能在星期字段中使用，表示当月某个工作日。如6#3表示当月的第三个星期五(6表示星期五，#3表示当前的第三个)，而4#5表示当月的第五个星期三，假设当月没有第五个星期三，忽略不触发；

C：该字符只在日期和星期字段中使用，代表“Calendar”的意思。它的意思是计划所关联的日期，如果日期没有被关联，则相当于日历中所有日期。例如5C在日期字段中就相当于日历5日以后的第一天。1C在星期字段中相当于星期日后的第一天。

Cron表达式对特殊字符的大小写不敏感，对代表星期的缩写英文大小写也不敏感。

一些例子：