一.概述
listener是一个监听器对象，用于监听scheduler中发生的事件，然后执行相应的操作；你可能已经猜到了，TriggerListeners接受与trigger相关的事件，JobListeners接受与jobs相关的事件。
二.JobListener监听器
定义job类，用来打印任务详情，代码如下：
package com.ickes.job;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
/**
* 实现Job接口，定义运行的任务
* @author Ickes
*/
public class SimpleJob implements Job {
public void execute(JobExecutionContext context)
throws JobExecutionException {
//打印任务详情
System.out.println(
context.getJobDetail().getGroup()
+"——"+context.getJobDetail().getName()
+"——"+context.getTrigger().getName()
+"——"+context.getTrigger().getGroup());
}
}
JobListener监听器类，代码如下：
package com.ickes.job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobListener;
/**
* JobListener监听器
* @author Ickes
*/
public class Job1Listener implements JobListener {
/**
* 返回当前监听器的名字，这个方法必须被写他的返回值；
* 因为listener需要通过其getName()方法广播它的名称
*/
public String getName() {
return "Job1Listener";
}
/**
* 任务被触发前触发
*/
public void jobToBeExecuted(JobExecutionContext context) {
System.out.println(context.getJobDetail().getName()+":A");
}
/**
* 这个不管
*/
public void jobExecutionVetoed(JobExecutionContext context) {
System.out.println(context.getJobDetail().getName()+":B");
}
/**
* 任务调度完成后触发
*/
public void jobWasExecuted(JobExecutionContext context,
JobExecutionException jobException) {
System.out.println(context.getJobDetail().getName()+":C");
}
}
JobListener监听器测试类，代码如下：
package com.ickes.job;
import java.util.Date;
import org.quartz.JobDetail;
import org.quartz.JobListener;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;
/**
* @author Ickes
*/
public class ListenerDemo {
public static void main(String[] args) throws Exception {
//第一步：创建一个JobDetail实例
JobDetail jobDetail = new JobDetail("j_job1","j_group1", SimpleJob.class);
//第二步：通过SimpleTrigger触发器定义调度规则：马上启动，每2秒运行一次，共运行100次
SimpleTrigger simpleTrigger = new SimpleTrigger("t_job1","t_group1");
simpleTrigger.setStartTime(new Date());
simpleTrigger.setEndTime(new Date(System.currentTimeMillis()+1000*5));
simpleTrigger.setRepeatInterval(2000); //运行间隔单位为毫秒
simpleTrigger.setRepeatCount(10); //运行次数
//第三步：通过SchedulerFactory获取一个调度器实例
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
//第四步：关联监听器
JobListener listener = new Job1Listener();
scheduler.addJobListener(listener);
jobDetail.addJobListener(listener.getName());
//第五步：将job跟trigger注册到scheduler中进行调度
scheduler.scheduleJob(jobDetail, simpleTrigger);
//第六步：调度启动
scheduler.start();
}
}
三.TriggerListener监听器
Trigger1Listener监听器类，该类实现了TriggerListener接口，代码如下：
package com.ickes.job;
import org.quartz.JobExecutionContext;
import org.quartz.Trigger;
import org.quartz.TriggerListener;
/**
*
* @author Ickes
*
*/
public class Trigger1Listener implements TriggerListener {
public String getName() {
return "Trigger1Listener";
}
/**
* 被调度时触发，和它相关的org.quartz.jobdetail即将执行。
* 该方法优先vetoJobExecution()执行
*/
public void triggerFired(Trigger trigger, JobExecutionContext context) {
System.out.println("A");
}
/**
* 被调度时触发，和它相关的org.quartz.jobdetail即将执行。
*/
public boolean vetoJobExecution(Trigger trigger, JobExecutionContext context) {
System.out.println("B");
return false;
}
/**
* 被调度时，触发失败时触发
*/
public void triggerMisfired(Trigger trigger) {
System.out.println("C");
}
/**
* 执行完毕时触发
*/
public void triggerComplete(Trigger trigger, JobExecutionContext context,
int triggerInstructionCode) {
System.out.println("D");
}
}
TriggerListener监听器测试类TriggerListenerDemo代码如下：
package com.ickes.job;
import java.util.Date;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.TriggerListener;
import org.quartz.impl.StdSchedulerFactory;
/**
* @author Ickes
*/
public class TriggerListenerDemo {
public static void main(String[] args) throws Exception {
//第一步：创建一个JobDetail实例
JobDetail jobDetail = new JobDetail("j_job1","j_group1", SimpleJob.class);
//第二步：通过SimpleTrigger触发器定义调度规则：马上启动，每2秒运行一次，共运行100次
SimpleTrigger simpleTrigger = new SimpleTrigger("t_job1","t_group1");
simpleTrigger.setStartTime(new Date());
//5秒钟还有任务没有完成，所以
simpleTrigger.setEndTime(new Date(System.currentTimeMillis()+1000*5));
simpleTrigger.setRepeatInterval(2000); //运行间隔单位为毫秒
simpleTrigger.setRepeatCount(10); //运行次数
//第三步：通过SchedulerFactory获取一个调度器实例
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
//第四步：关联监听器
TriggerListener listener = new Trigger1Listener();
scheduler.addTriggerListener(listener);
simpleTrigger.addTriggerListener(listener.getName());
//第五步：将job跟trigger注册到scheduler中进行调度
scheduler.scheduleJob(jobDetail, simpleTrigger);
//第六步：调度启动
scheduler.start();
}
}
您还没有登录,请您登录后再发表评论