一javautilTimer
在Java中有一个任务处理类javautilTimer非常方便于处理由时间触发的事件任务只需建立一个继承javautilTimerTask的子类重载父类的run()方法实现具体的任务然后调用Timer的public void schedule(TimerTask task long delay long period)方法实现任务的调度
但是这种方法只能实现简单的任务调度不能满足任务调度时间比较复杂的需求比如希望系统在每周的工作日的时向系统用户给出一个提示这种方法实现起来就困难了还有更为复杂的任务调度时间要求
二Quartz
OpenSymphony 的Quartz提供了一个比较完美的任务调度解决方案
Quartz 是个开源的作业调度框架为在 Java 应用程序中进行作业调度提供了简单却强大的机制
Quartz中有两个基本概念作业和触发器作业是能够调度的可执行任务触发器提供了对作业的调度
作业
实现 orgquartzjob 接口实现接口方法 public void execute(JobExecutionContext context) throws JobExecutionException在这个方法实现具体的作业任务
代码例子
java 代码
execute 方法接受一个 JobExecutionContext 对象作为参数这个对象提供了作业实例的运行时上下文它提供了对调度器和触发器的访问这两者协作来启动作业以及作业的 JobDetail 对象的执行Quartz 通过把作业的状态放在 JobDetail 对象中并让 JobDetail 构造函数启动一个作业的实例分离了作业的执行和作业周围的状态JobDetail 对象储存作业的侦听器群组数据映射描述以及作业的其他属性
触发器
触发器可以实现对任务执行的调度Quartz 提供了几种不同的触发器复杂程度各不相同
简单触发器
public void task() throws SchedulerException {
// Initiate a Schedule Factory
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
// Retrieve a scheduler from schedule factory
Scheduler scheduler = schedulerFactorygetScheduler();
// current time
long ctime = SystemcurrentTimeMillis();
// Initiate JobDetail with job name job group and executable job class
JobDetail jobDetail =
new JobDetail(jobDetails jobDetailGroups SimpleQuartzJobclass);
// Initiate SimpleTrigger with its name and group name
SimpleTrigger simpleTrigger =
new SimpleTrigger(simpleTrigger triggerGroups);
// set its start up time
simpleTriggersetStartTime(new Date(ctime));
// set the interval how often the job should run ( seconds here)
simpleTriggersetRepeatInterval();
// set the number of execution of this job set to times
// It will run time and exhaust
simpleTriggersetRepeatCount();
// set the ending time of this job
// We set it for seconds from its startup time here
// Even if we set its repeat count to
// this will stop its process after repeats as it gets it endtime by then
// simpleTriggersetEndTime(new Date(ctime + L));
// set priority of trigger If not set the default is
// simpleTriggersetPriority();
// schedule a job with JobDetail and Trigger
schedulerscheduleJob(jobDetail simpleTrigger);
// start the scheduler
schedulerstart();
}
首先实例化一个 SchedulerFactory获得调度器创建 JobDetail 对象时它的构造函数要接受一个 Job 作为参数SimpleTrigger 是一个简单的触发器在创建对象之后设置几个基本属性以立即调度任务然后每 秒重复一次直到作业被执行 次
Cron触发器
CronTrigger 支持比 SimpleTrigger 更具体强大的调度实现起来却不是很复杂CronTrigger基于 cron 表达式支持类似日历的重复间隔更为复杂的调度时间上的要求
Cron 表达式包括以下 个字段
·秒
·分
·小时
·月内日期
·月
·周内日期
·年（可选字段）
Cron 触发器利用一系列特殊字符如下所示
·反斜线（/）字符表示增量值例如在秒字段中/代表从第 秒开始每 秒一次
·问号（?）字符和字母 L 字符只有在月内日期和周内日期字段中可用问号表示这个字段不包含具体值所以如果指定月内日期可以在周内日期字段中插入?表示周内日期值无关紧要字母 L 字符是 last 的缩写放在月内日期字段中表示安排在当月最后一天执行在周内日期字段中如果L单独存在就等于否则代表当月内周内日期的最后一个实例所以L表示安排在当月的最后一个星期日执行
·在月内日期字段中的字母（W）字符把执行安排在最靠近指定值的工作日把W放在月内日期字段中表示把执行安排在当月的第一个工作日内
·井号（#）字符为给定月份指定具体的工作日实例把MON#放在周内日期字段中表示把任务安排在当月的第二个星期一
·星号（*）字符是通配字符表示该字段可以接受任何可能的值
所有这些定义看起来可能有些吓人但是只要几分钟练习之后cron 表达式就会显得十分简单
下面的代码显示了 CronTrigger 的一个示例请注意 SchedulerFactoryScheduler 和 JobDetail 的实例化与 SimpleTrigger 示例中的实例化是相同的在这个示例中只是修改了触发器这里指定的 cron 表达式（/ * * * * ?）安排任务每 秒执行一次
public void task() throws SchedulerException {
// Initiate a Schedule Factory
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
// Retrieve a scheduler from schedule factory
Scheduler scheduler = schedulerFactorygetScheduler();
// current time
long ctime = SystemcurrentTimeMillis();
// Initiate JobDetail with job name job group and executable job class
JobDetail jobDetail =
new JobDetail(jobDetail jobDetailGroup SimpleQuartzJobclass);
// Initiate CronTrigger with its name and group name
CronTrigger cronTrigger = new CronTrigger(cronTrigger triggerGroup);
try {
// setup CronExpression
CronExpression cexp = new CronExpression(/ * * * * ?);
// Assign the CronExpression to CronTrigger
cronTriggersetCronExpression(cexp);
} catch (Exception e) {
eprintStackTrace();
}
// schedule a job with JobDetail and Trigger
schedulerscheduleJob(jobDetail cronTrigger);
// start the scheduler
schedulerstart();
}
三Spring + Quartz
spring对Java的Timer类和Quartz都提供了一个抽象层使用我们可以更方便地使用它们
spring与Timer的集成
首先是一个定时器任务
public class EmailReportTask extends TimerTask {
public EmailReportTask() {
}
public void run() {
courseServicesendCourseEnrollmentReport();
}
private CourseService courseService;
public void setCourseService(CourseService courseService) {
urseService = courseService;
}
}
spring配置文件中配置EmailReportTask
<bean id=reportTimerTask
class=comspringinactiontrainingscheduleEmailReportTask>
<property name=courseService>
<ref bean=courseService/>
</property>
</bean>
调度定时器任务
xml 代码
<bean id=scheduledReportTask
class=orgspringframeworkschedulingtimerScheduledTimerTask>
<property name=timerTask>
<ref bean=reportTimerTask/>
property>
<property name=period>
<value><value>
property>
<property name=delay>
<value>value>
property>
bean>
启动定时器
xml 代码
<bean class=orgspringframeworkschedulingtimerTimerFactoryBean>
<property name=scheduledTimerTasks>
<list>
<ref bean=scheduledReportTask/>
list>
property>
bean>
spring与Quartz的集成
创建一个工作
public class EmailReportJob extends QuartzJobBean {
public EmailReportJob() {
}
protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
courseServicesendCourseEnrollmentReport();
}
private CourseService courseService;
public void setCourseService(CourseService courseService) {
urseService = courseService;
}
}
在spring配置文件的配置EmailReportJob
<bean id=reportJob
class=orgspringframeworkschedulingquartzJobDetailBean>
<property name=jobClass>
<value>comspringinactiontrainingscheduleEmailReportJobvalue>
property>
<property name=jobDataAsMap>
<map>
<entry key=courseService>
<ref bean=courseService/>
entry>
map>
property>
bean>
调度工作
和quartz对应Spirng提供了两个触发器SimpleTriggerBean和CronTriggerBean
使用SimpleTriggerBean触发器
<bean id=simpleReportTrigger
class=orgspringframeworkschedulingquartzSimpleTriggerBean>
<property name=jobDetail>
<ref bean=reportJob/>
property>
<property name=startDelay>
<value>value>
property>
<property name=repeatInterval>
<value>value>
property>
bean>
使用CronTriggerBean触发器
<bean id=cronReportTrigger
class=orgspringframeworkschedulingquartzCronTriggerBean>
<property name=jobDetail>
<ref bean=reportJob/>
property>
<property name=cronExpression>
<value> * * * * ?value>
property>
bean>
系统会在每分钟的秒执行调度任务
