<!-- quartz监听器 -->  
<listener>
    <listener-class>sedion.jeffli.wmuitp.listener.ScheduleStartListener</listener-class>
</listener>

package sedion.jeffli.wmuitp.listener;

import java.util.List;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;

import sedion.jeffli.wmuitp.exception.QuartzException;

public class ScheduleStartListener implements ServletContextListener
{

    public void contextDestroyed(ServletContextEvent sce) 
    {
        
    }

    public void contextInitialized(ServletContextEvent sce) 
    {
        try 
        {
            recovery();
        } 
        catch (Exception e)
        {
            throw new QuartzException(" ScheduleStartListener contextInitialized ERROR!!",e);
        }
    }
    

    public void recovery() 
    {
        
        Scheduler scheduler = null;
        
        try {
            
            SchedulerFactory schedulerFactory = new StdSchedulerFactory();
            scheduler = schedulerFactory.getScheduler();//可以通过SchedulerFactory创建一个Scheduler实例
            List<String> triggerGroups = scheduler.getTriggerGroupNames();//获取调度器中所有的触发器组
            System.out.println("调度器中所有的触发器组 size():"+triggerGroups.size());
            
            if(triggerGroups != null && triggerGroups.size() != 0)//重新恢复在triggerGroups组中所有的触发器
            {
                for (int i = 0; i < triggerGroups.size(); i++) 
                {
                        TriggerKey triggerKey = TriggerKey.triggerKey(triggerGroups.get(i), triggerGroups.get(i));
                        System.out.println("triggerKey:"+triggerKey);
                        
                        Trigger tg = scheduler.getTrigger(triggerKey);//获取trigger
                        System.out.println(triggerKey+" -> 执行时间 :"+tg.getNextFireTime());
                        
                        scheduler.rescheduleJob(triggerKey, tg);//按新的trigger重新设置job执行
                }
            }
            
            scheduler.start();
            
        } 
        catch (Exception e) 
        {
            throw new QuartzException("ScheduleStartListener  recovery() Error!", e);
        }
    }
}

package test.quartz;


import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.TriggerKey;
import org.quartz.impl.StdSchedulerFactory;

import sedion.jeffli.wmuitp.exception.QuartzException;


public class JobTest implements Job{
    
    public JobTest() {}    
  
    public void execute(JobExecutionContext context)throws JobExecutionException
    {  
        
        JobDataMap data = context.getJobDetail().getJobDataMap();
        System.out.println("data.testId : "+data.getInt("testId")); //不需要可删除
        
        try
        {
            System.out.println("添入需要加入任务的具体操作");
        }
        catch (Exception e) 
        {
            throw new QuartzException("JobTest execute() ERROR !!", e);
        }
    }  
    
    public static void removeJob(JobKey jobKey, TriggerKey tiKey)throws SchedulerException
    { 
        
        SchedulerFactory sf     = new StdSchedulerFactory();
        Scheduler          sched     = sf.getScheduler();  
        
        sched.pauseTrigger(tiKey);            //停止触发器  
        sched.unscheduleJob(tiKey);            //移除触发器  
        sched.deleteJob(jobKey);            //删除任务  
        
    } 
}

package test.quartz;

import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;

import java.util.Date;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;


public class QuartzTest
{

    public void run(String date, int id)throws Exception 
    {

        
        SchedulerFactory schedulerFactory = new StdSchedulerFactory();
        Scheduler scheduler = schedulerFactory.getScheduler();//可以通过SchedulerFactory创建一个Scheduler实例
        
        //设置工作详情
        JobDetail job = newJob(JobTest.class) 
            .withIdentity("job_"+id, "test"+id)         // (String name, String group)把触发器在集群节点实例命名的组只是为了区分（伐木）从什么地方定问调度重新执行此作业，如果它是正在进行时调度下去...
            .requestRecovery()                             
            .build();
       
        job.getJobDataMap().put("testId", id);        //设置存储参数(不需要可删除)
        
       
        Date startDate = FormatDate.stringToDateAll(date);//Date转String
        //设置触发器
        SimpleTrigger trigger = (SimpleTrigger) newTrigger()
                .withIdentity("overdue"+id, "overdue"+id)//withIdentity("trigger", "group")
                .startAt(startDate)
                .build();
        
        scheduler.scheduleJob(job, trigger);
        scheduler.start();
        System.out.println("------- Start Scheduler ----------------");
    }
    
    public static void main(String[] args) throws Exception 
    {
        QuartzTest quartzOverdue = new QuartzTest();
        quartzOverdue.run("2014-07-02 00:30:00",666);//666,随便的吉祥数字
    }
}

public static void main(String[] args) throws Exception 
    {
        QuartzTest quartzOverdue = new QuartzTest();
        quartzOverdue.run("2014-07-02 00:30:00",666);//666,随便的吉祥数字
    }

------- Start Scheduler ----------------

添入需要加入任务的具体操作