關(guān)鍵字: Quartz
你曾經(jīng)需要應(yīng)用執(zhí)行一個(gè)任務(wù)嗎？這個(gè)任務(wù)每天或每周星期二晚上11：30，或許僅僅每個(gè)月的最后一天執(zhí)行。一個(gè)自動(dòng)執(zhí)行而無(wú)須干預(yù)的任務(wù)在執(zhí)行過(guò)程中如果
發(fā)生一個(gè)嚴(yán)重錯(cuò)誤，應(yīng)用能夠知到其執(zhí)行失敗并嘗試重新執(zhí)行嗎？你和你的團(tuán)隊(duì)是用java編程嗎？如果這些問(wèn)題中任何一個(gè)你回答是，那么你應(yīng)該使用
Quartz調(diào)度器。
旁注：Matrix目前就大量使用到了Quartz。比如，排名統(tǒng)計(jì)功能的實(shí)現(xiàn)，在Jmatrix里通過(guò)Quartz定義了一個(gè)定時(shí)調(diào)度作業(yè)，在每天凌晨一點(diǎn)，作業(yè)開(kāi)始工作，重新統(tǒng)計(jì)大家的Karma和排名等。
還有，RSS文件的生成，也是通過(guò)Quartz定義作業(yè)，每隔半個(gè)小時(shí)生成一次RSS XML文件。
Quartz是OpenSymphony開(kāi)源組織在Job
scheduling領(lǐng)域又一個(gè)開(kāi)源項(xiàng)目,它可以與J2EE與J2SE應(yīng)用程序相結(jié)合也可以單獨(dú)使用。Quartz可以用來(lái)創(chuàng)建簡(jiǎn)單或?yàn)檫\(yùn)行十個(gè)，百個(gè)，
甚至是好幾萬(wàn)個(gè)Jobs這樣復(fù)雜的日程序表。Jobs可以做成標(biāo)準(zhǔn)的Java組件或 EJBs。
http://www.opensymphony.com/quartz/
從下載連接取得Quartz的發(fā)布版本，并且解壓到到本地
目錄。這個(gè)下載文件包含了一個(gè)預(yù)先構(gòu)建好的Quartz二進(jìn)制文件（quartz.jar），你可以將它放進(jìn)自己的應(yīng)用中。Quartz框架只需要少數(shù)的
第三方庫(kù)，并且這些三方庫(kù)是必需的，你很可能已經(jīng)在使用這些庫(kù)了。
你要把Quartz的安裝目錄的
quartz.properties文件
Quartz有一個(gè)叫做
quartz.properties的配置文件，它允許你修改框架運(yùn)行時(shí)環(huán)境。缺省是使用Quartz.jar里面的quartz.properties
文件。當(dāng)然，你應(yīng)該創(chuàng)建一個(gè)quartz.properties文件的副本并且把它放入你工程的classes目錄中以便類裝載器找到它。
quartz.properties樣本文件如例1所示。
例1.quartz.properties文件允許修改Quartz運(yùn)行環(huán)境：
一旦將Quartz.jar文件和第三方庫(kù)加到自己的工程里面并且quartz.properties文件在工程的classes目錄中，就可以創(chuàng)建作業(yè)了。
1. 在web.xml里面加上
package.ContextListener
這樣就可以在部署的時(shí)候啟動(dòng)定時(shí)器。
package.ContextListener.java
package package;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import org.quartz.SchedulerException;
public class ContextListener implements ServletContextListener {
Runner qRunner = null;
public void contextInitialized(ServletContextEvent arg0) {
// init job
// start schedule task
try {
qRunner = new Runner();
qRunner.task();
} catch (Exception e) {
e.printStackTrace();
}
}
public void contextDestroyed(ServletContextEvent arg0) {
try {
// stop task
qRunner.stop();
} catch (SchedulerException e) {
e.printStackTrace();
}
}
}
Runner.java
import org.quartz.CronExpression;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.impl.StdSchedulerFactory;
/**
*/
public class Runner {
static Scheduler scheduler = null;
public void task() throws SchedulerException {
// Initiate a Schedule Factory
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
// Retrieve a scheduler from schedule factory
scheduler = schedulerFactory.getScheduler();
// current time
long ctime = System.currentTimeMillis();
// Initiate JobDetail with job name, job group, and executable job class
JobDetail jobDetail = new JobDetail("jobDetail1", "jobDetailGroup1",
YourScheduleJob.class);
// Initiate CronTrigger with its name and group name
CronTrigger cronTrigger = new CronTrigger("cronTrigger",
"triggerGroup1");
try {
// setup CronExpression
CronExpression cexp = new CronExpression("0/180 * * * * ?");
// Assign the CronExpression to CronTrigger
cronTrigger.setCronExpression(cexp);
} catch (Exception e) {
e.printStackTrace();
}
// schedule a job with JobDetail and Trigger
scheduler.scheduleJob(jobDetail, cronTrigger);
// start the scheduler
scheduler.start();
}
public void stop() throws SchedulerException {
scheduler.shutdown();
}
public static void main(String args[]) {
try {
Runner qRunner = new Runner();
qRunner.task();
} catch (Exception e) {
e.printStackTrace();
}
}
}
YourScheduleJob.java
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class YourScheduleJob implements Job {
public void execute(JobExecutionContext context) throws JobExecutionException {
System.out.println("In SimpleQuartzJob - executing its JOB at "
+ new Date() + " by " + context.getTrigger().getName());
// your job here
}
}