三、Quartz中Scheduler的理解和使用

作者: ChienSun | 来源:发表于2018-02-02 17:20 被阅读0次
    (一)、调度器是什么?有什么作用?

      调度器(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创建的所有资源(线程、数据库连接等)。

    一般情况下,调度器启动后不需要做其他任何事情。

    到此,调度器讲述完毕,如果大家有什么问题,请在下方留言,谢谢!

    相关文章

      网友评论

        本文标题:三、Quartz中Scheduler的理解和使用

        本文链接:https://www.haomeiwen.com/subject/nlbdzxtx.html