对quartz的总结

pheh

浏览: 11490 次
性别:
来自: 天津

最近访客更多访客>>

aiziyuer

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

2007-08 ( 2)
更多存档...

博客分类：

quartz

quartz Spring Bean VB VB.NET

Quartz 是一个强大的企业级 Schedule 工具，也是目前最好的开源 Schedule 工具。Spring中也集成了quartz的应用，下面就讲一下如何在spring中使用quartz。

spring的配置：

xml 代码

<bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="triggers">
<list>
<ref bean="simpleTrigger"/>
<ref bean="cornTrigger"/>
</list>
</property>
</bean>
<bean id="schedulerControl" class="com.pheh.scheduler.Schedule">
<property name="scheduler">
<ref bean="schedulerFactoryBean"/>
</property>
</bean>
<bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">
<property name="jobDetail">
<ref bean="methodInvokingJobDetail"/>
</property>
<property name="startDelay">
<value>1000</value>
</property>
<property name="repeatInterval">
<value>3000</value>
</property>
</bean>
<bean id="cornTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail">
<ref bean="methodInvokingJobDetail"/>
</property>
<property name="cronExpression">
<value>0 0 */1 * * ?</value>
</property>
</bean>

Job：
org.quartz.Job是一个接口，只定义了void execute(JobExecutionContext context)throws JobExecutionException;一个方法。当定时任务被触发后，系统会自动调用实现了该接口的方法。在spring中，org.springframework.scheduling.quartz.QuartzJobBean对其进行了封装，使用了Template Method模式。主要是为了在使用jobDataMap时更加方便。QuartzJobBean有两个方法，
public final void execute(JobExecutionContext context) throws JobExecutionException
Job接口中定义的，spring在该方法里进行了些处理，将jobDataMap中的值注入到该Job的实现者中

protected abstract void executeInternal(JobExecutionContext context) throws JobExecutionException
这是一个抽象方法，用户在扩展了QuartzJobBean后，要自己实现该方法，在其中添加相应的业务逻辑

JobDetail：
JobDetail描述了一个任务具体的信息。在Spring中，JobDetailBean对JobDetail进行了封装（继承了JobDetail）。
private String name;//名称
private String group = Scheduler.DEFAULT_GROUP;//组
private String description;//描述
private Class jobClass;//定时任务触发时，回调的class，该class要实现Job接口或继承QuartzJobBean
private JobDataMap jobDataMap;//该任务存储的数据，在回调的时候也可以使用
private boolean volatility = false;//是否持久化到org.quartz.spi.JobStore中
private boolean durability = false;//当该任务完成后，是否还在JobStore中继续保留该任务
private boolean shouldRecover = false;//当系统重新启动后，是否再次执行该任务
对于jobDataMap，它是是一个封装过的Map，使用方法同Map，如
jobDetailBean.getJobDataMap().put(target,value);
如果使用了QuartzJobBean，在使用jobDetailBean时，可将target的值设成QuartzJobBean的子类的属性名称，这样，在定时触发时，spring会自动将与target对应的value值注入到QuartzJobBean的子类中去。如。

java 代码

...
public class ReminderManager extends QuartzJobBean{
private String reminderStr = "";
}
...
jobDetailBean.getJobDataMap().put(reminderStr,"abcdefg");
...

这样当该任务被触发后，在ReminderManager中，reminderStr的值就会被注入为"abcdefg"。

Trigger：
trigger就是触发器。Quartz有个很好的想法就是分离了任务和任务执行的条件。Trigger就是控制任务执行条件的类，当Trigger认为执行条件满足的时刻，Trigger会通知相关的Job去执行。分离的好处是：
1.你可以为某个Job关联多个Trigger，其中任何一个条件满足都可以触发job执行，这样可以完成一些组合的高级触发条件
2.当Trigger失效后（比如：一个永远都不能满足的条件），你不必去声明一个新的job，代替的是你可以为job关联一个新的Trigger让job可以继续执行。
目前的Quartz实现中，存在两种Trigger，SimpleTrigger和CronTrigger，在spring中分别用SimpleTriggerBean和CronTriggerBean对其进行封装。SimpleTrigger是简单触发器，如从某日到某日，每个一定时间进行一次提醒，在这段时间内进行多少次提醒；CronTrigger是复杂触发器，用来执行calendar-like的任务，可设定一些复杂的触发规则，如每年的x月的第y个星期五，或是每个星期天的几点进行提醒。后面附加一个日常语义与cronTrigger的转化

Trigger
private String name;//名称
private String group = Scheduler.DEFAULT_GROUP;//组
private String jobName;//所关联的jobDetail的名称
private String jobGroup = Scheduler.DEFAULT_GROUP;//所关联的jobDetail的组
private String description;//描述
private JobDataMap jobDataMap;//该触发器存储的数据，在回调的时候也可以使用
private boolean volatility = false;//是否持久化到org.quartz.spi.JobStore中

SimpleTrigger
private Date startTime = null;//开始日期
private Date endTime = null;//结束日期
private Date nextFireTime = null;//下次的触发时间
private Date previousFireTime = null;//上次的触发时间
private int repeatCount = 0;//重复次数
private long repeatInterval = 0;//重复间隔
private int timesTriggered = 0;/已触发的次数

SimpleTriggerBean
private JobDetail jobDetail;//所关联的JobDetail，方便在配置文件中使用

CornTrigger
private CronExpression cronEx = null;//触发条件表达式，它有一个String型的setter
private Date startTime = null;//开始日期
private Date endTime = null;//结束日期
private Date nextFireTime = null;//下次的触发时间
private Date previousFireTime = null;//上次的触发时间
private transient TimeZone timeZone = null;//所在时区

CronTriggerBean
private JobDetail jobDetail;//所关联的JobDetail，方便在配置文件中使用

Scheduler的常用方法
添加一个定时任务：
Date scheduleJob(JobDetail jobDetail,Trigger trigger)

修改一个定时任务，主要是更改trigger：
Date rescheduleJob(String triggerName, String groupName, Trigger newTrigger)

删除一个定时任务，同时也会将于该jobDetail关联的trigger一并删除：
boolean deleteJob(String jobName,String jobGroup)

取得所有的jobDetail组
String[] getJobGroupNames()

取得某个group下的所有的jobDetail
String[] getJobNames(String groupName)

取得指定的jobDetail
JobDetail getJobDetail(String jobName, String jobGroup)

取得指定的jobDetail的所有的Trigger
Trigger[] getTriggersOfJob(String jobName, String groupName)

取得指定的Trigger
Trigger getTrigger(String triggerName, String triggerGroup)

Quartz的存储：
Quartz默认的是使用RAM存储所有的信息，但是这样的话，当我们重启服务器后，之前的所有的定时任务就全消失了。为了让服务器重启以后，我们的定时任务仍不丢失，我们可采用数据库持久化定时任务。
首先要先建立数据库，在quartz-1.6.0\docs\dbTables下，选择自己使用的数据库的sql脚本，建立相应的数据库表。
在WEB-INF下加一个quartz.properties。我们可以在 quartz-1.6.0\examples\example10 中找到该文件的样例

org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX #表明使用JDBC进行持久化
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties = false
org.quartz.jobStore.dataSource = myDS
org.quartz.jobStore.tablePrefix = QRTZ_ #该值尽量不要改动，如改动，还要相应的修改sql脚本
org.quartz.jobStore.isClustered = false

org.quartz.dataSource.myDS.driver = net.sourceforge.jtds.jdbc.Driver
org.quartz.dataSource.myDS.URL = jdbc:jtds:sqlserver://192.168.1.101:1433/Northwind;autoReconnect=true
org.quartz.dataSource.myDS.user = sa
org.quartz.dataSource.myDS.password =
org.quartz.dataSource.myDS.maxConnections = 5

日常语义与cronTrigger的转化，以下setter,getter省略

java 代码

public class TDateRange{
private int startType = 2;//开始类型。默认的使用2表示使用开始日期
private Date startDate = new Date();//开始日期
private int endType = 0;//结束类型。0表示无结束时间；1表示重复n次后结束；2表示使用结束日期
private Date endDate = new Date();//结束日期
private int occurrences;//执行次数
}
public class TFrequency{
//0：无重复提醒
//1：每every
//2：每个工作日detail=1,2,3,4,5
//3：每every周后的星期detail日
//4：每every月的detail日
//5：每every月的第num1个星期num2
//6：每年num1月num2日
//7：每年every月的第num1个月的星期num2
private int type = 0;//频率类型
private int every = 0;
private String detail = "";
private String num1 = "";
private String num2 = "";
}
private String formatQuartzString(){
String quartzStr = "";
tiggernote="";
//秒分时
quartzStr = "0 "+this.dateRange.getStartDate().getMinutes()+" "+this.dateRange.getStartDate().getHours()+" ";
switch(this.frequency.getType()){
case 0://无重复提醒
quartzStr += this.dateRange.getStartDate().getDate()+" "+(this.dateRange.getStartDate().getMonth()+1)+" ? "+(this.dateRange.getStartDate().getYear()+1900);
tiggernote+="起始时间:"+quartzStr;
break;
case 1://每XX天提醒
quartzStr += "*/"+this.frequency.getEvery()+" * ? ";
tiggernote+="每"+this.frequency.getEvery()+"提醒";
break;
case 2://每个工作日detail=1,2,3,4,5
//quartzStr += "? * 2-6";
quartzStr ="0 */1 * * * ?"; //测试
tiggernote+="每个工作日1,2,3,4,5提醒";
break;
case 3://每every周后的星期detail日
quartzStr += "? * "+this.frequency.getDetail()+"/"+this.frequency.getEvery();
tiggernote+="每"+this.frequency.getEvery()+"周星期"+this.frequency.getDetail()+"日";
break;
case 4://每every个月的detail日
quartzStr += this.frequency.getDetail()+" */"+this.frequency.getEvery()+" ?";
tiggernote+="每"+this.frequency.getEvery()+"月"+this.frequency.getDetail()+"日";
break;
case 5://每every个月的第num1个星期num2
quartzStr += "? */"+this.frequency.getEvery()+" "+this.frequency.getNum2();
//星期
if(Integer.valueOf(this.frequency.getNum1()).intValue()>0){
quartzStr += "#"+this.frequency.getNum1();
tiggernote+="每"+this.frequency.getEvery()+"月第"+this.frequency.getNum1()+"个星期"+this.frequency.getNum2()+"日";
}else{
quartzStr += "L";
tiggernote+="每"+this.frequency.getEvery()+"月星期"+this.frequency.getNum2();
}
break;
case 6://每年num1月num2日
quartzStr += this.frequency.getNum2()+" "+this.frequency.getNum1()+" ?";
tiggernote+="每年"+this.frequency.getNum1()+"月"+this.frequency.getNum2()+"日";
break;
case 7://每年every月的第num1个星期num2
quartzStr += "? "+this.getFrequency().getEvery()+" "+this.getFrequency().getNum2();
//星期
if(Integer.valueOf(this.frequency.getNum1()).intValue()>0){
quartzStr += "#"+this.frequency.getNum1();
tiggernote+="每年"+this.getFrequency().getEvery()+"月的第"+this.frequency.getNum1()+"个星期"+this.getFrequency().getNum2()+"日";
}else{
quartzStr += "L";
tiggernote+="每年"+this.getFrequency().getEvery()+"月的"+this.getFrequency().getNum2()+"日";
}
break;
default :
}
log.debug("quartzStr="+quartzStr);
return quartzStr;
}

Scheduler：
Scheduler 是一个计划集，其中可以包含多个 JobDetail 和 Trigger 组成的计划任务。
在Quartz中，我们可以通过
SchedulerFactory scheduleFactory = new StdSchedulerFactory();
Scheduler scheduler = scheduleFactory.getScheduler();
来取得scheduler，通过调用scheduler.start()来启动quartz。
在spring中，org.springframework.scheduling.quartz.SchedulerFactoryBean是对Quartz的org.quartz.Scheduler的封装，通过上面的配置，在spring启动的时候，quartz就会跟随着启动，不需要再用scheduler.start()来启动。在spring中，如果要取得scheduler，可通过上面的配置文件那样，将SchedulerFactoryBean注入到schdeuler中。

分享到：

spring中的no session问题

2007-08-27 18:01
浏览 6724
评论(14)
论坛回复 / 浏览 (14 / 36912)
分类:企业架构
查看更多

14 楼 huajz 2008-07-21

jjs_love 写道

我这里有一个java WEB程序要与vb之间进行socket通信,
我这里quartz主要是用定时任务,每5秒就做一次任务马上发消息给vb应用程序,但我在测试的时候,我项目启动时间要大于5秒,也就是说我的项目还没有完成,调度任务就开始了,怎么让它在项目启动完成之后再调度任务?

同问。

13 楼 herowzz 2008-07-02

pragmatic 写道

因公司近期项目中有个功能需要用到定时执行任务,公司项目又是基于ssh框架的,所以自然就选用了quartz,一切弄好之后,发现有个小小的问题,每次重启weblogic,任务都会先执行一遍,而不是等待到了时间触发点再执行,比如:我设置的任务是每天12:00执行,重启服务的时候他会执行一下,然后等到12:00再执行,查了很多资料都没有这方面的介绍,不知道大家碰到过没有?

没有这样的情况啊，我们配置好就只会在时间触发点才会执行.

12 楼 jjs_love 2007-12-26

11 楼 pragmatic 2007-11-13

10 楼 asklxf 2007-10-10

Quartz可以配置线程池大小，如果任务多，执行频繁，把线程池配大点就好了，只有当线程池的线程都在跑task时，才会阻塞后面的任务

pheh 写道

galaxystar 写道

在quartz中, 建议每个任务的工作量, 最好是均衡的, 因为, 我发现, 有时, 某个task very busy的时候, 其他task会阻塞.

甚至导致, 当前应用出现响应超时的现象.

部署quartz的时候, 裸体单机感觉不错.

我的项目中用quartz只是做了一个定时任务提醒功能，每个提醒任务的工作量基本上一样，就是发出邮件或是屏幕提醒之类的，没有发现你所有的问题。
P.S.quartz不是多线程的吗？怎么会出现task阻塞？没想明白，还请galaxystar详细讲讲

9 楼 hbcui1984 2007-09-29

请问楼主：
可清楚quartz的实现机制，在哪个类里实现了时间监控？
比如：我的job一分钟执行一次，quartz是怎么知道什么时候该执行了？好像是把下次执行时间保存在了JobDataMap中，可是下一分钟到来时刻，是什么激发job执行呢？

8 楼 zhu_chen001 2007-09-04

可惜了quartz在暂停任务后,过段时间再恢复的时候会根据停止的时间判断是否自动执行一次,导致临界任务不能控制

7 楼 y_yqing 2007-09-04

楼主是否知道如何用CronExpression表示每个月的最后三天内某时间点触发吗？望不吝赐教

另外，对于文中“但是如果在day-of-week字段L在另一个值后面，意味着这个月的最后XXX天，比如"6L"表示这个月的最后一个星期五。”这段话，我没能理解。如果L在day-of-week段就代表是这个月的最后xxx天，为什么6L就一定代表是最后一个星期五呢？

6 楼 pheh 2007-08-30

小弟愚钝，还是不太明白，希望楼上的能写个示例代码说明一下，如何在构造时传参来定义类型，这个参数是什么时候赋值的，是在定时触发时吗？
public class ReminderManager extends QuartzJobBean{
private String reminderStr = "";
}
之所以定义一个reminderStr属性，是因为spring会在定时触发时自动将值注入到reminderStr中，spring已经帮我们做好了这些工作，就不用再通过参数的形式传参了，虽然这样灵活性上会差些，但是考虑到在项目中这块的需求基本上不会变动，就采取了这种方法。

5 楼 Groovy 2007-08-30

pheh 写道

Groovy 写道

感觉用实现Job接口还是StatefulJob接口来区分有状态和无状态Job不是很方便啊
为什么不做成一个属性来设置呢?

我对StatefulJob不太熟悉，看源代码，它是继承自Job接口的，并且也没有他自己定义的方法，应该是属于标识接口，你指的的做成一个属性来设置是什么意思呢？

这样在使用的时候需要用两个类实现分别Job和StatefulJob,我的意思是说他们既然没有什么不一样的方法,为什么不做成在构造时候传参来定义类型呢

4 楼 pheh 2007-08-30

galaxystar 写道

3 楼 pheh 2007-08-30

Groovy 写道

感觉用实现Job接口还是StatefulJob接口来区分有状态和无状态Job不是很方便啊
为什么不做成一个属性来设置呢?

2 楼 galaxystar 2007-08-27

1 楼 Groovy 2007-08-27

感觉用实现Job接口还是StatefulJob接口来区分有状态和无状态Job不是很方便啊
为什么不做成一个属性来设置呢?

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论