quartz源码解析--转

quartz源码解析(一)  、

http://ssuupv.blog.163.com/blog//146156722013829111028966/

任何个人、任何企业、任何行业都会有作业调度的需求。举几个简单的例子:

1、每个月都会发工资,每个月都要报销等;

2、每个人每天都要吃饭和睡觉;

3、每个公司都有会计帐期,都需要向公司领导汇报月报、季报、年报等。

4、银行和金融行业每天都需要日切等等。

对于个人,对作业调度的感知不是非常明确,但对于一个企业,一个好的作业调度可以为企业节省很多时间和金钱。俗话说,时间就是金钱,过高的资源投入到枯燥的任务中无疑是金钱和资源的浪费,随着业务流程复杂性的提高,自动化流程和自动化作业调度更能凸显出益处来。之所以自动化的出现,因为在做重复性工作时,人的效率和正确率远低于电脑。把一系列任务自动安排到一个作业中,然后再为这个作业创建一个调度器,到时候这个作业就会自动执行了。

Quartz是经典的作业调度框架,在深入研究之初,先仿照quartz的原理,设计一个简单的作业调度器,类图如下:

quartz源码解析--转

1、  先看job类,这个类,非常简单,只有一个execute方法,该方法是job具体执行的内容:

quartz源码解析--转

2、  jobdetail类,该类是对具体job类的封装,包括jobName(id),job执行需要的运行时参数,在名为jobdata的hashMap中

quartz源码解析--转

quartz源码解析--转

3、  trigger类,记录下次运行作业的时间和运行job的key:

quartz源码解析--转

4、  scheduler类,最重要的类,用来启动和停止框架

quartz源码解析--转

quartz源码解析--转

5、  scheduler的执行是在scheduler的schedulerThread中执行;线程中最重要的是run方法体,另外还有一个halt方法用来停止线程。先看halt方法

quartz源码解析--转

Run方法体为:

quartz源码解析--转

quartz源码解析--转

至此所有的框架代码都已经完成。注:没有考虑NullPointException和多线程问题。

再看下测试代码:

quartz源码解析--转

结果

quartz源码解析--转

系统按照下次运行时间来执行,并成功显示结果。

本章只是在抽取quartz的核心处理逻辑的基础智商,去除安全验证和多线程同步问题编写的基本调度任务。仅为抛砖引玉,为quartz源码的解析打个基础。

quartz框架分析(二)

http://ssuupv.blog.163.com/blog/static/146156722013829324461/

Quartz框架执行的任务需要写在一个实现Job接口的类中,在实现类中的execute(JobExecutionContext context)中执行相关的操作,通过实现Job接口来使你的Java 组件可以很简单的被scheduler执行,下面是job接口:

quartz源码解析--转

如上,你会看到job触发器出发时,job的execute方法会被执行。那么,scheduler的job是通过何种方式创建和执行的呢。先来看看job的部署,job是通过jobdetail scheduler到框架中去的,然后通过getJobClass()方法获取到job实现类的class字节码的,通过jobFactory的newJob()方法反射出Java 的具体实例,然后在JobRunShell线程对象的run方法中执行。

1、  先看看jobdetail的创建,在quartz2.0中,jobdetail是通过jobbuilder创建

quartz源码解析--转

Jobbuilder通过静态方法newjob()不同重载来创建Jobbuilder,通过withIdentity()重载设置参数,如下:

quartz源码解析--转

quartz源码解析--转

2、  创建号jobdetail后,scheduler通过线程类JobRunShell来执行Job。

通过initialize方法中调用JobFactory的newJob()创建Job实例。

quartz源码解析--转

JobFactory的newJob()方法通过反射使用默认无参数的构造方法实现job实例创建,如下:quartz源码解析--转

Job的执行很简单,直接调用execute方法即可,以下代码省略中间检查部分:

quartz源码解析--转

Job的实现和执行很简单, 主要是业务逻辑,以下简单的把类之间的关系整理下:

quartz源码解析--转

quartz源码简析(三)

http://ssuupv.blog.163.com/blog/static/14615672201382931053129/

Quartz Trigger 部分

Trigger用来记录job任务的运行时间,运行次数等信息。Trigger的基本类图如下:

quartz源码解析--转

1、trigger接口主要提供trigger必备的一些参数信息,如triggerkey等,在trigger接口中只提供了jobkey,key等信息的get方法,并没有set方法,于是trigger接口派生一个MutableTrigger接口用于提供set上述字段值的方法。Trigger的其他子接口crontrigger和simpletrigger在提供了基本的trigger方法的基础上针对不同类型的trigger加以不同形式的参数方法。

2、所有trigger的实现类都是继承自AbstractTrigger,AbstractTrigger并没有提供任何特别的方法体,只是针对trigger接口的get方法和MutableTrigger接口的set方法对应的参数声明为private变量。

3、quartz中存在3个可实例化trigger。CronTriggerImpl、SimpleTriggerImpl和CalendarItervalTrigger。主要是针对time时间的计算。

总体来说trigger还是比较简单的

上一篇:ubuntu中文实训手册


下一篇:PostgreSQL获取table名,字段名