陌上花開

本課題參考自《Spring in action》。并非應用系統中發生的所有事情都是由用戶的動作引起的。有時候，系統自己也需要發起一些動作。例如，集抄系統每天早上六點把抄表數據傳送 給營銷系統。我們有兩種選擇：或者是每天由用戶手動出發任務，或者讓應用系統中按照預定的計劃自動執行任務。 
在Spring中有兩種流行配置：Java的Timer類和OpenSymphony的Quartz來執行調度任務。下面以給商丘做的接口集抄900到中間庫的日凍結數據傳輸為例： 

1. Java Timer調度器 
首先定義一個定時器任務，繼承java.util.TimerTask類實現run方法 
import java.util.TimerTask; 
import xj.service.IJdbc1Service; 
import xj.service.IJdbc2Service; 
public class DayDataTimerTask extends TimerTask{ 
private IJdbc2Service jdbc2Service=null; 
private IJdbc1Service jdbc1Service=null; 
public void run(){ 
SimpleDateFormat df=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
System.out.println("日凍結轉接任務開始時間："+df.format(Calendar.getInstance().getTime())); 
System.out.println("日凍結轉接任務結束時間："+df.format(Calendar.getInstance().getTime())); 
} 

//通過set方法獲取service服務，如果沒有該方法，則為null 
public void setJdbc2Service(IJdbc2Service jdbc2Service) { 
this.jdbc2Service = jdbc2Service; 
} 

public void setJdbc1Service(IJdbc1Service jdbc1Service) { 
this.jdbc1Service = jdbc1Service; 
} 
} 
Run()方法定義了當任務運行時該做什么。jdbc1Service，jdbc2Service通過依賴注入的方式提供給DayDataTimerTask。如果該任務中沒有service服務的set方法，則取到的該service服務為null。 
其次，在Spring配置文件中聲明 dayDataTimerTask： 
<!-- 聲明定時器任務 --> 
<bean id="dayDataTimerJob" class="xj.action.DayDataTimerTask"> 
<property name="jdbc1Service"> 
<ref bean="jdbc1Service"/> 
</property> 
<property name="jdbc2Service"> 
<ref bean="jdbc2Service"/> 
</property> 
</bean> 
該聲明將DayDataTimerTask放到應用上下文中，并在jdbc1Service、jdbc2Service屬性中分別裝配jdbc1Service、jdbc2Service。在調度它之前，它不會做任何事情。 
<!-- 調度定時器任務 --> 
<bean id="scheduledDayDataTimerJob" class="org.springframework.scheduling.timer.ScheduledTimerTask"> 
<property name="timerTask"> 
<ref bean="dayDataTimerJob"/> 
</property> 
<property name="delay"> 
<value>3000</value> 
</property> 
<property name="period"> 
<value>864000000</value> 
</property> 
</bean> 
屬性timerTask告訴ScheduledTimerTask運行哪個TimerTask。再次，該屬性裝配了指向 scheduledDayDataTimerJob的一個引用，它就是DayDataTimerTask。屬性period告訴 ScheduledTimerTask以怎樣的頻度調用TimerTask的run()方法。該屬性以毫秒作為單位，它被設置為864000000，指定 這個任務應該每24小時運行一次。屬性delay允許你指定當任務第一次運行之前應該等待多久。在此指定DayDataTimerTask的第一次運行相 對于應用程序的啟動時間延遲3秒鐘。 
<!-- 啟動定時器 --> 
<bean class="org.springframework.scheduling.timer.TimerFactoryBean"> 
<property name="scheduledTimerTasks"> 
<list> 
<ref bean="scheduledDayDataTimerJob"/> 
</list> 
</property> 
</bean> 
Spring的TimerFactoryBean負責啟動定時任務。屬性scheduledTimerTasks要求一個需要啟動的定時器任務的列表。在此只包含一個指向scheduledDayDataTimerJob的引用。 
    Java Timer只能指定任務執行的頻度，但無法精確指定它何時運行，這是它的一個局限性。要想精確指定任務的啟動時間，就需要使用Quartz[kw?:ts]調度器。 

2.Quartz調度器 
Quartz調度器不僅可以定義每隔多少毫秒執行一個工作，還允許你調度一個工作在某個特定的時間或日期執行。 
首先創建一個工作，繼承QuartzJobBean類實現executeInternal方法 
import org.quartz.JobExecutionContext; 
import org.quartz.JobExecutionException; 
import org.springframework.dao.DataIntegrityViolationException; 
import org.springframework.scheduling.quartz.QuartzJobBean; 

import xj.service.IJdbc1Service; 
import xj.service.IJdbc2Service; 
public class DayDataQuartzTask extends QuartzJobBean{ 
private IJdbc2Service jdbc2Service=null; 
private IJdbc1Service jdbc1Service=null; 
protected void executeInternal(JobExecutionContext context) throws JobExecutionException{ 
SimpleDateFormat df=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
System.out.println("日凍結轉接任務開始時間："+df.format(Calendar.getInstance().getTime())); 
System.out.println("日凍結轉接任務結束時間："+df.format(Calendar.getInstance().getTime())); 
} 

//通過set方法獲取service服務，如果沒有該方法，則為null 
public void setJdbc2Service(IJdbc2Service jdbc2Service) { 
this.jdbc2Service = jdbc2Service; 
} 

public void setJdbc1Service(IJdbc1Service jdbc1Service) { 
this.jdbc1Service = jdbc1Service; 
} 

} 

在Spring配置文件中按照以下方式聲明這個工作： 
<!-- 定時啟動任務 Quartz--> 
<!—聲明工作--> 
<bean id="dayDataJob" class="org.springframework.scheduling.quartz.JobDetailBean"> 
<property name="jobClass"> 
<value>xj.action.DayDataQuartzTask</value> 
</property> 
<property name="jobDataAsMap"> 
<map> 
<entry key="jdbc1Service"> 
<ref bean="jdbc1Service"/> 
</entry> 
<entry key="jdbc2Service"> 
<ref bean="jdbc2Service"/> 
</entry> 
</map> 
</property> 
</bean> 
Quartz的org.quartz.Trigger類描述了何時及以怎樣的頻度運行一個Quartz工作。Spring提供了兩個觸發器 SimpleTriggerBean和CronTriggerBean。SimpleTriggerBean與scheduledTimerTasks類 似。指定工作的執行頻度，模仿scheduledTimerTasks配置。 
<!-- 調度Simple工作 --> 
<bean id="simpleDayDataJobTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean"> 
<property name="jobDetail"> 
<ref bean="dayDataJob"/> 
</property> 
<property name="startDelay"> 
<value>1000</value> 
</property> 
<property name="repeatInterval"> 
<value>86400000</value> 
</property> 
</bean> 
<!—調度cron工作--> 
<bean id="dayDataJobTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean"> 
<property name="jobDetail"> 
<ref bean="dayDataJob"/> 
</property> 
<property name="cronExpression"> 
<value>0 30 2 * * ?</value> 
</property> 
</bean> 
一個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）。 
每一個元素都可以顯式地規定一個值（如6），一個區間（如9-12），一個列表（如9,11,13）或一個通配符（如*）。“月份中的日期”和“星期中的日期”這兩個元素互斥，應該通過設置一個問號（？）來表明你不想設置的那個字段。

corn表達式API具體見 

我們在此定義該任務在每天凌晨兩點半開始啟動。 
<!—啟動工作--> 
<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> 
<property name="triggers"> 
<list> 
<ref bean="simpleDayDataJobTrigger"/> 
<ref bean="dayDataJobTrigger"/> 
</list> 
</property> 
</bean> 
屬性triggers接受一組觸發器，在此只裝配包含simpleDayDataJobTrigger bea和dayDataJobTrigger bean的一個引用列表。