quartz框架(七)-JobStore

在之前的博文中,博主已经写了关于Job的相关内容。本篇博文,博主将介绍JobStore相关的内容。

JobStore是存放Job和Trigger的地方。当我们调用Scheduler对象的scheduleJob时就会将其存入JobStore中,然后供quartzSchedulerThread使用。

因为我们需要被Scheduler调用的任务大多数并不是一次性的任务,而是需要被定时触发,或者某个时间点才能被触发的。因此我们需要一个容器来存储Job和Trigger的相关内容。

其次,quartz框架还有考虑到持久化存储的场景,比如说将对应的数据存放到数据库,这时候存放或者读取数据库里面的数据都需要有一个与之对应的容器。

JobStore接口中定义的方法太多,这里博主只列出一下比较重要的方法。接口定义如下所示:


public interface JobStore {

   //存储job和tigger
   void storeJobAndTrigger(JobDetail newJob, OperableTrigger newTrigger)
        throws ObjectAlreadyExistsException, JobPersistenceException;

   //获取下一次需要进行触发的触发器
   List acquireNextTriggers(long noLaterThan, int maxCount, long timeWindow)
        throws JobPersistenceException;

   //释放获取到的触发器
   void releaseAcquiredTrigger(OperableTrigger trigger);

   //触发器被触发
   List triggersFired(List triggers) throws JobPersistenceException;

   //触发器触发完成
   void triggeredJobComplete(OperableTrigger trigger, JobDetail jobDetail, CompletedExecutionInstruction triggerInstCode);
}

在quartz的默认配置中使用的就是RAMJobStore。顾名思义,RAMJobStore是基于内存来存储的Job相关数据,也就是在程序重启之后,对应的数据就会消失,并且它不支持集群,也就是说它不可以把需要调度的任务分配到多台机器上面进行执行。博主这里就以RAMJobStore为例,讲解一下RAMJobStore的相关实现。

总体来说,quartzSchedulerThread有设置idlewaitime时间。idlewaitime时间就是在这个空闲时间内如果没有接收到调度器发生变化的信号(sigLock锁的notify),它就会阻塞对应的时间(sigLock的wait(idlewaitime)方法)。因此quartzSchedulerThread需要提前获取到这个(now + idlewaitime)时间点内的trigger,否则会造成触发器失火的情况,并且它会一次性获取当前可用空闲线程个数的trigger。

acquireNextTriggers方法逻辑:

在JobStore中调用triggerWrapper相关的方法时(如triggersFired方法),如果发生了异常,则会调用该方法,将其重新放入timeTriggers中。

releaseAcquiredTrigger方法逻辑:

正常情况下,Job被执行完毕的时候,会通知JobStore执行该方法。

Original: https://www.cnblogs.com/chenhaoblog/p/16000062.html
Author: 幕友皎敖奔乾
Title: quartz框架(七)-JobStore

原创文章受到原创版权保护。转载请注明出处:https://www.johngo689.com/711882/

转载文章受原作者版权保护。转载请注明原作者出处!

(0)

大家都在看

亲爱的 Coder【最近整理,可免费获取】👉 最新必读书单  | 👏 面试题下载  | 🌎 免费的AI知识星球