企业级任务调度框架Quartz(6) 任务调度器(Scheduler)

2023-02-17,,,,

前序:
     我们已经在前面的内容能里看到了,我们用 Scheduler 来管理我们的 Job;创建并关联触发器以使 Job 能被触发执行;以及如可选择 calendar 为给定的时程安排提供更多的灵活性。

1.Quartz 调度器的介绍

     调度器(Scheduler) 是Quartz 框架的心脏,Scheduler也是 Quartz 的主要 API。对于
Quartz 用户来说,多数时候与框架的交互是发生于 Scheduler  之上的。客服端与 Scheduler 交互是通过
org.quartz.Scheduler接口的。从Quartz内部来说,我们可以从前面看出,它是任务执行的一个平台,如果光有任务没有调度器的存
在,众多任务也不会实现为多任务的批处理;

      我们访问Quartz的时候,其实Scheduler并不是真正的处理类,这个Scheduler
的实现,在这种情况下,是一个代理,对其中方法调用会传递到 QuartzScheduler
实例上。QuartzScheduler对于客户端是不可见的,并且也不存在与此实例的直接交互;

       QuartzScheduler 处在框架根的位置,它是一个引擎驱动着整个框架。并非所有的功能都直接内建到
QuartzScheduler,然而,框架为灵活性和可配置性考虑而设计,所以许多重要的功能由分离的组件和子框架实现。这就意味着 Quartz
用户可以用自己某个关键特征实现来替换原有默认实现。即使 QuartzScheduler 代理了它的一些职责,但它仍然掌控着整个作业调度流程

2.Quartz Scheduler 的类层次

Scheduler为一个接口,客户端会同两种类型的 Scheduler 交互,它们都实现了 

org.quartz.Scheduler 接口。

               Scheduler

StdScheduler        RemoteScheduler;

3.Quartz SchedulerFactory 调度器工厂类

  Quartz SchedulerFactory 为一个创建任务调度器的工厂类;

他的工厂方法来确保了构造出 Sheduler 实例并正确的得到初始化,当 Scheduler
实例被创建之后,就会存到一个仓库中(org.quartz.impl.SchedulerRepository),这个仓库还提供了通过一个
class loader 查询实例的机制。要使用 Scheduler
实例,客户端必须从工厂(和随同的仓库中)使用不同方法调用来获取到它们。换句话说,要通过工厂创建一个 Scheduler
实例并获取到它需要经由两次方法调用。有一些方便的方法封装了那两个方法,你将很快能看到。

一个是create动作,一个是get动作;

SchedulerFactory也只是一个接口,他有具体两个实现类分别为:

 

  a.org.quartz.impl.DirectoSchedulerFactory

  b.org.quartz.impl.StdSchedulerFactory

4.DirectSchedulerFactory

DirectSchedulerFactory 是为那些想绝对控制 Scheduler 实例是如何生产出的人所

设计的。下面的代码显示了最简单的方式去使用 DirectSchedulerFactory

来创建一个 Scheduler 实例。

    /**
    * 测试DirectSchedulerFactory的功能
    * @author liuwei
    *
    */
    public class DirectSchedulerFactoryTest {
    static Log logger = LogFactory.getLog
    (DirectSchedulerFactoryTest.class);
    /**
    * 测试DirectSchedulerFactory的功能
    * @param args
    */
    public static void main(String[] args) {
    DirectSchedulerFactoryTest example=new DirectSchedulerFactoryTest();
    example.startScheduler();
    }
    /**
    *根据DirectSchedulerFactory创建一个任务调度器实例
    */
    public void startScheduler() {
    /*静态方法 getInstance() 获取到工厂的实例*/
    DirectSchedulerFactory factory=DirectSchedulerFactory.getInstance()
    try {
    /*
    * createVolatileScheduler() 方法创建 Scheduler 实例的。
    * 方法 createVolatileScheduler() 带有单个参数:要创建的线程数量
    */
    factory.createVolatileScheduler(10);
    //获取一个任务调度器实例通过工厂类
    Scheduler scheduler = factory.getScheduler();
    //启动该任务调度器,并执行上面注册的作业任务
    logger.info("Scheduler starting up...");
    //启动任务调度器;
    scheduler.start();
    } catch (SchedulerException ex) {
    logger.error(ex);
    }
    }
    }

注意:

在调用 getScheduler() 方法之前调用其中的一个 createXXX 方法 ;

方法 createVolatileScheduler() 方法不会返回 scheduler 的实例。createXXX()
方法是告诉工厂如何配置要创建的 Scheduler 实例。你必须调用方法 getScheduler() 获取到在工厂上执行方法
createXXX() 产生的实例。实际上,在调用 getScheduler() 方法之前,你必须调用其中一个 createXXX()
方法;否则,你将有收到一个 SchedulerException 错误,因为根本没有 Scheduler 实例存在。

我们上面获取的为Scheduler接口的实现StdScheduler的实例,那么我们如何根据factory来创建一个RemoteScheduler呢?

    public void createRemoteScheduler(String rmiHost, int rmiPort)
    throws SchedulerException;
    protected void createRemoteScheduler(String schedulerName,
    String schedulerInstanceId, String rmiHost, int rmiPort)
    throws SchedulerException;

对于标准任务调度器的创建,通过工厂类的createVolatileScheduler()方法是不够的

    public void createScheduler(ThreadPool threadPool, JobStore jobStore)throws SchedulerException;
    public void createScheduler(String schedulerName,
    String schedulerInstanceId, ThreadPool threadPool, JobStore jobStore) throws SchedulerException;
    public void createScheduler(String schedulerName,String
    schedulerInstanceId, ThreadPool threadPool,JobStore jobStore, String rmiRegistryHost, int rmiRegistryPort,long idleWaitTime, long dbFailureRetryInterval)throws SchedulerException;

5.StdSchedulerFactory

   我们都可以看出来,上面DirectSechdulerFactory是通过create的方式来初始化任务调度器的相关信息,我们可否通过文件配置的形式来实现我们的

任务调度器信息的初始化呢?StdSchedulerFactory,另一个 SchedulerFactory
版本,它依赖于一系列的属性来配置 Scheduler,而不是通过 createXXX() 方法参数来传递配置参数。这样也避免了在代码中对
Scheduler 的配置选项的硬编码。

    它提供了三种方式来实现通知工厂类创建任务调度器实例的属性;

    我们可以通过以下三种途径向工厂提供那些属性:

·通过 java.util.Properties 实例提供

·通过外部属性文件提供

·通过含用属性文件内容的 java.io.InputStream 实例提供

下面我们将一个个的来实现上面的三种方式

a.通过java.util.Properties 实例创建 StdSchedulerFactory

    /**
    * 通过java.util.Properties类来实现创建Secheduler
    * @author liuwei
    */
    public class PropertiesStdSechedulerFactory {
    static Log logger = LogFactory.getLog
    (PropertiesStdSechedulerFactory.class);
    /**
    *调度器的执行模拟
    */
    public static void main(String[] args) {
    PropertiesStdSechedulerFactory example = new
    PropertiesStdSechedulerFactory();
    example.startScheduler();
    }
    /**
    * 获取任务调度器方法
    */
    public void startScheduler() {
    /*创建一个StdSchedulerFactory实例*/
    StdSchedulerFactory factory = new StdSchedulerFactory();
    /*创建一个Properties类,来实现对工厂类的属性初始化*/
    Properties props = new Properties();
    /*
    * 初始化两个属性
    * StdSchedulerFactory.PROP_THREAD_POOL_CLASS --
    *  org.quartz.simpl.SimpleThreadPool
    * org.quartz.threadPool.threadCount          --10
    */
    props.put(StdSchedulerFactory.PROP_THREAD_POOL_CLASS,"org.quartz.simpl.SimpleThreadPool");
    props.put("org.quartz.threadPool.threadCount", "10");
    try {
    /*根据属性信息初始化工厂类*/
    factory.initialize(props);
    //获取一个任务调度器实例通过工厂类
    Scheduler scheduler = factory.getScheduler();
    //启动该任务调度器,并执行上面注册的作业任务
    logger.info("Scheduler starting up...");
    scheduler.start();
    } catch (SchedulerException ex) {
    logger.error(ex);
    }
    }
    }

b.外部文件实现属性初始化

   工厂也能通过传入一个外部文件名而被初始化,在这个外部文件中包含了这些配置项。应使用 initialize() 的替代方法形式如下:

    public void initialize(String filename) throws SchedulerException;

Java 属性文件

我们这里使用述语“属性文件”,对于 Java 传统来说就是:在一个外部文件中指定一系列的 key=value  对,并且每个 key=value 对独占一行。

要使文件和属性能被成功加载的话,这个文件必须对于 classloader 是可见的。也就是说它必须在你的应用程序的 classpath 中

c.文件输入流的形式

    假如你用的是 java.io.InputStream 去加载文件,你可以使用另一个 initialize() 的替代方法如下:

    public void initialize(InputStream propertiesStream) throws SchedulerException;

注意,假使我们对于stdSechedulerFactory的initialize没有指定属性,那么 StdSchedulerFactory 会试图从名为 quartz.properties 的文件中加载它们;

对于默认读取properties的过程,分析如下:

·使用默认的 quartz.properties 文件创建 Scheduler

假如你使用无参的 initialize() 方法,StdSchedulerFactory 会执行以下几个步骤去尝试为工厂加载属性:

1).  检查 System.getProperty("org.quartz.properties") 中是否设置了别的文件名

2).  否则,使用 quartz.properties 作为要加载的文件名

3).  试图从当前工作目录中加载这个文件

4).  试图从系统 classpath 下加载这个文件

在 Quartz Jar 包中的默认 quartz.properties 文件

上面第4步总是能成功的,因为在 Quartz Jar 包中有一个默认的 quartz.properties 文件。假如你想使用另一个替代文件,你必须自己创建一个并确保它在 classpath 上。

StdSchedulerFactory 直接提供了一个方便的静态方法 getDefaultScheduler(),它也就是调用了前面的三个initialize方法中的一个;

如果一次initialize方法都没有别调用,则它将调用一个默认的无参initialize方法!也就是说,它将默认将quartz.properties文件做为默认的初始化信息;

任务调度器的作用

Scheduler 的 API 可以分组成以下三个类别:

    ·管理 Scheduler

·管理 Job

·管理 Trigger 和 Calendar

企业级任务调度框架Quartz(6) 任务调度器(Scheduler)的相关教程结束。

《企业级任务调度框架Quartz(6) 任务调度器(Scheduler).doc》

下载本文的Word格式文档,以方便收藏与打印。