posts - 35, comments - 0, trackbacks - 0, articles - 0
            BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理

          Spring定時器在SSH框架中的應用

          Posted on 2012-05-17 23:59 timelyxyz 閱讀(132) 評論(0)  編輯  收藏

          本課題參考自《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具體見

          http://www.quartz-scheduler.org/documentation/quartz-1.x/tutorials/crontrigger

          我們在此定義該任務在每天凌晨兩點半開始啟動。
          <!—啟動工作-->
          <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的一個引用列表。


          只有注冊用戶登錄后才能發表評論。


          網站導航:
           
          主站蜘蛛池模板: 光山县| 富阳市| 无棣县| 讷河市| 衡水市| 盐池县| 翁源县| 岫岩| 申扎县| 冀州市| 木兰县| 望奎县| 长沙市| 迭部县| 花莲县| 秦皇岛市| 石首市| 武穴市| 雷山县| 宜都市| 高密市| 徐州市| 离岛区| 锦屏县| 麻城市| 扬州市| 高雄市| 老河口市| 清水河县| 平乡县| 新兴县| 曲阳县| 什邡市| 三江| 漯河市| 伊通| 汾阳市| 富顺县| 大方县| 沿河| 台东县|