Quartz初始化源码跟踪(1)

Quartz调用示例:

  import org.quartz.Scheduler;
  import org.quartz.SchedulerException;
  import org.quartz.impl.StdSchedulerFactory;
  import static org.quartz.JobBuilder.*;
  import static org.quartz.TriggerBuilder.*;
  import static org.quartz.SimpleScheduleBuilder.*;

  public class QuartzTest {

      public static void main(String[] args) {

          try {
              // Grab the Scheduler instance from the Factory
              Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

              // and start it off
              scheduler.start();

              scheduler.shutdown();

          } catch (SchedulerException se) {
              se.printStackTrace();
          }
      }
  }
初始化

可以看到,Quartz的核心调度器是通过工厂创建的。SchedulerFactory两种实现:

schedulerFactory

1.StdSchedulerFactory 根据Properties文件创造QuartzScheduler实例,支持一个JVM多实例创建。
默认的配置文件:quartz.properties.(优先级:当前工作目录>quarz包内)。也可以通过环境变量指定org.quartz.properties
2.DirectSchedulerFactory 工厂的单例实现。

工厂接口如下:

public interface SchedulerFactory{
    //获取一个客户端可用的Scheduler
    Scheduler getScheduler() throws SchedulerException;
    Scheduler getScheduler(String schedName) throws SchedulerException;
    Collection<Scheduler> getAllSchedulers() throws SchedulerException;
}

Std工厂构造Scheduler
获取默认调度器:getDefaultScheduler()

public Schedulerget Scheduler() throws SchedulerException{
        if(cfg == null){
                //加载配置文件
                initialize();
        }
        //获得调度器仓库
        SchedulerRepository schedRep = SchedulerRepository.getInstance();
        //从仓库中加载配置名称的调度器,未配置获取默认名称"QuartzScheduler"的调度器
        **Scheduler sched = schedRep.lookup(getSchedulerName());**
        
        if(sched != null){
                if(sched.isShutdown()){
                        schedRep.remove(getSchedulerName());
                }else{
                        //返回已存在的实例
                        return sched;
                }
        }
        //实例初始化
        sched = instantiate();
        return sched;
}

【单例】SchedulerRepository 调度器仓库,存放所有均由一个Classloader加载的调度器实例的引用,作用:保证调度器实例唯一性,防止GC,允许全局搜索。
内部用一个HashMap成员变量存放调度器实例。
private HashMap<String,Scheduler> schedulers;
提供lookup方法查找调度器 public synchronized Scheduler lookup(StringschedName){
return schedulers.get(schedName);
}

初始化Scheduler调度器实例,核心步骤【代码比较多】

    JobStore js = null; //作业存储器
    ThreadPool tp = null; //调度线程池
    QuartzScheduler qs=null;//调度器实例
    DBConnectionManager dbMgr = null;//jdbc管理
    String instanceIdGeneratorClass=null;
    Properties tProps = null; //线程执行器的一组配置信息
    String userTXLocation=null;
    Boolean wrapJobInTx = false; //是否将任务执行包装成事务
    boolean autoId=false;
    Long idleWaitTime = -1; //线程空闲时间
    long dbFailureRetry=15000L;//15secs
    String classLoadHelperClass;
    String jobFactoryClass;
    ThreadExecutor threadExecutor; //线程执行器


    SchedulerRepository schedRep = SchedulerRepository.getInstance();

    //GetSchedulerProperties
    //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
    //(1)此处代码为加载配置文件构造调度器信息
        //(2)此处代码使用rmi获取远程调度器

    //Get ThreadPool Properties
    //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
    //(2)此处代码为根据配置反射创建初始化线程池

    //GetJobStoreProperties
    //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
    //(3)此处代码为JobStore配置

    //Setup any DataSources
    //~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
    //(4)此处代码为数据库配置




    //注:**调度器必须资源管理类**  --->这里用建造者模式改进~~
    QuartzSchedulerResources rsrcs = new QuartzSchedulerResources();
    rsrcs.setName(schedName); //调度器名称
    rsrcs.setThreadName(threadName); //调度线程名称
    rsrcs.setInstanceId(schedInstId); //实例ID
    rsrcs.setJobRunShellFactory(jrsf); //作业执行终端工厂
    rsrcs.setMakeSchedulerThreadDaemon(makeSchedulerThreadDaemon);
    rsrcs.setThreadsInheritInitializersClassLoadContext(threadsInheritInitalizersClassLoader);
    rsrcs.setRunUpdateCheck(!skipUpdateCheck);
    rsrcs.setBatchTimeWindow(batchTimeWindow);
    rsrcs.setMaxBatchSize(maxBatchSize);
    rsrcs.setInterruptJobsOnShutdown(interruptJobsOnShutdown);
    rsrcs.setInterruptJobsOnShutdownWithWait(interruptJobsOnShutdownWithWait);
    rsrcs.setJMXExport(jmxExport);
    rsrcs.setJMXObjectName(jmxObjectName);
    SchedulerDetailsSetter.setDetails(tp,schedName,schedInstId);
    //设置类执行器并初始化
    rsrcs.setThreadExecutor(threadExecutor);
    threadExecutor.initialize();
    //设置线程池并初始化
    rsrcs.setThreadPool(tp);
    if(tp instanceof SimpleThreadPool){
    if(threadsInheritInitalizersClassLoader)
        ((SimpleThreadPool)tp).setThreadsInheritContextClassLoaderOfInitializingThread(threadsInheritInitalizersClassLoader);
    }
    tp.initialize();
    tpInited=true;
    
    //配置jobstore
    rsrcs.setJobStore(js);

//addplugins
for(inti=0;i<plugins.length;i++){
rsrcs.addSchedulerPlugin(plugins[i]);
}
    
    //调度器实例正式初始化
    qs = new QuartzScheduler(rsrcs,idleWaitTime,dbFailureRetry);
    qsInited = true;

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

推荐阅读更多精彩内容