7.3.2 使用Quartz調(diào)度器
Quartz調(diào)度器為調(diào)度工作提供了更豐富的支持。和Java定時器一樣，可以使用Quartz來每隔多少毫秒執(zhí)行一個工作。但Quartz比Java Timer更先進之處在于它允許你調(diào)度一個工作在某個特定的時間或日期執(zhí)行。
關(guān)于Quartz的更多信息，可以訪問Quartz位于http://www.opensymphony.com/quartz的主頁。
讓我們從定義發(fā)送報表郵件的工作開始使用Quartz：
創(chuàng)建一個工作
定義Quartz工作的第一步是創(chuàng)建一個類來定義工作。要做到這一點，你需要從Spring的QuartzJobBean中派生子類，如程序清單7.3所示：
程序清單7.3 定義一個Quartz工作
public class EmailReportJob extends QuartzJobBean {
public EmailReportJob() {}
protected void executeInternal(JobExecutionContext context)
throws JobExecutionException {
courseService.sendCourseEnrollmentReport();
}
private CourseService courseService;
public void setCourseService(CourseService courseService) {
this.courseService = courseService;
}
}
QuartzJobBean是Quartz中與Java的TimerTask等價的類。它實現(xiàn)了org.quartz.Job接口。executeInternal()方法定義了當預定的時刻來臨時應該執(zhí)行哪些動作。在這里，正如EmailReportTask，你只是簡單地調(diào)用了courseService屬性的sendCourseEnrollmentReport()方法。
在Spring配置文件中按以下方式聲明這個工作：
<bean id="reportJob"
class="org.springframework.scheduling.quartz.JobDetailBean">
<property name="jobClass">
<value>com.springinaction.training.
schedule.EmailReportJob</value>
</property>
<property name="jobDataAsMap">
<map>
<entry key="courseService">
<ref bean="courseService"/>
</entry>
</map>
</property>
</bean>
值得注意的是，在這里你并沒有直接聲明一個EmailReportJob Bean，而是聲明了一個JobDetailBean。這是使用Quartz時的一個特點。JobDetailBean是Quartz的org.quartz.JobDetail的子類，它要求通過jobClass屬性來設(shè)置一個Job對象。
使用Quartz的JobDetail中的另一個特別之處是EmailReportJob的courseService屬性是間接設(shè)置的。JobDetail的jobDataAsMap屬性接受一個java.util.Map，其中包含了需要設(shè)置給jobClass的各種屬性。在這里，這個map包含了一個指向courseService Bean的引用，它的鍵值為courseService。當JobDetailBean實例化時，它會將courseService Bean注入到EmailReportJob的courseService屬性中。
調(diào)度工作
現(xiàn)在工作已經(jīng)被定義好了，接下來你需要調(diào)度這個工作。Quartz的org.quartz.Trigger類描述了何時及以怎樣的頻度運行一個Quartz工作。Spring提供了兩個觸發(fā)器，SimpleTriggerBean和CronTriggerBean。你應該使用哪個觸發(fā)器？讓我們分別考察一下這兩個觸發(fā)器，首先從SimpleTriggerBean開始。
SimpleTriggerBean與ScheduledTimerTask類似。你可以用它來指定一個工作應該以怎樣的頻度運行，以及（可選地）在第一次運行工作之前應該等待多久。例如，要調(diào)度報表工作每24小時運行一次，第一次在1小時之后開始運行，可以按照以下方式進行聲明：
<bean id="simpleReportTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">
<property name="jobDetail">
<ref bean="reportJob"/>
</property>
<property name="startDelay">
<value>3600000</value>
</property>
<property name="repeatInterval">
<value>86400000</value>
</property>
</bean>
屬性jobDetail裝配了將要被調(diào)度的工作，在這個例子中是reportJob Bean。屬性repeatInterval告訴觸發(fā)器以怎樣的頻度運行這個工作（以毫秒作為單位）。這里，我們設(shè)置它為86400000，因此每隔24小時它會被觸發(fā)一次。你也可以選擇設(shè)置startDelay屬性來延遲工作的第一次執(zhí)行。我們設(shè)置它為3600000，因此在第一次觸發(fā)之前它會等待1小時。
調(diào)度一個cron工作
盡管你可能認為SimpleTriggerBean適用于大多數(shù)應用，但它仍然不能滿足發(fā)送注冊報表郵件的需求。正如ScheduledTimerTask，你只能指定工作執(zhí)行的頻度，而不能準確指定它于何時運行。因此，你無法使用SimpleTriggerBean在每天早晨6:00給課程主任發(fā)送注冊報表郵件。
然而，CronTriggerBean允許你更精確地控制任務(wù)的運行時間。如果你對Unix的cron工具很熟悉，則會覺得CronTriggerBean很親切。你不是定義工作的執(zhí)行頻度，而是指定工作的準確運行時間（和日期）。例如，要在每天早上6:00運行報表工作，可以按照以下方式聲明一個CronTriggerBean：
<bean id="cronReportTrigger"
class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail">
<ref bean="reportJob"/>
</property>
<property name="cronExpression">
<value>0 0 6 * * ?</value>
</property>
</bean>
和SimpleTriggerBean一樣，jobDetail屬性告訴觸發(fā)器調(diào)度哪個工作。這里我們又一次裝配了一個reportJob Bean。屬性cronExpression告訴觸發(fā)器何時觸發(fā)。如果你不熟悉cron，這個屬性可能看上去有點神秘，因此讓我們進一步考察一下這個屬性。
一個cron表達式有至少6個（也可能是7個）由空格分隔的時間元素。從左至右，這些元素的定義如下：
1．秒（0–59）
2．分鐘（0–59）
3．小時（0–23）
4．月份中的日期（1–31）
5．月份（1–12或JAN–DEC）
6．星期中的日期（1–7或SUN–SAT）
7．年份（1970–2099）
每一個元素都可以顯式地規(guī)定一個值（如6），一個區(qū)間（如9-12），一個列表（如9，11，13）或一個通配符（如*）。“月份中的日期”和“星期中的日期”這兩個元素是互斥的，因此應該通過設(shè)置一個問號（？）來表明你不想設(shè)置的那個字段。表7.1中顯示了一些cron表達式的例子和它們的意義：
表7.1 一些cron表達式的例子
表 達 式
意 義
0 0 10,14,16 * * ?
每天上午10點，下午2點和下午4點
0 0,15,30,45 * 1-10 * ?
每月前10天每隔15分鐘
30 0 0 1 1 ? 2012
在2012年1月1日午夜過30秒時
0 0 8-5 ? * MON-FRI
每個工作日的工作時間
對于cronReportTrigger，我們設(shè)置cronExpression為0 0 6 * * ?可以把它讀作“在任何月份任何日期（不管是星期幾）的6時0分0秒執(zhí)行觸發(fā)器。”換句話說，這個觸發(fā)器會在每天早晨6:00執(zhí)行。
使用CronTriggerBean完全能夠滿足課程主任的期望了。現(xiàn)在剩下要做的只是啟動這個工作了。
啟動工作
Spring的SchedulerFactoryBean是Quartz中與TimerFactoryBean等價的類。按照如下方式在Spring配置文件中聲明它：
<bean class="org.springframework.scheduling.
quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<ref bean="cronReportTrigger"/>
</list>
</property>
</bean>
屬性triggers接受一組觸發(fā)器。由于目前只有一個觸發(fā)器，因此只需簡單地裝配一個包含cronReportTrigger Bean的一個引用的列表即可。
現(xiàn)在，你已經(jīng)實現(xiàn)了調(diào)度發(fā)送注冊報表郵件的需求。但在這個過程中，你做了一些額外的工作。在開始新的話題之前，首先讓我們看一下如何通過更簡單一些的方式調(diào)度報表郵件。
示例配置：
<beans>
<bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<!--ref local="SocketJobTrigger"/>
<ref local="RouteJobTrigger"/-->
</list>
</property>
</bean>
<!---->
<bean id="SocketJobTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">
<property name="jobDetail">
<ref bean="SocketJobDetail"/>
</property>
<property name="startDelay">
<value>10000</value>
</property>
<property name="repeatInterval">
<!-- repeat every 2 minutes -->
<value>120000</value>
</property>
</bean>
<bean id="SocketJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetObject">
<ref local="quartzManager"/>
</property>
<property name="targetMethod">
<value>useQuartz</value>
</property>
</bean>
<bean id="socketManager" class="com.lxh.bean.quartzManager">
</bean>
<!---->
<bean id="RouteJobTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">
<property name="jobDetail">
<ref bean="RouteJobDetail"/>
</property>
<property name="startDelay">
<value>30000</value>
</property>
<property name="repeatInterval">
<value>30000</value>
</property>
</bean>
<bean id="RouteJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetObject">
<ref local="otherManager"/>
</property>
<property name="targetMethod">
<value>otherQuartz</value>
</property>
</bean>
<bean id="routeManager" class="com.lxh.job.otherManager">
</bean>
</beans>