关于Quartz,我想不要多做介绍了,凡是接触JAVA调度的都会知道这个开源的调度框架.本文就重点说下Quartz中有状态JOB的使用心得.因为我感觉国内的有状态JOB相关的资料比较少,所以在此提供一部分个人的一点经验.主要是针对使用quartz1.6的有状态JOB可能出现的一个棘手问题.
1.关于有状态JOB(StatefulJob)
网上有很多关于有状态JOB的作用与使用的文章,我借鉴下,做下简单的说明:
a). 实现有状态JOB只需要实现org.quartz.StatefulJob 接口即可,StatefulJob 接口仅仅是扩展了 Job 接口,未加入新的方法.
b). Job(无状态)和 StatefulJob 在框架中使用中存在两个关键差异。首先,JobDataMap 在每次执行之后重新持久化到 JobStore 中。这样就确保你对 Job 数据的改变直到下次执行仍然保持着。你可以在有状态 Job 中简单的通过 map 的 put() 方法来修改 JobDataMap.已存在的任何数据会被新的数据覆盖掉。你也能对无状态的 Job 这么做,但是因为对于无状态 Job 来说,JobDataMap 不会持久化,所以数据不会保存下来。
c). 两个或多个有状态的 JobDetail 实例不能并发执行。说的是你创建并注册了一个有状态 JobDetail 到 Scheduler 上。你还建立了两个 Trigger 来触发这个 Job:一个每五分钟触发,另一个也是每五分钏触发。假如这两个 Trigger 试图在同一时刻触发 Job,框架是不允许这种事情发生的。第二个 Trigger 一直会被阻塞直到第一个结束。
2.使用有状态JOB可能碰到的棘手问题(我目前所碰到的)
在使用quartz1.6版本的时候,我碰到过比较麻烦的问题,后来在iteye和csdn求助都没有解决.还是从国外的文章上找到了一些眉目解决了.
在实现SteafulJob接口后,该JOB怎么搞都只执行一次.
public class SimpleJob implements StatefulJob {
public void execute(JobExecutionContext context) throws JobExecutionException {
System.out.println("begin execute...");
System.out.println("end execute...");
}
}
public static void main(String [] args) {
try{
Scheduler scher = StdSchedulerFactory.getDefaultScheduler(); Calendar cal = Calendar.getInstace();
cal.add(Calendar.SECOND,1);
Trigger trigger = new SimpleTrigger("JD","JD",cal.getTime (),null,5,3000L);
JobDetail jobDetail = new JobDetail("JD","JD",SimpleJob.class);
scher.scheduleJob(jobDetaill,trigger);
scher.start();
}catch(Exception ex){
ex.printStackTrade();
}
}
后来发现,每次调度启动执行一次后,quartz的记录触发器状态的表就会显示该触发器的状态为:ERROR.
于是从这上面下功夫,还是久久不能解决,然后求助网络.后来尝试了2个方案,终于解决了.
方案一: 国内网站的一个解决方案,说是2个或多个项目使用同一个quartz数据源,会产生冲突出现上述问题,突然想起公司的quartz数据源好像是有2-3个项目连着.结果修改了其他2个项目的quartz数据源,只让我正在弄的项目连接quartz数据源,一样没能解决,只能作罢.估计我出现的问题和这位总结者的问题不一样.
方案二:这是从国外网站看到的一个方案,属于换血型的改动,风险也还是有的.就是进行版本迁移.Quartz1.6及以下版本存在着一些不稳定的状况,具体什么状况我没验证过.但是我是实在不知道怎么下手了,就尝试着将Quartz换成方案中所说的稳定性很不错的版本:2.0版本.然后进行测试,问题就解决了.
Quartz2.0版本作为目前quartz最稳定的版本,还是值得使用的.不过中间的API变动相当大.我列出一些不同的地方.
a). 实现方式
2.0之前的版本是直接实现StatefulJob接口.
2.0版本:使用注解方式
@PersistJobDataAfterExecution
@DisallowConcurrentExecution
public class StatefulJobAction implements Job{ }
b). 对象操作
JobDetail jobDetail = null;
JobDataMap dataMap = null;
CronTrigger cronTrigger = null;
String calendarName = triggerName;
DailyCalendar dailCalendar = new DailyCalendar(startTime,endTime);
dailyCalendar.setInvertTimeRange(true);
scheduler.addCalendar(calendarName,dailyCalendar,null,null);
/** quartz1.6 */
/**
jobDetail = new JobDetail(jobName,jobGroup,StatefulJobAction.class);
dataMap = new JobDataMap();
dataMap.put("Scher",scher);
jobDetail.setJobDataMap(dataMap);
cronTrigger = new CronTrigger(triggerName,triggerGroup); cronTrigger.setStartTime(startTime);
cronTrigger.setEndTime(endTime);
cronTrigger.setCalendarName(calendarName);
*/
/** quartz2.0 */
jobDetail = newJob(StatefulJobAction.class).withIdentity(jobName,jobGroup).build();
dataMap = jobDetail.getJobDataMap();
dataMap.put("Scher",scher);
//一次性构建触发器
/**
cronTrigger = newTrigger().withIdentity(triggerName,triggerGroup).withSchedule(cronSchedule(cronExpress)).startAt(startTime).endAt(endTime).modifiedByCalendar(triggerName).build;
*/
//分开构建触发器
TriggerBuilder<Trigger> triggerBuilder = newTrigger(); triggerBuilder.withIdentity(triggerName,triggerGroup);
if(StringUtils.isBlank(startTime)){
triggerBuilder.startAt(new Date());
} else{
triggerBuilder.startAt(startTime);
}
triggerBuilder.endAt(endTime);
cronTrigger = triggerBuilder.withSchedule(cronSchedule(cronExpress)).modifiedByCalendar(triggerName).build();
//简单触发器 //
SimpleTrigger simpleTrigger = newTrigger().withSchedule(simpleSchedule()).withIntervalInSeconds(10).withRepeatCount(5).build();
另外有一点需要注意,可以看到quartz2.0版本有很多这种写法:newTrigger(),simpleScheduler().其实是采用了JDK1.5后提供的静态导入.
import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule; import static org.quartz.TriggerBuilder.newTrigger;
import static静态导入是JDK1.5中的新特性。静态导入是导入这个类里的静态方法。然后就可以直接用方法名调用静态方法,而不必用ClassName.方法名 的方式来调用。
这种方法的好处就是可以简化一些操作,例如打印操作System.out.println(...);就可以将其写入一个静态方法print(...),在使用时直接print(...)就可以了。
最后在附件里附上quartz2.0需要的jar包,和quartz2.0的docs即sql脚本.
必须的JAR包:
quartz-2.0.jar,
slf4j-api.1.6.2.jar
slf4j-log4j12-1.6.2.jar
c3p0-0.9.1.jar
分享到:
相关推荐
Quartz 1.6API方便查阅,很好的资料。
Quartz1.6API参考手册.chm Quartz是java中的一个定时程序库。这是chm格式的API参考手册。
Quartz1.5,Quartz1.6,Quartz1.8。Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个...
quartz1.6在webapp下应用 demo例子 包含详细的类说明 可以拿来就用
有状态Job和无状态Job 描述>=20个字符,不支持HTML标签。 详细的资源描述有机会获得我们的推荐,更有利于他人下载,赚取更多积分。
各种企业应用几乎都会碰到任务调度的需求,就拿论坛来说:每隔半个小时生成精华文章的RSS文件,每天凌晨统计论坛用户的积分排名,每隔30分钟执行锁定 用户解锁任务。对于一个典型的MIS系统来说,在每月1号凌晨统计上...
1,源码 2,API 3,示例 4,版本为1.6
quartz quartz-1.6.5使用手册只是部分,后面的待续完毕。
实现把job持久化数据库,里面有具体的说明文档 Quartz 1 1 通过quartz创建持久化定时执行任务 3 1.1 首先创建一个基本的web工程,所需jar包 3 1.2 Quartz配置文件quartz.properties 4 1.3 创建job 6 1.3.1 实现org....
Spring quartz jar java 定时任务 调度
最近公司项目上线,需要把app部署在多台服务器上,但只能让其中一台服务器的job执行,一台服务器挂了,另一台还能继续执行job,通过网上查找资料,都是java工程的方式,不好部署并测试,经过二天辛苦整合,终于整理成...
11_Elastic-Job框架介绍.mp4 12_初识Elastic-Job.mp4 13_急速入门Simple-1.mp4 14_急速入门Simple-2.mp4 15_急速入门dataflow.mp4 16_急速入门script.mp4 17_知识点检测与小结.mp4 18_Simple作业的3种整合方式介绍....
赠送jar包:quartz-1.6.1.jar 赠送原API文档:quartz-1.6.1-javadoc.jar 包含翻译后的API文档:quartz-1.6.1-javadoc-API文档-中文(简体)-英语-对照版.zip 对应Maven信息:groupId:org.opensymphony.quartz,...
完成定时任务所需jar包,希望对大家有帮助
quartz所需jar包,包含以下3个版本。quartz-2.2.1jar、quartz-all-1.8.5jar、quartz-all-1.6.0jar。
quartz-1.6.0任务调试
再次翻看一下我的博客,最早的那篇《 Quartz Job Scheduling Framwork 》翻译是在 2007 - 10 - 17 02:17 ,距离今日那是一个造人的时间,足见这个翻译过程有多难产。一方面是源于语言水平,再者其间也发生了许多事情...
quartz1.6.0源码包 网上只此一家,不要犹豫了
quartz在集群环境下的最终解决方案quartz在集群环境下的最终解决方案