最風行的java後台框架spring quartz准時義務。本站提示廣大學習愛好者：（最風行的java後台框架spring quartz准時義務）文章只能為提供參考，不一定能成為您想要的結果。以下是最風行的java後台框架spring quartz准時義務正文
設置裝備擺設quartz 在spring中須要三個jar包：
quartz-1.8.5.jar、commons-collections-3.2.1.jar、commons-logging-1.1.jar
起首要設置裝備擺設我們的spring.xml
xmlns 多加上面的內容、
xmlns:task="http://www.springframework.org/schema/task"
然後xsi:schemaLocation多加上面的內容、
http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-3.1.xsd
最初是我們的task義務掃描注解
<task:annotation-driven/>
我的設置裝備擺設掃描地位是：
<context:annotation-config/>
<bean class="org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor"/>
<context:component-scan base-package="com.test"/>
掃描的是com.test如許的包下的內容、
上面須要接口和完成（我的這幾個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秒履行一次
@Override
public void myTest(){
System.out.println("進入測試");
}
}
履行後掌握台就會打印出 進入測試 了
須要留意的幾點：
1、spring的@Scheduled注解 須要寫在完成上、
2、 准時器的義務辦法不克不及有前往值（假如有前往值，spring初始化的時刻會告知你有個毛病、須要設定一個proxytargetclass的某個值為true、詳細就去百度谷歌吧）
3、完成類上要有組件的注解@Component
剩下的就是corn表達式了、詳細應用和參數請百度谷歌、
【秒】 【分】 【時】 【日】 【月】 【周】 【年】
上面只例出幾個式子
CRON表達式 寄義
"0 0 12 * * ?" 天天正午十二點觸發
"0 15 10 ? * *" 天天早上10：15觸發
"0 15 10 * * ?" 天天早上10：15觸發
"0 15 10 * * ? *" 天天早上10：15觸發
"0 15 10 * * ? 2005" 2005年的天天早上10：15觸發
"0 * 14 * * ?" 天天從下晝2點開端到2點59分每分鐘一次觸發
"0 0/5 14 * * ?" 天天從下晝2點開端到2：55分停止每5分鐘一次觸發
"0 0/5 14,18 * * ?" 天天的下晝2點至2：55和6點至6點55分兩個時光段內每5分鐘一次觸發
"0 0-5 14 * * ?" 天天14:00至14:05每分鐘一次觸發
"0 10,44 14 ? 3 WED" 三月的每周三的14：10和14：44觸發
"0 15 10 ? * MON-FRI" 每一個周1、周2、周3、周4、周五的10：15觸發
有時刻我們的義務(Job)須要再某些義務完成以後能力停止；例如從舊的數據庫批量導數據的時刻；須要現將被其他數據依附的數據導入新的數據庫；然後再停止關系的導入.。在這類情形下我們便可以應用Quartz的listener來做文章了。
起首我們寫一個主義務的類，定名為MainJob；她的感化是作為一系列義務的開端點。
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.");
}
}
然後我們新建別的一個義務（SecondJob）作為後續義務：
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.");
}
}
創立一個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();
//查找稱號和行將參加的義務一樣的義務
JobDetail oldJob=schduler.getJobDetail(nextJob.getName(),nextJob.getGroup());
//查找稱號和行將參加的觸發器一樣的觸發器
Trigger oldTrigger=schduler.getTrigger(nextTrigger.getName(),nextTrigger.getGroup());
if(oldJob==null&&oldTrigger==null)//同名的義務和觸發器都不存在
{
logger.debug("inside scheduleJob."+code);
schduler.scheduleJob(nextJob,nextTrigger);
}else//同名的義務或觸發器
{
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"> <!-- 主義務 --> <bean id="mainJob" class="org.springframework.scheduling.quartz.JobDetailBean"> <!-- 運轉的類 --> <property name="jobClass"> <value> jobs.MainJob </value> </property> </bean> <!-- 主義務的監聽器 --> <bean id="mainTriggerListener" class="listeners.NextJobTriggerListener"> <!-- 下個觸發器 --> <property name="nextTrigger" ref="secondTrigger"></property> <!-- 監聽器稱號 --> <property name="name" value="mainTriggerListener"></property> </bean> <!-- 主義務的觸發器 --> <bean id="mainTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean"> <property name="jobDetail"> <!-- 下面創立的義務調劑對象 --> <ref bean="mainJob" /> </property> <!-- 啟動60秒後履行義務調劑的excute辦法 --> <property name="startDelay"> <value> 6000 </value> </property> <!-- 運轉次數 --> <property name="repeatCount"> <value> </value> </property> <!-- 隔一個小時運轉一次(貌似過剩,不寫會報錯) --> <property name="repeatInterval"> <value> 3600000 </value> </property> <property name="triggerListenerNames"> <list> <value> mainTriggerListener </value> </list> </property> </bean> <!-- 後續義務 --> <bean id="secondJob" class="org.springframework.scheduling.quartz.JobDetailBean"> <!-- 運轉的類 --> <property name="jobClass"> <value> jobs.SecondJob </value> </property> </bean> <!-- 後續義務的觸發器 --> <bean id="secondTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean"> <property name="jobDetail"> <!-- 下面創立的義務調劑對象 --> <ref bean="secondJob" /> </property> <!-- 啟動6秒後履行義務調劑的excute辦法 --> <property name="startDelay"> <value> 6000 </value> </property> <!-- 運轉次數 --> <property name="repeatCount"> <value> </value> </property> <!-- 隔一個小時運轉一次(貌似過剩,不寫會報錯) --> <property name="repeatInterval"> <!-- <value>3600000</value> --> <value> 6000 </value> </property> </bean> <!-- 義務調劑工場類 --> <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> <!-- 觸發器,可以放一年夜堆觸發器 --> <property name="triggers"> <list> <!-- 在這裡加 --> <ref bean="mainTrigger"/> </list> </property> <property name="triggerListeners"> <list> <!-- 觸發器的監聽器 --> <ref bean="mainTriggerListener" /> </list> </property> </bean> </beans>
開啟辦事器，輸入
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
別的這裡一個義務只綁定了一個簡略的觸發器，如許做是為了比擬便利地可以檢測就任務完成的情形；至於義務的詳細內容就職由年夜家施展了。寫這篇文章願望能有人在個中取得啟示。
