package com.taobao.terminator.allen.QuartzTest;import org.apache.commons.logging.Log;import org.apache.commons.logging.LogFactory;import org.quartz.CronTrigger;import org.quartz.JobDetail;import org.quartz.JobListener;import org.quartz.Scheduler;import org.quartz.SchedulerFactory;import org.quartz.impl.StdSchedulerFactory;public class QuartzTest {    private final static Log logger = LogFactory.getLog(QuartzTest.class);    public static void main(String[] args) {        System.out.println("this is test for Quartz");        //初始化scheduler工厂类        SchedulerFactory factory = new StdSchedulerFactory();                try {            //DirectSchedulerFactory生成一个实例，可create一个带名字的shceduler            Scheduler shceduler = factory.getScheduler();                        //Quartz监听器，分为全局和局部的。局部的需要在特定的jobDetail中重回一次，全局不需要            JobListener jobListener = new QuartzListener("quartz - test");            shceduler.addJobListener(jobListener);                        //Shceduler的Context类似于servlet的context，功能相似.Context会传递给监听器            shceduler.getContext().put("coreName", "coreName");                        //同样可以保存context的key-value ,jobDetail.getJobDataMap()            JobDetail jobDetail = new JobDetail("Full-Detail", "Full-Detail-Group", QuartzJob.class);            jobDetail.addJobListener("quartz - test");            jobDetail.getJobDataMap().put("jobDetail-data", "jobDetail");                        //生成触发器            CronTrigger trigger = new CronTrigger("Full-Trigger" , "Full-Trigger-Group");            trigger.setCronExpression("0/30 * * * * ?");                        //添加job            shceduler.scheduleJob(jobDetail, trigger);                        //开始执行shceduler            shceduler.start();                        while(true) {                Thread.sleep(1000 * 10);                System.out.println("触发定时任务");                                shceduler.triggerJob("Full-Detail", "Full-Detail-Group");                                Thread.sleep(1000 * 40);                                //终止正在运行的job                shceduler.interrupt("Full-Detail", "Full-Detail-Group");                System.out.println("the schedule is over");                                //关闭定时器                shceduler.shutdown();                                break;            }        } catch (Exception e) {            logger.error("生成调试器失败" , e);        }    }}

package com.taobao.terminator.allen.QuartzTest;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;import org.quartz.JobListener;public class QuartzListener implements JobListener{    private String listenerName = "quartz-listener";        public QuartzListener(String listenerName) {        this.listenerName = listenerName;    }        public String getName() {        return this.listenerName;    }    public void jobToBeExecuted(JobExecutionContext context) {        System.out.println("the job listener is start");            }    public void jobExecutionVetoed(JobExecutionContext context) {    }    public void jobWasExecuted(JobExecutionContext context,            JobExecutionException jobException) {        System.out.println("the job listener is end");    }}

import org.quartz.InterruptableJob;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;import org.quartz.UnableToInterruptJobException;public class QuartzJob implements InterruptableJob{    private boolean stop = false ;    public void execute(JobExecutionContext context) throws JobExecutionException {        if(!this.stop) {            System.out.println("this is ok");        }    }    public void interrupt() throws UnableToInterruptJobException {        this.stop = true ;        System.out.println("it is over");    }        public boolean isStop() {        return stop;    }}