Quartz任务调度(4)JobListener分版本超详细解析

JobListener

1. 自定义监听器接口实现类

public class MyJobListener implements JobListener {

@Override//相当于为我们的监听器命名
public String getName() {
return "myJobListener";
}

@Override
public void jobToBeExecuted(JobExecutionContext context) {
System.out.println(getName() + "触发对"+context.getJobDetail().getJobClass()+"的开始执行的监听工作，这里可以完成任务前的一些资源准备工作或日志记录");
}

@Override//“否决JobDetail”是在Triiger被其相应的监听器监听时才具备的能力
public void jobExecutionVetoed(JobExecutionContext context) {
System.out.println("被否决执行了，可以做些日志记录。");
}

@Override
public void jobWasExecuted(JobExecutionContext context,
JobExecutionException jobException) {
System.out.println(getName() + "触发对"+context.getJobDetail().getJobClass()+"结束执行的监听工作，这里可以进行资源销毁工作或做一些新闻扒取结果的统计工作");

}

}

2. 在scheduler中注册监听器

1. 准备工作

public class PickNewsJob implements Job {

@Override
public void execute(JobExecutionContext jec) throws JobExecutionException {
SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
System.out.println("在" + sdf.format(new Date()) + "扒取新闻");
}
}

public class GetHottestJob implements Job {

@Override
public void execute(JobExecutionContext jec) throws JobExecutionException {
SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
System.out.println("在" + sdf.format(new Date()) +"根据文章的阅读量和评论量来生成我们的最热文章列表");
}

}

2. 1.x版本配置

/**********局部监听器配置**********/
JobListener myJobListener = new MyJobListener();
pickNewsJob.addJobListener("myJobListener");//这里的名字和myJobListener中getName()方法的名字一样
scheduler.addJobListener(myJobListener);//向scheduler注册我们的监听器
/*********全局监听器配置************/
JobListener myJobListener = new MyJobListener();
scheduler.addGlobalJobListener(myJobListener);//直接添加为全局监听器

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();
pickNewsJob.addJobListener("myJobListener");//这里的名字和myJobListener中getName()方法的名字一样
scheduler.addJobListener(myJobListener);//向scheduler注册我们的监听器
/*********全局监听器配置************/
//      JobListener myJobListener = new MyJobListener();
//      scheduler.addGlobalJobListener(myJobListener);//直接添加为全局监听器

scheduler.scheduleJob(pickNewsJob,pickNewsTrigger);
scheduler.scheduleJob(getHottestJob,getHottestTrigger);

scheduler.start();

}

3. 2.x版本配置

1. ListenerManager

2. matcher

KeyMatcher<JobKey>

/************构造Matcher方法************/
KeyMatcher<JobKey> keyMatcher = KeyMatcher.keyEquals(pickNewsJob.getKey());//构造匹配pickNewsJob中的JobKey的keyMatcher。

/*********使用方法************/
scheduler.getListenerManager().addJobListener(myJobListener, keyMatcher);//通过这句完成我们监听器对pickNewsJob的唯一监听

GroupMatcher<JobKey> groupMatcher = GroupMatcher.jobGroupContains("group1");//包含特定字符串
GroupMatcher.groupEndsWith("oup1");//以特定字符串结尾
GroupMatcher.groupEquals("jgroup1");//以特定字符串完全匹配
GroupMatcher.groupStartsWith("jgou");//以特定字符串开头

KeyMatcher<JobKey> keyMatcher = KeyMatcher.keyEquals(pickNewsJob.getKey());
GroupMatcher<JobKey> groupMatcher = GroupMatcher.jobGroupContains("group1");
AndMatcher<JobKey> andMatcher = AndMatcher.and(keyMatcher,groupMatcher);//同时满足两个入参匹配

OrMatcher<JobKey> orMatcher = OrMatcher.or(keyMatcher, groupMatcher);//满足任意一个即可

EverythingMatcher.allJobs();//对全部JobListener匹配
EverythingMatcher.allTriggers();//对全部TriggerListener匹配

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);
scheduler.scheduleJob(pickNewsJob, pickNewsTrigger);
scheduler.scheduleJob(getHottestJob,getHottestTrigger);
scheduler.start();
}

源码下载