一、java.util.Timer
在Java中有一個(gè)任務(wù)處理類java.util.Timer，非常方便于處理由時(shí)間觸發(fā)的事件任務(wù)，只需建立一個(gè)繼承java.util.TimerTask的子類，重載父類的run()方法實(shí)現(xiàn)具體的任務(wù)，然后調(diào)用Timer的public void schedule(TimerTask task, long delay, long period)方法實(shí)現(xiàn)任務(wù)的調(diào)度。
但是這種方法只能實(shí)現(xiàn)簡(jiǎn)單的任務(wù)調(diào)度，不能滿足任務(wù)調(diào)度時(shí)間比較復(fù)雜的需求。比如希望系統(tǒng)在每周的工作日的8：00時(shí)向系統(tǒng)用戶給出一個(gè)提示，這種方法實(shí)現(xiàn)起來(lái)就困難了，還有更為復(fù)雜的任務(wù)調(diào)度時(shí)間要求。
二、Quartz
OpenSymphony 的Quartz提供了一個(gè)比較完美的任務(wù)調(diào)度解決方案。
Quartz 是個(gè)開源的作業(yè)調(diào)度框架，為在 Java 應(yīng)用程序中進(jìn)行作業(yè)調(diào)度提供了簡(jiǎn)單卻強(qiáng)大的機(jī)制。
Quartz中有兩個(gè)基本概念：作業(yè)和觸發(fā)器。作業(yè)是能夠調(diào)度的可執(zhí)行任務(wù)，觸發(fā)器提供了對(duì)作業(yè)的調(diào)度。
1、作業(yè)
實(shí)現(xiàn) org.quartz.job 接口，實(shí)現(xiàn)接口方法 public void execute(JobExecutionContext context) throws JobExecutionException，在這個(gè)方法實(shí)現(xiàn)具體的作業(yè)任務(wù)。
代碼例子：
java 代碼
execute 方法接受一個(gè) JobExecutionContext 對(duì)象作為參數(shù)。這個(gè)對(duì)象提供了作業(yè)實(shí)例的運(yùn)行時(shí)上下文。它提供了對(duì)調(diào)度器和觸發(fā)器的訪問(wèn)，這兩者協(xié)作來(lái)啟動(dòng)作業(yè)以及作業(yè)的 JobDetail 對(duì)象的執(zhí)行。Quartz 通過(guò)把作業(yè)的狀態(tài)放在 JobDetail 對(duì)象中并讓 JobDetail 構(gòu)造函數(shù)啟動(dòng)一個(gè)作業(yè)的實(shí)例，分離了作業(yè)的執(zhí)行和作業(yè)周圍的狀態(tài)。JobDetail 對(duì)象儲(chǔ)存作業(yè)的偵聽器、群組、數(shù)據(jù)映射、描述以及作業(yè)的其他屬性。
2、觸發(fā)器
觸發(fā)器可以實(shí)現(xiàn)對(duì)任務(wù)執(zhí)行的調(diào)度。Quartz 提供了幾種不同的觸發(fā)器，復(fù)雜程度各不相同。
簡(jiǎn)單觸發(fā)器：
public void task() throws SchedulerException {
// Initiate a Schedule Factory
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
// Retrieve a scheduler from schedule factory
Scheduler scheduler = schedulerFactory.getScheduler();
// current time
long ctime = System.currentTimeMillis();
// Initiate JobDetail with job name, job group, and executable job class
JobDetail jobDetail =
new JobDetail("jobDetail-s1", "jobDetailGroup-s1", SimpleQuartzJob.class);
// Initiate SimpleTrigger with its name and group name
SimpleTrigger simpleTrigger =
new SimpleTrigger("simpleTrigger", "triggerGroup-s1");
// set its start up time
simpleTrigger.setStartTime(new Date(ctime));
// set the interval, how often the job should run (10 seconds here)
simpleTrigger.setRepeatInterval(10000);
// set the number of execution of this job, set to 10 times.
// It will run 10 time and exhaust.
simpleTrigger.setRepeatCount(100);
// set the ending time of this job.
// We set it for 60 seconds from its startup time here
// Even if we set its repeat count to 10,
// this will stop its process after 6 repeats as it gets it endtime by then.
// simpleTrigger.setEndTime(new Date(ctime + 60000L));
// set priority of trigger. If not set, the default is 5
// simpleTrigger.setPriority(10);
// schedule a job with JobDetail and Trigger
scheduler.scheduleJob(jobDetail, simpleTrigger);
// start the scheduler
scheduler.start();
}
首先實(shí)例化一個(gè) SchedulerFactory，獲得調(diào)度器。創(chuàng)建 JobDetail 對(duì)象時(shí)，它的構(gòu)造函數(shù)要接受一個(gè) Job 作為參數(shù)。SimpleTrigger 是一個(gè)簡(jiǎn)單的觸發(fā)器。在創(chuàng)建對(duì)象之后，設(shè)置幾個(gè)基本屬性以立即調(diào)度任務(wù)，然后每 10 秒重復(fù)一次，直到作業(yè)被執(zhí)行 100 次。
Cron觸發(fā)器
CronTrigger 支持比 SimpleTrigger 更具體強(qiáng)大的調(diào)度，實(shí)現(xiàn)起來(lái)卻不是很復(fù)雜。CronTrigger基于 cron 表達(dá)式，支持類似日歷的重復(fù)間隔更為復(fù)雜的調(diào)度時(shí)間上的要求。
Cron 表達(dá)式包括以下 7 個(gè)字段：
·秒
·分
·小時(shí)
·月內(nèi)日期
·月
·周內(nèi)日期
·年（可選字段）
Cron 觸發(fā)器利用一系列特殊字符，如下所示：
·反斜線（/）字符表示增量值。例如，在秒字段中“5/15”代表從第 5 秒開始，每 15 秒一次。
·問(wèn)號(hào)（?）字符和字母 L 字符只有在月內(nèi)日期和周內(nèi)日期字段中可用。問(wèn)號(hào)表示這個(gè)字段不包含具體值。所以，如果指定月內(nèi)日期，可以在周內(nèi)日期字段中插入“?”，表示周內(nèi)日期值無(wú)關(guān)緊要。字母 L 字符是 last 的縮寫。放在月內(nèi)日期字段中，表示安排在當(dāng)月最后一天執(zhí)行。在周內(nèi)日期字段中，如果“L”單獨(dú)存在，就等于“7”，否則代表當(dāng)月內(nèi)周內(nèi)日期的最后一個(gè)實(shí)例。所以“0L”表示安排在當(dāng)月的最后一個(gè)星期日?qǐng)?zhí)行。
·在月內(nèi)日期字段中的字母（W）字符把執(zhí)行安排在最靠近指定值的工作日。把“1W”放在月內(nèi)日期字段中，表示把執(zhí)行安排在當(dāng)月的第一個(gè)工作日內(nèi)。
·井號(hào)（#）字符為給定月份指定具體的工作日實(shí)例。把“MON#2”放在周內(nèi)日期字段中，表示把任務(wù)安排在當(dāng)月的第二個(gè)星期一。
·星號(hào)（*）字符是通配字符，表示該字段可以接受任何可能的值。
所有這些定義看起來(lái)可能有些嚇人，但是只要幾分鐘練習(xí)之后，cron 表達(dá)式就會(huì)顯得十分簡(jiǎn)單。
下面的代碼顯示了 CronTrigger 的一個(gè)示例。請(qǐng)注意 SchedulerFactory、Scheduler 和 JobDetail 的實(shí)例化，與 SimpleTrigger 示例中的實(shí)例化是相同的。在這個(gè)示例中，只是修改了觸發(fā)器。這里指定的 cron 表達(dá)式（“0/5 * * * * ?”）安排任務(wù)每 5 秒執(zhí)行一次。
public void task() throws SchedulerException {
// Initiate a Schedule Factory
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
// Retrieve a scheduler from schedule factory
Scheduler scheduler = schedulerFactory.getScheduler();
// current time
long ctime = System.currentTimeMillis();
// Initiate JobDetail with job name, job group, and executable job class
JobDetail jobDetail =
new JobDetail("jobDetail2", "jobDetailGroup2", SimpleQuartzJob.class);
// Initiate CronTrigger with its name and group name
CronTrigger cronTrigger = new CronTrigger("cronTrigger", "triggerGroup2");
try {
// setup CronExpression
CronExpression cexp = new CronExpression("0/5 * * * * ?");
// Assign the CronExpression to CronTrigger
cronTrigger.setCronExpression(cexp);
} catch (Exception e) {
e.printStackTrace();
}
// schedule a job with JobDetail and Trigger
scheduler.scheduleJob(jobDetail, cronTrigger);
// start the scheduler
scheduler.start();
}
三、Spring + Quartz
spring對(duì)Java的Timer類和Quartz都提供了一個(gè)抽象層，使用我們可以更方便地使用它們。
1、spring與Timer的集成
首先是一個(gè)定時(shí)器任務(wù)
public class EmailReportTask extends TimerTask {
public EmailReportTask() {
}
public void run() {
courseService.sendCourseEnrollmentReport();
}
private CourseService courseService;
public void setCourseService(CourseService courseService) {
this.courseService = courseService;
}
}
spring配置文件中配置EmailReportTask
1.<bean id="reportTimerTask"
2. class="com.springinaction.training.schedule.EmailReportTask">
3. <property name="courseService">
4. <ref bean="courseService"/>
5. </property>
6.</bean>
調(diào)度定時(shí)器任務(wù)
xml 代碼
1.<bean id="scheduledReportTask"
2.
3. class="org.springframework.scheduling.timer.ScheduledTimerTask">
4.
5.
6. <property name="timerTask">
7.
8. <ref bean="reportTimerTask"/>
9.
10. property>
11.
12. <property name="period">
13.
14. <value>86400000<value>
15.
16.
17. property>
18.
19. <property name="delay">
20.
21. <value>32000value>
22.
23. property>
24.
25.bean>
26.
啟動(dòng)定時(shí)器
xml 代碼
1.<bean class="org.springframework.scheduling.timer.TimerFactoryBean">
2. <property name="scheduledTimerTasks">
3. <list>
4. <ref bean="scheduledReportTask"/>
5. list>
6. property>
7.bean>
2、spring與Quartz的集成
創(chuàng)建一個(gè)工作
1.public class EmailReportJob extends QuartzJobBean {
2.
3. public EmailReportJob() {
4.
5. }
6.
7. protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
8. courseService.sendCourseEnrollmentReport();
9. }
10.
11. private CourseService courseService;
12. public void setCourseService(CourseService courseService) {
13. this.courseService = courseService;
14. }
15.}
在spring配置文件的配置EmailReportJob
1.<bean id="reportJob"
2. class="org.springframework.scheduling.quartz.JobDetailBean">
3. <property name="jobClass">
4. <value>com.springinaction.training.schedule.EmailReportJobvalue>
5. property>
6. <property name="jobDataAsMap">
7. <map>
8. <entry key="courseService">
9. <ref bean="courseService"/>
10. entry>
11. map>
12. property>
13.bean>
調(diào)度工作
和quartz對(duì)應(yīng)，Spirng提供了兩個(gè)觸發(fā)器SimpleTriggerBean和CronTriggerBean
使用SimpleTriggerBean觸發(fā)器
1.<bean id="simpleReportTrigger"
2. class="org.springframework.scheduling.quartz.SimpleTriggerBean">
3. <property name="jobDetail">
4. <ref bean="reportJob"/>
5. property>
6. <property name="startDelay">
7. <value>3600000value>
8. property>
9. <property name="repeatInterval">
10. <value>86400000value>
11. property>
12.bean>
使用CronTriggerBean觸發(fā)器
1.<bean id="cronReportTrigger"
2. class="org.springframework.scheduling.quartz.CronTriggerBean">
3. <property name="jobDetail">
4. <ref bean="reportJob"/>
5. property>
6. <property name="cronExpression">
7. <value>0 * * * * ?value>
8. property>
9.bean>
系統(tǒng)會(huì)在每分鐘的0秒執(zhí)行調(diào)度任務(wù)。