三、Quartz中Scheduler的理解和使用

(一)、调度器是什么?有什么作用?

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

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

到此,调度器讲述完毕,如果大家有什么问题,请在下方留言,谢谢!
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 220,884评论 6 513
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 94,212评论 3 395
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 167,351评论 0 360
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 59,412评论 1 294
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 68,438评论 6 397
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 52,127评论 1 308
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 40,714评论 3 420
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 39,636评论 0 276
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 46,173评论 1 319
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 38,264评论 3 339
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 40,402评论 1 352
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 36,073评论 5 347
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 41,763评论 3 332
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 32,253评论 0 23
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 33,382评论 1 271
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 48,749评论 3 375
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 45,403评论 2 358

推荐阅读更多精彩内容