Quartz 编程式详解

比较常用的两种job区别

1.一个类实现了 org.quartz.Job 接口,默认方法 execute()

execute()参数 JobExecutionContext 被用来访问 org.quartz.JobDetail 类， JobDetail 类持有 Job 的详细信息

2.一个类实现了 org.quartz.StatefulJob 得到是一个同一个描述，但任务还是新的任务。( JobDetail 不会改变)

注：Scheduler 会为每一次执行创建新的 Job 实例

    package org.ymm.chapter3;

import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class DirectoryJob implements Job{
	@Override
	public void execute(JobExecutionContext context) throws JobExecutionException {
		// TODO Auto-generated method stub
		JobDetail jobDetail = context.getJobDetail();  
		JobDataMap jdm=jobDetail.getJobDataMap();
		String uName=jdm.getString("uname");
		System.out.println(uName+" say hello1..."+"Job Class: " + jobDetail.getJobClass());
	}
}

  

    QuartZTest qt=new QuartZTest();
		try {
			/*Scheduler sch =StdSchedulerFactory.getDefaultScheduler();*/
			DirectSchedulerFactory factory=DirectSchedulerFactory.getInstance();   
			factory.createVolatileScheduler(5);//告诉工厂以5个工作者线程初始化它自己
			Scheduler sch= factory.getScheduler();
			sch.start();
			//qt.schJob(sch,"DirectoryJob",DirectoryJob.class,"yy",2);//关联job
		} catch (SchedulerException e) {
			e.printStackTrace();
		}
  

4 .创建一个 JobDetail 的描述和 trigger 触发器

    public void schJob(Scheduler sch,String jobName,Class jobclass,String name,Integer scanInterval) throws SchedulerException{
		
		JobDetail jobDetail=new JobDetail(jobName,Scheduler.DEFAULT_GROUP,jobclass);  
		
		jobDetail.getJobDataMap().put("uname", name);
		
		Trigger trigger=TriggerUtils.makeSecondlyTrigger(scanInterval);
		
		trigger.setName("DirectoryJob" + "-Trigger");
		
        trigger.setStartTime(new Date()); 

        //得到当前时间
        Calendar nTime = Calendar.getInstance();
        nTime.add(Calendar.MINUTE, 1);
		trigger.setEndTime(nTime.getTime());
       // trigger.setEndTime(new Date(new Date().getTime() + 30000));
        
		sch.scheduleJob(jobDetail, trigger);
	}
  

    NthIncludedDayTrigger nt = new NthIncludedDayTrigger(jd.getName()+"-Trigger",Scheduler.DEFAULT_FAIL_OVER_GROUP);
//		nt.setName(jd.getName()+"-Trigger");
		nt.setIntervalType(NthIncludedDayTrigger.INTERVAL_TYPE_WEEKLY);
		nt.setN(Calendar.MONDAY);
		//每个月第三天
//		nt.setIntervalType(NthIncludedDayTrigger.INTERVAL_TYPE_MONTHLY);
//		nt.setN(3);
		nt.setFireAtTime("12:00:00");
		nt.setStartTime(new Date());//注意,有效时间是从这个启动时间开始算的
  

顾名思义，Trigger 的责任就是触发一个 Job 去执行。当用 Scheduler 注册一个 Job 的时候要创建一个 Trigger 与这个 Job 相关联。Quartz 提供了四种类型的 Trigger，但其中两种是最为常用的，它们就是要用到的 SimpleTrigger 和 CronTrigger. (上面的NthIncludedDayTrigger主要对日期)
SimpleTrigger 是两个之中简单的那个，它主要用来激发单事件的 Job，Trigger 在指定时间激发，并重复 n 次--两次激发时间之间的延时为 m，然后结束作业。CronTrigger 非常复杂且强大。它是基于通用的公历，当需要用一种较复杂的时间表去执行一个 Job 时用到。例如，四月至九月的每个星期一、星期三、或星期五的午夜。
为更简单的使用 Trigger，Quartz 包含了一个工具类，叫做 org.quartz.TriggerUtils. TriggerUtils 提供了许多便捷的方法简化了构造和配置 trigger. 上面用的就是 TriggerUtils 类；
调用了 TriggerUtils 的方法 makeSecondlyTrigger() 来创建一个每2秒种激发一次的 trigger(实际是由 TriggerUtils 生成了一个 SimpleTrigger 实例，但是我们的代码并不想知道这些)。我们同样要给这个 trigger 实例一个名称并告诉它何时激发相应的 Job；与之关联的 Job 会立即启动，因为由方法 setStartTime() 设定的是当前时间。

CronTrigger :

    public void schJob(Scheduler sch,String jobName,Class jobclass,String name,Integer scanInterval) throws SchedulerException{
		
		JobDetail jobDetail=new JobDetail(jobName,Scheduler.DEFAULT_GROUP,jobclass);  
		
		jobDetail.getJobDataMap().put("uname", name);
		
		CronTrigger trigger=null;
		try {
			trigger = new CronTrigger("CronTrigger",null,"1 * * ? * *");
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		/*Trigger trigger=TriggerUtils.makeSecondlyTrigger(scanInterval);
		trigger.setName("DirectoryJob" + "-Trigger");
        trigger.setStartTime(new Date()); 

        //得到当前时间
        Calendar nTime = Calendar.getInstance();
        nTime.add(Calendar.MINUTE, 1);
		trigger.setEndTime(nTime.getTime());
		//trigger.setEndTime(new Date(new Date().getTime() + 30000));
*/        
		sch.scheduleJob(jobDetail, trigger);
	}
  

Quartz 编程式详解