Quartz 监听器的应用

当我在项目中用到任务调用的时候，有必要在每次调用任务和任务出现错误的时候有详细的记录过程。在这个时候我想到了监听器的使用。

 

Quartz实现自己的JobListener和TriggerListener

我们是能对Job和Trigger创建自己的监听器的.

MyTriggerListener:

package com;

import org.quartz.JobExecutionContext;
import org.quartz.Trigger;
import org.quartz.TriggerListener;
/** *//**
 * 
 * @author zdw
 *
 */
public class MyTriggerListener implements TriggerListener
{

    public String getName()
    {
        return "myTriggerListener";
    }

    public void triggerComplete(Trigger trigger, JobExecutionContext jeContext,
            int arg2)
    {
        System.out.println("triggerName:" + trigger.getName());
        System.out.println("complete");
    }

    public void triggerFired(Trigger arg0, JobExecutionContext arg1)
    {
        System.out.println("fire");
        System.out.println("trigger" + arg0.getGroup());
    }

    public void triggerMisfired(Trigger arg0)
    {
        System.out.println("triggerMisfired");
    }

    public boolean vetoJobExecution(Trigger arg0, JobExecutionContext arg1)
    {
        System.out.println("vetoJobException");
        return false;
    }

}

MyJobDetailListener:

package com;

import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobListener;
/** *//**
 * 
 * @author zdw
 *
 */
public class MyJobDetailListener implements JobListener
{
    /** *//**
     * 注意name是必须的
     */
    public String getName()
    {
        return "myJobListener";
    }

    public void jobExecutionVetoed(JobExecutionContext arg0)
    {
        System.out.println("jobExceution");
    }

    public void jobToBeExecuted(JobExecutionContext arg0)
    {
        System.out.println("jobTobeExecuted");
    }

    public void jobWasExecuted(JobExecutionContext arg0,
            JobExecutionException arg1)
    {
        System.out.println("job was executed");
    }

}

上面两个类只要注意name是必须的就可以了.

package com;

import java.util.Date;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.TriggerUtils;
import org.quartz.impl.StdSchedulerFactory;

/** *//**
 * 
 * @author zdw
 * 
 */
public class QuartzTest
{

    public static void main(String args[])
    {
        // 得到可用客户端处理调度程序的工厂
        SchedulerFactory schedFact = new StdSchedulerFactory();
        // 高度程序接口,控制JobDeail和Trigger
        try
        {
            Scheduler sched = schedFact.getScheduler();
            // 表示给定工作类的详细信息
            JobDetail jobDetail = new JobDetail("myJb", null, StringTest.class);
            // 也可以分别设置
            jobDetail.setName("angel");
            jobDetail.setGroup("007");
            jobDetail.setJobClass(StringTest.class);
            jobDetail.getJobDataMap().put("jobSays", "I will be success!!");
            // 触发器
            Trigger trigger = TriggerUtils.makeSecondlyTrigger();
            // 设置开始时间,这时设置的是每一秒执行一次
            trigger.setStartTime(TriggerUtils
                    .getEvenSecondDateBefore(new Date()));
            // 必须设置,不能为空
            trigger.setName("firstTrigger");
            // 使用自己的监听器
            MyTriggerListener triggerListener = new MyTriggerListener();
            sched.addTriggerListener(triggerListener);
            sched.addJobListener(new MyJobDetailListener());
            // 匹配(必须操作）
            trigger.addTriggerListener("myTriggerListener");
            jobDetail.addJobListener("myJobListener");
            // 为调度程序设置具体工作和触发器
            sched.scheduleJob(jobDetail, trigger);
            // fire
            sched.start();
        } catch (SchedulerException e)
        {
            e.printStackTrace();
        }
    }
}

注意:

// 匹配(必须操作）
            trigger.addTriggerListener("myTriggerListener");
            jobDetail.addJobListener("myJobListener");

这两步是必须的,官方文档没有提及,而且必须在scheduler添加完相应的监听器之后．
这时我们看到输出:

vetoJobException
jobTobeExecuted
execute at Fri May 09 09:24:11 CST 2008
instName:angel  instGroup:007 jobSays:I will be success!!
job was executed
triggerName:firstTrigger
complete
fire
triggerDEFAULT
vetoJobException
jobTobeExecuted
execute at Fri May 09 09:24:12 CST 2008
instName:angel  instGroup:007 jobSays:I will be success!!
job was executed
triggerName:firstTrigger
complete

我们自己的监听器已经被执行了．