timelyxyz

本課題參考自《Spring in action》。并非應(yīng)用系統(tǒng)中發(fā)生的所有事情都是由用戶的動作引起的。有時候，系統(tǒng)自己也需要發(fā)起一些動作。例如，集抄系統(tǒng)每天早上六點把抄表數(shù)據(jù)傳送 給營銷系統(tǒng)。我們有兩種選擇：或者是每天由用戶手動出發(fā)任務(wù)，或者讓應(yīng)用系統(tǒng)中按照預(yù)定的計劃自動執(zhí)行任務(wù)。
在Spring中有兩種流行配置：Java的Timer類和OpenSymphony的Quartz來執(zhí)行調(diào)度任務(wù)。下面以給商丘做的接口集抄900到中間庫的日凍結(jié)數(shù)據(jù)傳輸為例：
1. Java Timer調(diào)度器
首先定義一個定時器任務(wù)，繼承java.util.TimerTask類實現(xiàn)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("日凍結(jié)轉(zhuǎn)接任務(wù)開始時間："+df.format(Calendar.getInstance().getTime()));
System.out.println("日凍結(jié)轉(zhuǎn)接任務(wù)結(jié)束時間："+df.format(Calendar.getInstance().getTime()));
}

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

public void setJdbc1Service(IJdbc1Service jdbc1Service) {
this.jdbc1Service = jdbc1Service;
}
}
Run()方法定義了當(dāng)任務(wù)運行時該做什么。jdbc1Service，jdbc2Service通過依賴注入的方式提供給DayDataTimerTask。如果該任務(wù)中沒有service服務(wù)的set方法，則取到的該service服務(wù)為null。
其次，在Spring配置文件中聲明 dayDataTimerTask：
<!-- 聲明定時器任務(wù) -->
<bean id="dayDataTimerJob" class="xj.action.DayDataTimerTask">
<property name="jdbc1Service">
<ref bean="jdbc1Service"/>
</property>
<property name="jdbc2Service">
<ref bean="jdbc2Service"/>
</property>
</bean>
該聲明將DayDataTimerTask放到應(yīng)用上下文中，并在jdbc1Service、jdbc2Service屬性中分別裝配jdbc1Service、jdbc2Service。在調(diào)度它之前，它不會做任何事情。
<!-- 調(diào)度定時器任務(wù) -->
<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以怎樣的頻度調(diào)用TimerTask的run()方法。該屬性以毫秒作為單位，它被設(shè)置為864000000，指定 這個任務(wù)應(yīng)該每24小時運行一次。屬性delay允許你指定當(dāng)任務(wù)第一次運行之前應(yīng)該等待多久。在此指定DayDataTimerTask的第一次運行相 對于應(yīng)用程序的啟動時間延遲3秒鐘。
<!-- 啟動定時器 -->
<bean class="org.springframework.scheduling.timer.TimerFactoryBean">
<property name="scheduledTimerTasks">
<list>
<ref bean="scheduledDayDataTimerJob"/>
</list>
</property>
</bean>
Spring的TimerFactoryBean負(fù)責(zé)啟動定時任務(wù)。屬性scheduledTimerTasks要求一個需要啟動的定時器任務(wù)的列表。在此只包含一個指向scheduledDayDataTimerJob的引用。
    Java Timer只能指定任務(wù)執(zhí)行的頻度，但無法精確指定它何時運行，這是它的一個局限性。要想精確指定任務(wù)的啟動時間，就需要使用Quartz[kw?:ts]調(diào)度器。
2.Quartz調(diào)度器
Quartz調(diào)度器不僅可以定義每隔多少毫秒執(zhí)行一個工作，還允許你調(diào)度一個工作在某個特定的時間或日期執(zhí)行。
首先創(chuàng)建一個工作，繼承QuartzJobBean類實現(xiàn)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("日凍結(jié)轉(zhuǎn)接任務(wù)開始時間："+df.format(Calendar.getInstance().getTime()));
System.out.println("日凍結(jié)轉(zhuǎn)接任務(wù)結(jié)束時間："+df.format(Calendar.getInstance().getTime()));
}

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

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

}

在Spring配置文件中按照以下方式聲明這個工作：
<!-- 定時啟動任務(wù) 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提供了兩個觸發(fā)器 SimpleTriggerBean和CronTriggerBean。SimpleTriggerBean與scheduledTimerTasks類 似。指定工作的執(zhí)行頻度，模仿scheduledTimerTasks配置。
<!-- 調(diào)度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>
<!—調(diào)度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表達(dá)式有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）或一個通配符（如*）。“月份中的日期”和“星期中的日期”這兩個元素互斥，應(yīng)該通過設(shè)置一個問號（？）來表明你不想設(shè)置的那個字段。

corn表達(dá)式API具體見

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