Quartz学习笔记
1. QuartZ简介
?
??? Quartz是OpenSymphony公司的一个开源项目，主要用于复杂的任务调度。
?
2. Quartz下载
?
??? 请到官方网站http://www.opensymphony.com/下载最新的Quart版本进行学习，本人下载的为quartz-1.8.4。
?
3. Quartz结构简介
?
??? 
?
??????? 错误：trigger为一Abstract类而非Interface
?
Job： 任务接口，必须存在一public无参构造方法，要调度的任务必须实现此接口。
?
JobDetail： Quartz不直接使用Job接口，而是通过JobDetail来使用Job接口，JobDetail中有一属性为Class jobClass，
?????????????????? 这也是实现Job接口时必须存在一public无参构造方法的原因。可通过JobDataMap向Job传输数据。
?????????? 每一个Job都有一个jobName和groupName与之对应，并且在同一个Scheduler中必须唯一。
?
Trigger：?任务执行的条件。
????????? 每一个Trigger都有一个name和group与之对应，并且在同一个Scheduler中也必须唯一。
??????????一个Trigger只能指向一个JobDetail，而不同的Trigger可以指向同一个JobDetail。
???????????????? 可以通过JobDataMap向Job传输数据。
?
SimpleTrigger： Trigger的子类，根据一定频率以及次数对任务进行调度。
?
CronTrigger： Trigger的子类，根据Cron表达式对任务进行调度。
?????????????????????? 关于Cron表达式可参考附件详解。
?
Scheduler： 对在其内注册的JobDetail根据相应的Trigger进行调度。
?????????????????? 通过SchedulerFactory生成实例。
?
注：上述信息均可在Quartz API中参阅得出。
?
4. Quartz应用实例
???
??? 包的导入：将quartz-all-1.8.4.jar 以及其依赖包 lib\log4j-1.2.14.jar, lib\slf4j-api-1.6.0.jar, lib\slf4j-log4j12-1.6.0.jar导入到项目中。
??
1）JobImpl： 任务
/**
?* JobImpl.java
?* Create by Administrator at 9:22:04 PM
?*/
package com.siyuan.quartz;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
/**
?* @author Administrator
?* @Description 需要被调度执行的任务
?*/
public class JobImpl implements Job {
?/* (non-Javadoc)
? * @see org.quartz.Job#execute(org.quartz.JobExecutionContext)
? */
?public void execute(JobExecutionContext ctxt) throws JobExecutionException {
??// TODO Auto-generated method stub
??JobDetail detail = ctxt.getJobDetail();
??JobDataMap data = detail.getJobDataMap();
??if (data.containsKey("name")) {
???System.out.println(data.getString("name"));
??}
??System.out.println("Current time: " + new Date());
?}
}
2）SimpleTriggerTest: SimpleTrigger测试
/**
?* SimpleTrigger.java
?* Create by Administrator at 9:30:42 PM
?*/
package com.siyuan.quartz;
import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;
/**
?* @author Administrator
?* @Description
?*/
public class SimpleTriggerTest {
?
?/**
? * Job循环执行之间的时间间隔10s
? */
?public static final int PERIOD_BETWEEN_LOOP = 1000 * 10;
?
?/**
? * Job循环执行的次数
? */
?public static final int REPEAT_TIME = 3;
?
?/**
? * @param args
? * @throws SchedulerException
? */
?public static void main(String[] args) throws SchedulerException {
??//Quartz不使用Job实例，而是通过JobDetail来使用Job实例
??//Job 1-1 JobDetail
??JobDetail job = new JobDetail("current time printer", "test", JobImpl.class);
??//通过JobDataMap向Job中传递数据
??job.getJobDataMap().put("name", "current time printer test");
??
??Calendar calendar = GregorianCalendar.getInstance();
??calendar.set(Calendar.MINUTE, 40);
??calendar.set(Calendar.SECOND, 0);
??Date startTime = calendar.getTime();
??//trigger n-1 JobDetail
??SimpleTrigger trigger = new SimpleTrigger("simple trigger", "test");
??//假如startTime>=currentTime,则在startTime执行第一次
??//假如startTime<currentTime,则立即执行第一次
??trigger.setStartTime(startTime);
??trigger.setRepeatInterval(PERIOD_BETWEEN_LOOP);
??//Job总的执行次数为REPEAT_TIME+1
??trigger.setRepeatCount(REPEAT_TIME);
//??trigger.setJobName("current time printer");
//??trigger.setJobGroup("test");
??
??SimpleTrigger trigger1 = new SimpleTrigger("simple trigger1", "test");
??calendar.set(Calendar.MINUTE, 45);
??trigger1.setNextFireTime(calendar.getTime());
//??trigger1.setJobName("current time printer");
//??trigger1.setJobGroup("test");
??
??SchedulerFactory schdlFactory = new StdSchedulerFactory();
??Scheduler schdl = schdlFactory.getScheduler();
??
??// JobDetail n-1 Scheduler
??//方式1,缺点，不能实现JobDetail n-1 Scheduler
??//把schdl.scheduleJob(job, trigger1)注释删除将会报错
??schdl.scheduleJob(job, trigger);
//??schdl.scheduleJob(job, trigger1);
??//方式2
//??schdl.addJob(job, true);
//??schdl.scheduleJob(trigger);
//??schdl.scheduleJob(trigger1);
??
??//scheduler创建后处于"standy-by"状态，此时将不会触发任何触发器
??schdl.start();
?}
}
3）CronTriggerTest：CronTrigger测试
/**
?* CronTriggerTest.java
?* Create by Administrator at 11:36:45 PM
?*/
package com.siyuan.quartz;
import java.text.ParseException;
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;
/**
?* @author Administrator
?* @Description
?*/
public class CronTriggerTest {
?
?/**
? * CRON表达式：每天23点每一分钟的0，10，20，30，40，50S运行Job
? */
?public static final String CRON_EXP = "0/10 * 23 * * ?";
?
?/**
? * @param args
? * @throws ParseException
? * @throws SchedulerException
? */
?public static void main(String[] args) throws ParseException, SchedulerException {
??JobDetail job = new JobDetail("current time printer", "test", JobImpl.class);
??
??CronTrigger trigger = new CronTrigger("cron trigger", "test", CRON_EXP);
??
??SchedulerFactory schdlFactory = new StdSchedulerFactory();
??Scheduler schdl = schdlFactory.getScheduler();
??
??schdl.scheduleJob(job, trigger);
??
??schdl.start();
?}
}
5. 参考资料
??
?? http://www.ibm.com/developerworks/cn/java/j-quartz/
