(一)、调度器是什么?有什么作用?
调度器(Scheduler)是Quartz框架的心脏,用来管理触发器和Job,并保证Job能被触发执行。程序员与框架内部之间的调用都是通过org.quartz.Scheduler接口来完成的。对于Scheduler接口的实现,其实只是核心调度(org.quartz.core.QuartzScheduler)的一个代理,对代理的方法进行调用时会传递到底层核心调度实例上。QuartzScheduler处于Quartz框架的根位置,驱动着整个Quartz框架。
(二)、创建调度器
Scheduler接口有两个实现类,分别为StdScheduler(标准默认调度器)和RemoteScheduler(远程调度器),接下来重点讲述StdScheduler实例。
那么如何创建调度器实例呢?大家可能立马会想到通过new的方式显式的创建StdScheduler实例。StdScheduler只提供了一个带参构造方法,此构造需要传递QuartzScheduler和SchedulingContext两个实例参数:
public StdScheduler(QuartzScheduler sched, SchedulingContext schedCtxt)
然而我们一般不使用构造方法去创建调度器,而是通过调度器工厂来创建。调度器工厂接口org.quartz.SchedulerFactory提供了两种不同类型的工厂实现,分别是org.quartz.impl.DirectSchedulerFactoryh和org.quartz.impl.StdSchedulerFactory,下面我们分别讲述:
(1)、使用DirectSchedulerFactory工厂创建
此工厂方式创建适用于想绝对控制Scheduler实例的场景,下面用最简单的方式通过DirectSchedulerFactory创建一个实例:
public static void main(String[] args) {
try {
DirectSchedulerFactory schedulerFactory = DirectSchedulerFactory.getInstance();
// 表示以3个工作线程初始化工厂
schedulerFactory.createVolatileScheduler(3);
Scheduler scheduler = schedulerFactory.getScheduler();
} catch (SchedulerException e) {
e.printStackTrace();
}
}
创建步骤:
1、通过DirectSchedulerFactory的getInstance方法得到拿到实例
2、调用createXXX方法初始化工厂
3、调用工厂实例的getScheduler方法拿到调度器实例
可以看出,DirectSchedulerFactory是通过createXXX方法传递配置参数来初始化工厂,这种初始化方式是一种硬编码,在工作中用到的情况会很少。
(2)、使用StdSchedulerFactory工厂创建
此工厂是依赖一系列的属性来决定如何创建调度器实例的。
属性提供的方式有三种:
1、通过java.util.Properties属性实例
2、通过外部属性文件提供
3、通过有属性文件内容的 java.io.InputStream 文件流提供
public static void main(String[] args) {
try {
StdSchedulerFactory schedulerFactory = new StdSchedulerFactory();
// 第一种方式 通过Properties属性实例创建
Properties props = new Properties();
props.put(StdSchedulerFactory.PROP_THREAD_POOL_CLASS, "org.quartz.simpl.SimpleThreadPool");
props.put("org.quartz.threadPool.threadCount", 5);
schedulerFactory.initialize(props);
// 第二种方式 通过传入文件名
// schedulerFactory.initialize("my.properties");
// 第三种方式 通过传入包含属性内容的文件输入流
// InputStream is = new FileInputStream(new File("my.properties"));
// schedulerFactory.initialize(is);
// 获取调度器实例
Scheduler scheduler = schedulerFactory.getScheduler();
} catch (Exception e) {
e.printStackTrace();
}
}
- 第一种方式向工厂传入了两个属性,分别是线程池的类名和线程池大小,这两个属性是必须的,因为工厂没有给它们指定默认值。
- 第二种方式是通过定义一个外部属性文件,底层实现是:首先通过Thread.currentThread().getContextClassLoader().getResourceAsStream(filename)获取文件流,然后使用Properties实例的load方法加载文件流形成属性实例,最后在通过initialize(props)初始化完成。
- 第三种方式就是直接使用Properties实例的load方法加载文件流形成属性实例,再在通过initialize(props)初始化完成。
StdSchedulerFactory工厂还提供了无参数的initialize()方法,此方法本质也是通过加载属性文件,initialize()方法总是能加载成功的,因为quartz的jar包中有默认的quartz.properties文件,具体的加载步骤:
1、检查系统属性中是否设置了文件名,通过System.getProperty("org.quartz.properties")
2、如果没有设置,使用默认的quartz.properties作为要加载的文件名
3、然后先从当前工作目录中加载这个文件,如果没有找到,再从系统 classpath 下加载这个文件
StdSchedulerFactory工厂还可以不主动调用initialize()方法进行初始化,而是直接使用StdSchedulerFactory的静态方法getDefaultScheduler()拿到调度器。
(三)、管理调度器
通过上述方法拿到调度器实例以后,在调度的生命周期中可以做以下工作,例如:启动调度器,设置调度器为standby模式,继续或停止调度器。
(1)启动Scheduler
当调度器初始化完成,并且Job和Trigger也注册完成,此时就可以调用scheduler.start()启动调度器了。start()方法一旦被调用,调度器就开始搜索需要执行的Job。
(2)设置standby模式
设置Scheduler为standby模式会让调度器暂停寻找Job去执行。
应用场景举例:当需要重启数据库时可以先将调度器设置为standby模式,待数据库启动完成后再通过start()启动调度器。
(3)停止调度器
调用shutdown()或shutdown(boolean waitForJobsToComplete)方法停止调度器。第二个方法表示等待所有正在执行的job执行完毕后才停止调度器。shutdown方法调用后,就不可以再调用start方法了,因为shutdown方法会销毁Scheduler创建的所有资源(线程、数据库连接等)。
一般情况下,调度器启动后不需要做其他任何事情。
网友评论