上一篇咱们整理学习了Java调度框架Quartz的1+版本,这才咱们看一下Quartz的2+版本和2以下版本的有什么区别。无非就是几个步骤,1.创建调度器,2.创建作业任务,3.创建触发器并设置触发器的出发执行规则,4.开始调度。那么Quartz 2版本有什么区别呢,直接上代码直接一点:
还是那几步,我就不一一罗列了。
首先是Job作业的任务逻辑:实现Job interface
package com.traning.quartz.quartz2_1_7;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* Created by luyang.li on 17/2/8.
*/
public class QuartzTestJob implements Job {
public void execute(JobExecutionContext context) throws JobExecutionException {
System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "Quartz 2.1.7 Test");
}
}
具体的任务:
package com.traning.quartz.quartz2_1_7;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
import static org.quartz.TriggerBuilder.newTrigger;
/**
* Created by luyang.li on 17/2/13.
*/
public class QuartzTestApp {
public static void main(String[] args) throws SchedulerException, InterruptedException {
//获取 调度器
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
//获取 任务作业
JobDetail jobDetail = newJob(QuartzTestJob.class).withIdentity("groupJobName", "group1").build();
//获取 触发器
Trigger trigger = newTrigger().withIdentity("triggerName", "group1").startNow().build();
//绑定
scheduler.scheduleJob(jobDetail, trigger);
scheduler.start();
Thread.sleep(10);
scheduler.shutdown();
}
}
咱们直接执行这个方法就可以看见任务执行了,为什么要调用这个
scheduler.shutdown();
方法呢,应为Quartz任务在执行的时候不会显示关闭任务,就算主线程执行完毕了,任务还是在执行中,咱们就直接调用shutdown关闭。
咱们看一下两者的区别就是创建任务和触发器的时候使用的方式不同了在构造作业和触发器的时候都是构造他的 组 和 名,只是使用了不同的方式。来看一下源码:
public Key(String name, String group) {
if(name == null)
throw new IllegalArgumentException("Name cannot be null.");
this.name = name;
if(group != null)
this.group = group;
else
this.group = DEFAULT_GROUP;
}
其实和1+版本的作用都是一样的,构造作业的时候是绑定作业的类,然后构造 组 + 名,构造触发器的手也是同样的构造触发器的 组 + 名。
大家可以执行以下看一下结果,我就不贴结果了。
下面咱们看一下2+版本的SimpleTrigger的构造器的使用:SimpleTrigger上一节咱们说是简单的构造器执行方式
1.和1版本一样来看下这个方法:
public SimpleScheduleBuilder withIntervalInMinutes(int intervalInMinutes)
这个方法就是设置执行的间隔,参数是一个int值,再看下他的源码:
public SimpleScheduleBuilder withIntervalInMinutes(int intervalInMinutes) {
this.interval = intervalInMinutes * DateBuilder.MILLISECONDS_IN_MINUTE;
return this;
}
这个常量是:
public static final long MILLISECONDS_IN_MINUTE = 60l * 1000l;
我们可以看出来是单位是分钟!!!好了有执行间隔了,执行次数呢:
还有一个函数是设置执行次数:
public SimpleScheduleBuilder withRepeatCount(int triggerRepeatCount) {
this.repeatCount = triggerRepeatCount;
return this;
}
这个函数就是设置执行次数。
好了直接看下整体的代码:
package com.traning.quartz.quartz2_1_7;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleTrigger;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
import static org.quartz.TriggerBuilder.newTrigger;
/**
* Created by luyang.li on 17/2/13.
*/
public class QuartzTestApp {
public static void main(String[] args) throws SchedulerException, InterruptedException {
//获取 调度器
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();
//获取 任务作业
JobDetail jobDetail = newJob(QuartzTestJob.class).withIdentity("groupJobName", "group1").build();
//获取 触发器 !!!!!!
Trigger trigger = newTrigger().withSchedule(simpleSchedule()
.withIntervalInMinutes(1) // 1分钟
.withRepeatCount(20)) // 重复20次
.startNow()
.build();
//绑定
scheduler.scheduleJob(jobDetail, trigger);
scheduler.start();
}
}
这里我把关闭方法去掉了,因为任务要执行20次,不然要睡眠等到任务结束才可以调用关闭,大家自己执行下看看效果。
怎么样简单吧。好了下一节咱们看下 1+ 版本和 2+版本的CronTrigger的使用。