Quartz建立多个不一样名字的scheduler实例

  • _http://my.oschina.net/laiweiwei/blog/122280
      • 需求
        建立多个不一样的Scheduler实例,每一个实例自主启动、关闭    

      • 问题
        若是直接用
      • SchedulerFactory sf = newStdSchedulerFactory();
      • Scheduler scheduler = sf.getScheduler();
      • 获取的scheduler是从仓储SchedulerRepository里面取出来的,仓储注册scheduler的时候为每一个scheduler分配 一个惟一的名字,问题就在于这里,Quartz默认有个配置文件quartz.properties,里面定义了这个名字,这样的话,每次经过 sf.getScheduler()获取的都是同一个实例,(假设你认为get出来的都是不一样实例)把其中的某一个shceduler shutdown的话,其余scheduler也会关闭掉,由于它们实际上是同一个实例!

        尝试使用:
      • sf.getScheduler("给定名字")
      • 发现返回的都是null,翻看源码,此方法并无进行建立对象的逻辑。而仅仅是lookup而已!

        而后再尝试经过DirectSchedulerFactory.getInstance().createXXX的方法建立Scheduler实例,结果发现这些方法的参数...:
      • .createScheduler(schedulerName, schedulerInstanceId, threadPool, jobStore);
      • 这确实很灵活!可是真TM底层!忽然感到很无奈。

        Google了好久,StackOverFlow上面也有相似的问题,可是都说没有API直接提供建立给定名字的Scheduler实例。可是无心中想起 来,Quartz貌似支持配置文件初始化的,因而翻到了Quartz的默认配置文件(在其jar包里)quartz.properties。
      • # Default Properties file for use by StdSchedulerFactory

        # to create a Quartz Scheduler Instance, if a different

        # properties file is not explicitly specified.


            org.quartz.scheduler.instanceName: DefaultQuartzScheduler

            org.quartz.scheduler.rmi.export: false

            org.quartz.scheduler.rmi.proxy: false

            org.quartz.scheduler.wrapJobExecutionInUserTransaction: false


            org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool

            org.quartz.threadPool.threadCount: 10

            org.quartz.threadPool.threadPriority: 5

            org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true


            org.quartz.jobStore.misfireThreshold: 60000


          org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore
    • 因而就照葫芦画瓢的,将这些配置内容拷贝一份,在代码里写到一个Properties里面,而后调用初始化方法。搞定!

    • 解决方案
      显式使用StdSchedulerFactory,调用其initialize方法,而且本身定义填写配置内容:
    • 1    StdSchedulerFactory sf = new StdSchedulerFactory();
      2    Properties props = new Properties();
      3    props.put("org.quartz.scheduler.instanceName", "你定义的名字");
      4    props.put("org.quartz.threadPool.threadCount", "10");#必填
      5    sf.initialize(props);
      6    scheduler = sf.getScheduler();
      7    System.out.println(scheduler.getSchedulerName());
      8    scheduler.shutdown();
    • 以上方案经过初步测试使用。可是还须要在生产环境下使用看看......反馈状况将在这里补填

      =================== 最新反馈 2013-05-08 11:39 ========================
      通过近两个月的生产环境使用,发现以上解决方案可行,推荐使用之
相关文章
相关标签/搜索