快捷導(dǎo)航

最流行的java后臺框架spring quartz定時任務(wù)

更新時間：2015年12月01日 08:50:26 投稿：hebedich

近日項目開發(fā)中需要執(zhí)行一些定時任務(wù)，比如需要在每天凌晨時候，分析一次前一天的日志信息，借此機會整理了一下定時任務(wù)的幾種實現(xiàn)方式，由于項目采用spring框架，所以我都將結(jié)合spring框架來介紹

配置quartz 在spring中需要三個jar包：

quartz-1.8.5.jar、commons-collections-3.2.1.jar、commons-logging-1.1.jar

首先要配置我們的spring.xml

xmlns 多加下面的內(nèi)容、

xmlns:task="

然后xsi:schemaLocation多加下面的內(nèi)容、

http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-3.1.xsd

最后是我們的task任務(wù)掃描注解

<task:annotation-driven/>

我的配置掃描位置是：

復(fù)制代碼代碼如下:

<context:annotation-config/>  

    <bean class="org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor"/>  

    <context:component-scan base-package="com.test"/>  

掃描的是com.test這樣的包下的內(nèi)容、

下面需要接口和實現(xiàn)（我的這幾個java文件都是com.test的包下的、）

public interface IMyTestService { 
    public void myTest(); 
}

@Component //import org.springframework.stereotype.Component; 
public class MyTestServiceImpl implements IMyTestService { 
   @Scheduled(cron="0/5 * * * * ? ")  //每5秒執(zhí)行一次 
   @Override 
   public void myTest(){ 
      System.out.println("進入測試"); 
   } 
}

執(zhí)行后控制臺就會打印出進入測試了

需要注意的幾點：

1、spring的@Scheduled注解需要寫在實現(xiàn)上、

2、定時器的任務(wù)方法不能有返回值（如果有返回值，spring初始化的時候會告訴你有個錯誤、需要設(shè)定一個proxytargetclass的某個值為true、具體就去百度google吧）

3、實現(xiàn)類上要有組件的注解@Component

剩下的就是corn表達式了、具體使用以及參數(shù)請百度google、

【秒】【分】【時】【日】【月】【周】【年】

下面只例出幾個式子

CRON表達式    含義
"0 0 12 * * ?"    每天中午十二點觸發(fā)
"0 15 10 ? * *"    每天早上10：15觸發(fā)
"0 15 10 * * ?"    每天早上10：15觸發(fā)
"0 15 10 * * ? *"    每天早上10：15觸發(fā)
"0 15 10 * * ? 2005"    2005年的每天早上10：15觸發(fā)
"0 * 14 * * ?"    每天從下午2點開始到2點59分每分鐘一次觸發(fā)
"0 0/5 14 * * ?"    每天從下午2點開始到2：55分結(jié)束每5分鐘一次觸發(fā)
"0 0/5 14,18 * * ?"    每天的下午2點至2：55和6點至6點55分兩個時間段內(nèi)每5分鐘一次觸發(fā)
"0 0-5 14 * * ?"    每天14:00至14:05每分鐘一次觸發(fā)
"0 10,44 14 ? 3 WED"    三月的每周三的14：10和14：44觸發(fā)
"0 15 10 ? * MON-FRI"    每個周一、周二、周三、周四、周五的10：15觸發(fā)

有時候我們的任務(wù)(Job)需要再某些任務(wù)完成之后才能進行；例如從舊的數(shù)據(jù)庫批量導(dǎo)數(shù)據(jù)的時候；需要現(xiàn)將被其他數(shù)據(jù)依賴的數(shù)據(jù)導(dǎo)入新的數(shù)據(jù)庫；然后再進行關(guān)系的導(dǎo)入.。在這種情況下我們就可以使用Quartz的listener來做文章了。

首先我們寫一個主任務(wù)的類，命名為MainJob；她的作用是作為一系列任務(wù)的開始點。

MainJob.java

package jobs;

import org.apache.log4j.Logger;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;

public class MainJob extends QuartzJobBean {
private Logger logger=Logger.getLogger(getClass());
@Override
protected void executeInternal(JobExecutionContext arg0)
throws JobExecutionException {
// TODO Auto-generated method stub
logger.debug("Just say hi.");
}

}

然后我們新建另外一個任務(wù)（SecondJob）作為后續(xù)任務(wù)：

SecondJob.java

package jobs;

import org.apache.log4j.Logger;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;

public class SecondJob extends QuartzJobBean {
private Logger logger=Logger.getLogger(getClass());
@Override
protected void executeInternal(JobExecutionContext arg0)
throws JobExecutionException {
// TODO Auto-generated method stub
logger.debug("I'm the second job.");
}

}

創(chuàng)建一個TriggerListener,重寫其triggerComplete方法，并且添加一些方便spring注入的屬性和方法。

NextJobTriggerListener.java

package listeners;

import org.apache.log4j.Logger;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.Scheduler;
import org.quartz.Trigger;
import org.quartz.listeners.TriggerListenerSupport;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.scheduling.quartz.SimpleTriggerBean;

public class NextJobTriggerListener extends TriggerListenerSupport {
private Logger logger=Logger.getLogger(getClass());
private String name;
public String getName() {
return this.name;
}
public void setName(String name)
{
this.name=name;
}
private SimpleTriggerBean nextTrigger;
public void setNextTrigger(SimpleTriggerBean nextTrigger) {
this.nextTrigger=nextTrigger;
}
@Override
public void triggerComplete(Trigger trigger, JobExecutionContext context, int code) {
try{
Scheduler schduler=context.getScheduler();
JobDetail nextJob=nextTrigger.getJobDetail();
//查找名稱和即將加入的任務(wù)一樣的任務(wù)
JobDetail oldJob=schduler.getJobDetail(nextJob.getName(),nextJob.getGroup());
//查找名稱和即將加入的觸發(fā)器一樣的觸發(fā)器
Trigger oldTrigger=schduler.getTrigger(nextTrigger.getName(),nextTrigger.getGroup());

if(oldJob==null&&oldTrigger==null)//同名的任務(wù)和觸發(fā)器都不存在
{
logger.debug("inside scheduleJob."+code);
schduler.scheduleJob(nextJob,nextTrigger);
}else//同名的任務(wù)或觸發(fā)器
{

logger.debug("oldJob==null:"+(oldJob==null));
logger.debug("oldTrigger==null:"+(oldTrigger==null));
}
super.triggerComplete(trigger, context, code);
}catch(Exception e)
{
e.printStackTrace();
}
}


}

配置spring 的applicationContext.xml

applicationContext.xml

<?xml version="1.0"encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:jee="http://www.springframework.org/schema/jee"
xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-2.0.xsd">
<!-- 主任務(wù) -->
<bean id="mainJob"
class="org.springframework.scheduling.quartz.JobDetailBean">
<!-- 運行的類 -->
<property name="jobClass">
<value> jobs.MainJob </value>
</property>
</bean>
<!-- 主任務(wù)的監(jiān)聽器 -->
<bean id="mainTriggerListener"
class="listeners.NextJobTriggerListener">
<!-- 下個觸發(fā)器 -->
<property name="nextTrigger" ref="secondTrigger"></property>
<!-- 監(jiān)聽器名稱 -->
<property name="name" value="mainTriggerListener"></property>
</bean>

<!-- 主任務(wù)的觸發(fā)器 -->
<bean id="mainTrigger"
class="org.springframework.scheduling.quartz.SimpleTriggerBean">
<property name="jobDetail">
<!-- 上面創(chuàng)建的任務(wù)調(diào)度對象 -->
<ref bean="mainJob" />
</property>
<!-- 啟動60秒后執(zhí)行任務(wù)調(diào)度的excute方法 -->
<property name="startDelay">
<value> 6000 </value>
</property>
<!-- 運行次數(shù) -->
<property name="repeatCount">
<value> </value>
</property>
<!-- 隔一個小時運行一次(貌似多余,不寫會報錯) -->
<property name="repeatInterval">
<value> 3600000 </value>
</property>
<property name="triggerListenerNames">
<list>
<value> mainTriggerListener </value>
</list>
</property>
</bean>
<!-- 后續(xù)任務(wù) -->
<bean id="secondJob"
class="org.springframework.scheduling.quartz.JobDetailBean">
<!-- 運行的類 -->
<property name="jobClass">
<value> jobs.SecondJob </value>
</property>
</bean>
<!-- 后續(xù)任務(wù)的觸發(fā)器 -->
<bean id="secondTrigger"
class="org.springframework.scheduling.quartz.SimpleTriggerBean">
<property name="jobDetail">
<!-- 上面創(chuàng)建的任務(wù)調(diào)度對象 -->
<ref bean="secondJob" />
</property>
<!-- 啟動6秒后執(zhí)行任務(wù)調(diào)度的excute方法 -->
<property name="startDelay">
<value> 6000 </value>
</property>
<!-- 運行次數(shù) -->
<property name="repeatCount">
<value> </value>
</property>
<!-- 隔一個小時運行一次(貌似多余,不寫會報錯) -->
<property name="repeatInterval">
<!--
<value>3600000</value>
-->
<value> 6000 </value>
</property>
</bean>
<!-- 任務(wù)調(diào)度工廠類 -->
<bean
class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<!-- 這一部分的配置不用管 -->
<property name="quartzProperties">
<props>
<prop key="org.quartz.threadPool.class">
org.quartz.simpl.SimpleThreadPool
</prop>
<prop key="org.quartz.threadPool.threadCount"> </prop>
<prop key="org.quartz.threadPool.threadPriority">
</prop>
<prop
key="org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread">
true
</prop>
</props>
</property>
<!-- 觸發(fā)器,可以放一大堆觸發(fā)器 -->
<property name="triggers">
<list>
<!-- 在這里加 -->
<ref bean="mainTrigger"/>
</list>
</property>
<property name="triggerListeners">
<list>
<!-- 觸發(fā)器的監(jiān)聽器 -->
<ref bean="mainTriggerListener" />
</list>
</property>
</bean>
</beans>

開啟服務(wù)器，輸出

DEBUG [ MainJob.executeInternal(14) ] Just say hi.
DEBUG [ NextJobTriggerListener.triggerComplete(38) ] inside scheduleJob .3
DEBUG [SecondJob.executeInternal(14)] I'm the second job.
DEBUG [ NextJobTriggerListener.triggerComplete(43) ] oldJob==null:false
DEBUG [ NextJobTriggerListener.triggerComplete(44) ] oldTrigger== null:false

另外這里一個任務(wù)只綁定了一個簡單的觸發(fā)器，這樣做是為了比較方便地可以檢測到任務(wù)完成的情況；至于任務(wù)的具體內(nèi)容就任由大家發(fā)揮了。寫這篇文章希望能有人在其中獲得啟發(fā)。

您可能感興趣的文章: