Chinaunix首页 | 论坛 | 博客
  • 博客访问: 4011227
  • 博文数量: 626
  • 博客积分: 10
  • 博客等级: 民兵
  • 技术积分: 11080
  • 用 户 组: 普通用户
  • 注册时间: 2012-08-23 13:08
文章分类

全部博文(626)

文章存档

2015年(72)

2014年(48)

2013年(506)

分类: Java

2013-10-16 10:07:07

本文探讨Spring如何集成JDK的Timer定时器,实现计划执行任务。

有时候,需要执行一些无用户交互的程序,就像在指定的时间间隔后台运行进程那样。比如,杀毒软件可以每隔2天就在后台运行一次。又比如某些程序每天都要连接一次服务器,查看有没有更新。

本文探讨Spring如何集成JDK的Timer定时器,实现计划执行任务。

一、Spring框架集成JDK的Timer

JDK的Timer任务对象提供了在指定时间执行任何任务的功能。我们来看下面的例子:

假设我们想写一个服务,此服务周期性的检查互联网连接,并用日志记录连接的状态。让我们假定此服务是全天候运行的,且每隔30秒执行一次。

所需要的JAR包如下:

log4j-1.2.13.jar
commons-logging-1.1.1.jar
spring-beans-3.2.4.RELEASE.jar
spring-context-3.2.4.RELEASE.jar
spring-context-support-3.2.4.RELEASE.jar
spring-core-3.2.4.RELEASE.jar
spring-expression-3.2.4.RELEASE.jar

二、写服务类

下面的类实现了互联网连接检查。

Listing 1: CheckInternetConnectionService.java
  1. package com.chszs;  
  2. import java.net.URL;  
  3. import java.net.URLConnection;  
  4. import java.util.Date;  
  5.   
  6. public class CheckInternetConnectionService {  
  7.     public void checkConnection(){  
  8.         if(doCheck()){  
  9.             System.out.println(new Date() + "Internet connection available");  
  10.         }else{  
  11.             System.out.println(new Date() + "Internet connection not available");  
  12.         }  
  13.     }  
  14.       
  15.     private boolean doCheck(){  
  16.         URL urlObject = null;  
  17.         URLConnection urlConnection = null;  
  18.         try{  
  19.             urlObject = new URL("");  
  20.             urlConnection = urlObject.openConnection();  
  21.             urlConnection.getContent();  
  22.             return true;  
  23.         }catch(Exception e){  
  24.             return false;  
  25.         }  
  26.     }  
  27. }  

上面的代码很简单,doCheck()方法检查互联网连接是否有效。

三、封装定时器任务服务

下面我们写一个服务,实现定时任务。代码如下:

Listing 2: CheckInternetConnectionWithTimerTask
  1. package com.chszs;  
  2. import java.util.TimerTask;  
  3.   
  4. public class CheckInternetConnectionWithTimerTask extends TimerTask{  
  5.     private CheckInternetConnectionService service;  
  6.       
  7.     public CheckInternetConnectionService getService(){  
  8.         return service;  
  9.     }  
  10.       
  11.     public void setService(CheckInternetConnectionService service){  
  12.         this.service = service;  
  13.     }  
  14.       
  15.     @Override  
  16.     public void run() {  
  17.         service.checkConnection();  
  18.     }  
  19. }  

此类继承了java.util.TimerTask类。

重写了run()方法,可以执行任意操作。这里是调用互联网连接检查。

注意定时器任务依赖于连接服务对象。稍后,我们将看到怎样连线这两个对象。

四、配置

至今,我们还没有指定执行的时间间隔。Spring提供了这样的配置支持。下面我们来看看该如何配置:

Listing 3: timer.xml
  1. xml version="1.0" encoding="UTF-8"?>  
  2. <beans xmlns=""  
  3.     xmlns:xsi="" xmlns:context=""  
  4.     xmlns:cache="" xmlns:p=""  
  5.     xsi:schemaLocation="  
  6.     /spring-beans-3.0.xsd  
  7.       
  8.     /spring-context-3.0.xsd">  
  9.       
  10.     <bean id="connectionCheckService" class="com.chszs.CheckInternetConnectionService">  
  11.     bean>  
  12.     <bean id="connectionCheckTimerTask" class="com.chszs.CheckInternetConnectionWithTimerTask">  
  13.         <property name="service" ref="connectionCheckService" />  
  14.     bean>  
  15.     <bean id="scheduledConnectionCheckTimerTask" class="org.springframework.scheduling.timer.ScheduledTimerTask">  
  16.         <property name="delay" value="2000" />  
  17.         <property name="period" value="30000" />  
  18.         <property name="timerTask" ref="connectionCheckTimerTask" />  
  19.     bean>  
  20.     <bean class="org.springframework.scheduling.timer.TimerFactoryBean">  
  21.         <property name="scheduledTimerTasks">  
  22.             <list>  
  23.                 <ref bean="scheduledConnectionCheckTimerTask" />  
  24.             list>  
  25.         property>  
  26.     bean>  
  27. beans>  

以上配置文件的细节:

"connectionCheckService"这个Bean表示互联网连接服务。

"connectionCheckTimerTask"这个Bean定义了定时器任务。由于此定时器任务依赖于"connectionCheckService"这个Bean,故通过配置进行注入。

下面的代码是从Spring框架中声明定时器任务的调度对象:
  1. <bean id="scheduledConnectionCheckTimerTask" class="org.springframework.scheduling.timer.ScheduledTimerTask">  
  2.     <property name="delay" value="2000" />  
  3.     <property name="period" value="30000" />  
  4.     <property name="timerTask" ref="connectionCheckTimerTask" />  
  5. bean>  

org.springframework.scheduling.timer.ScheduledTimerTask这个类提供了对定时任务调度执行的支持。

属性delay的单位是毫秒,它指定任务执行前需要延时多少时间。2000意味着延时2秒开始执行任务。

第二个属性period的单位也是毫秒,它表示任务每隔多少时间就重复执行一次。30000这个值表示每隔30秒执行一次。

最后一个属性是timerTask,它指定实际要执行的任务。

触发调度任务是通过TimerFactoryBean进行的。它可以指定待调度的任务对象列表,尽管这里只有1个待调度的任务对象。
  1. <bean class="org.springframework.scheduling.timer.TimerFactoryBean">  
  2.     <property name="scheduledTimerTasks">  
  3.         <list>  
  4.             <ref bean="scheduledConnectionCheckTimerTask" />  
  5.         list>  
  6.     property>  
  7. bean>  

五、客户端

客户端程序会载入应用程序的上下文。一旦上下文被载入,服务对象、定时器任务对象、调度的定时器任务对象都会被载入并连线。下面我们继续介绍触发器Bean是如何触发定时器任务的执行,互联网连接在每隔30秒运行一次。

Listing 4: Client.java
  1. package com.chszs;  
  2.   
  3. import org.springframework.context.ApplicationContext;  
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;  
  5.   
  6. public class Client {  
  7.     public static void main(String[] args){  
  8.         ApplicationContext ctx = new ClassPathXmlApplicationContext("timer.xml");  
  9.     }  
  10. }  

运行Client.java,可以看到每隔30秒定时器任务就调度执行一次。
执行结果如下:
  1. Sun Aug 11 21:08:26 CST 2013Internet connection available  
  2. Sun Aug 11 21:08:56 CST 2013Internet connection available  
  3. Sun Aug 11 21:09:26 CST 2013Internet connection available  
  4. Sun Aug 11 21:09:56 CST 2013Internet connection available  

阅读(3270) | 评论(0) | 转发(1) |
给主人留下些什么吧!~~