Spring的任务调度服务实例讲解

ming_fanglin

浏览: 227115 次
性别:
来自: 北京

最近访客更多访客>>

fhgwert

challysue

heiyl

玄霄夙玉

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

Spring 应用服务器 quartz XML Bean

spring 任务调度总结
参考资料
http://www.ibm.com/developerworks/cn/java/j-quartz/
http://www.opensymphony.com/quartz/download.action

Java的Timer类和OpenSymphony的Quartz调度器是两个流行的调度API。Spring为这两个调度器提供了一个抽象层，可以更容易的使用他们

spring+timer

1 .使用java Timer调度任务
第一步 web.xml

    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>
            /WEB-INF/classes/applicationContextTimeTask.xml
        </param-value>
    </context-param>
第二步配置applicationContextTimeTask.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
     
    <bean id="testBean" class="com.photo.test.TestBean"/>
    <bean id="reportTimerTask" class="com.photo.task.EmailReportTask">
        <property name="testBean">
            <ref bean="testBean"/>
        </property>
    </bean>
    

    <bean id="scheduledReportTask" class="org.springframework.scheduling.timer.ScheduledTimerTask">
        <property name="timerTask">
            <ref bean="reportTimerTask"/>
        </property>
        <property name="period">
            <value>10000</value>
        </property>
        <property name="delay">
            <value>5000</value>
        </property>
    </bean>
    
    <bean class="org.springframework.scheduling.timer.TimerFactoryBean">
        <property name="scheduledTimerTasks">
            <list>
                <ref bean="scheduledReportTask"/>
            </list>
        </property>
    </bean>
</beans>
第三步相关类的编写
EmailReportTask.java
public class EmailReportTask extends TimerTask {//必需继承TimerTask
     Log log= LogFactory.getLog(EmailReportTask.class);
     public EmailReportTask() {
     }

     public void run() {//这个函数是调度任务执行的入口
        log.debug("task begin :"+testBean.greeting);
     }

     private TestBean testBean;//这里实现spring的依赖注入

     public void setTestBean(TestBean testBean) {
         this.testBean = testBean;
     }
}
testBean.java
public class TestBean {
     public String greeting="hello,world";
}

spring+Quartz
Quartz 作业调度框架所提供的 API 在两方面都表现极佳：既全面强大，又易于使用。Quartz 可以用于简单的作业触发，也可以用于复杂的 JDBC 持久的作业存储和执行。
第一步同上
第二步配置applicationContextTimeTask.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="reportJob" class="org.springframework.scheduling.quartz.JobDetailBean">
<property name="jobClass">
   <value>com.photo.task.EmailReportTask2</value>
</property>
<property name="jobDataAsMap">
   <map>
    <entry key="testBean">
     <ref bean="testBean"/>
    </entry>
   </map>
</property>
</bean>

<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>

<bean id="cronReportTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail">
   <ref bean="reportJob"/>
</property>
<property name="cronExpression">
   <value>0/5 * * * * ?</value>
</property>
</bean>
<bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
   <list>
    <ref bean="cronReportTrigger"/>
   </list>
</property>
</bean>
</beans>
第三步相关类的编写
EmailReportTask2.java
public class EmailReportTask2 extends QuartzJobBean {
     Log log = LogFactory.getLog(EmailReportTask.class);

     public EmailReportTask2() {
     }
//这个函数是调度任务执行的入口
     protected void executeInternal(JobExecutionContext jobExecutionContext) throws org.quartz.JobExecutionException {

         log.debug("task 2 begin :" + testBean.greeting);
     }

     private TestBean testBean;//这里实现spring的依赖注入

     public void setTestBean(TestBean testBean) {
         this.testBean = testBean;
     }
}
TestBean.java 同上

分享到：