public class MyTriggerListener implements TriggerListener {

    @Override

    public String getName() {

        return "myTriggerListener";

    }

    @Override

    public void triggerFired(Trigger trigger, JobExecutionContext context) {

        System.out.println(" Trigger 被触发了，此时Job 上的 execute() 方法将要被执行");

    }

    @Override

    public boolean vetoJobExecution(Trigger trigger, JobExecutionContext context) {

        System.out.println("发现此次Job的相关资源准备存在问题，不便展开任务，返回true表示否决此次任务执行");

        return true;

    }

    @Override

    public void triggerMisfired(Trigger trigger) {

        System.out.println( "当前Trigger触发错过了");

    }

    @Override//1.+版本

    public void triggerComplete(Trigger trigger, JobExecutionContext context,

            int triggerInstructionCode) {

        System.out.println("Trigger 被触发并且完成了 Job 的执行,此方法被调用");

    }

    /*

    @Override//这是2.+版本的配置，差别在于将triggerInstructionCode从整型改成了枚举类型

    public void triggerComplete(Trigger trigger, JobExecutionContext context,

            CompletedExecutionInstruction triggerInstructionCode) {

        System.out.println("Trigger 被触发并且完成了 Job 的执行,此方法被调用");

    }

    */

}

public static void main(String args[]) throws SchedulerException {

    JobDetail pickNewsJob =new JobDetail("job1", "jgroup1", PickNewsJob.class);

    JobDetail getHottestJob =new JobDetail("job2", "jgroup2", GetHottestJob.class);

    SimpleTrigger pickNewsTrigger = new SimpleTrigger("trigger1", "group1",1,2000);

    SimpleTrigger getHottestTrigger = new SimpleTrigger("trigger2", "group2",1,3000);

    SchedulerFactory schedulerFactory = new StdSchedulerFactory();

    Scheduler scheduler = schedulerFactory.getScheduler();

    JobListener myJobListener = new MyJobListener();

    /**********局部Job监听器配置**********/

        pickNewsJob.addJobListener("myJobListener");//这里的名字和myJobListener中getName()方法的名字一样

    scheduler.addJobListener(myJobListener);//向scheduler注册我们的监听器

    /*********全局Job监听器配置************/

//      scheduler.addGlobalJobListener(myJobListener);//直接添加为全局监听器

    TriggerListener myTriggerListener = new MyTriggerListener();

    /**********局部Trigger监听器配置**********/

    pickNewsTrigger.addTriggerListener("myTriggerListener");

    scheduler.addTriggerListener(myTriggerListener);

    /*********全局Trigger监听器配置************/

//      scheduler.addGlobalTriggerListener(myTriggerListener);//直接添加为全局监听器

    scheduler.scheduleJob(pickNewsJob,pickNewsTrigger);

    scheduler.scheduleJob(getHottestJob,getHottestTrigger);

    scheduler.start();

}

@Override

public boolean vetoJobExecution(Trigger trigger, JobExecutionContext context) {

//      System.out.println("发现此次Job的相关资源准备存在问题，不便展开任务，返回true表示否决此次任务执行");

//      return true;

    System.out.println("不否决Job,正常执行");

    return false;

}

public static void main(String args[]) throws SchedulerException {

    final JobDetail pickNewsJob = JobBuilder.newJob(PickNewsJob.class)

            .withIdentity("job1", "jgroup1").build();

    JobDetail getHottestJob = JobBuilder.newJob(GetHottestJob.class)

            .withIdentity("job2", "jgroup2").build();

    SimpleTrigger pickNewsTrigger = TriggerBuilder

            .newTrigger()

            .withIdentity("trigger1","tgroup1")

            .withSchedule(SimpleScheduleBuilder.repeatSecondlyForTotalCount(2, 1)).startNow()

            .build();

    SimpleTrigger getHottestTrigger = TriggerBuilder

            .newTrigger()

            .withIdentity("trigger2","tgroup2")

            .withSchedule(SimpleScheduleBuilder.repeatSecondlyForTotalCount(2, 2)).startNow()

            .build();

    Scheduler scheduler = new StdSchedulerFactory().getScheduler();

    JobListener myJobListener = new MyJobListener();

    KeyMatcher<JobKey> keyMatcher = KeyMatcher.keyEquals(pickNewsJob.getKey());

    scheduler.getListenerManager().addJobListener(myJobListener, keyMatcher);

    /********下面是新加部分***********/

    TriggerListener myTriggerListener = new MyTriggerListener();

    KeyMatcher<TriggerKey> tkeyMatcher = KeyMatcher.keyEquals(pickNewsTrigger.getKey());

    scheduler.getListenerManager().addTriggerListener(myTriggerListener, tkeyMatcher);

    scheduler.scheduleJob(pickNewsJob, pickNewsTrigger);

    scheduler.scheduleJob(getHottestJob,getHottestTrigger);

    scheduler.start();

}