问题1 如果你的任务执行发生错误了怎么办呀!
Quartz提供了二种解决方法
1 立即重新执行任务
2 立即停止所有相关这个任务的触发器
问题2 怎么去执行呢
Quartz的解决方式是
在你的程序出错时,用Quartz提供的JobExecutionException类相关方法很好的解决
1 立即重新执行任务
- try {
- int zero = 0;
- @SuppressWarnings("unused")
- int calculation = 4815 / zero;
- } catch (Exception e) {
- _log.error("执行任务出错了...");
- JobExecutionException e2 =
- new JobExecutionException(e);
- // this job will refire immediately
- e2.setRefireImmediately(true);
- throw e2;
- }
请注意其中作者写的注释:
// this job will refire immediately
e2.setRefireImmediately(true);
2 立即停止所有相关这个任务的触发器
- try {
- int zero = 0;
- @SuppressWarnings("unused")
- int calculation = 4815 / zero;
- } catch (Exception e) {
- _log.info("--- Error in job!");
- JobExecutionException e2 =
- new JobExecutionException(e);
- // Quartz will automatically unschedule
- // all triggers associated with this job
- // so that it does not run again
- e2.setUnscheduleAllTriggers(true);
- throw e2;
- }
请注意其中作者写的注释:
// Quartz will automatically unschedule
// all triggers associated with this job
// so that it does not run again
e2.setUnscheduleAllTriggers(true);
具体代码如下:
BadJob1.java
- package org.quartz.examples.example6;
- import java.util.Date;
- import org.quartz.DisallowConcurrentExecution;
- import org.quartz.Job;
- import org.quartz.JobExecutionContext;
- import org.quartz.JobExecutionException;
- import org.quartz.JobKey;
- import org.quartz.PersistJobDataAfterExecution;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- /**
- * <p>
- * A job dumb job that will throw a job execution exception
- * </p>
- *
- * @author Bill Kratzer
- */
- @PersistJobDataAfterExecution
- @DisallowConcurrentExecution
- public class BadJob1 implements Job {
- private static Logger _log = LoggerFactory.getLogger(BadJob1.class);
- public BadJob1() {
- }
- public void execute(JobExecutionContext context)
- throws JobExecutionException {
- JobKey jobKey = context.getJobDetail().getKey();
- _log.error("任务key: " + jobKey + " ,执行时间: " + new Date());
- try {
- int zero = 0;
- @SuppressWarnings("unused")
- int calculation = 4815 / zero;
- } catch (Exception e) {
- _log.error("执行任务出错了...");
- JobExecutionException e2 =
- new JobExecutionException(e);
- // this job will refire immediately
- e2.setRefireImmediately(true);
- throw e2;
- }
- _log.error("---" + jobKey + " completed at " + new Date());
- }
- }
BadJob2 .java
- package org.quartz.examples.example6;
- import java.util.Date;
- import org.quartz.DisallowConcurrentExecution;
- import org.quartz.Job;
- import org.quartz.JobExecutionContext;
- import org.quartz.JobExecutionException;
- import org.quartz.JobKey;
- import org.quartz.PersistJobDataAfterExecution;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- /**
- * <p>
- * A job dumb job that will throw a job execution exception
- * </p>
- *
- * @author Bill Kratzer
- */
- @PersistJobDataAfterExecution
- @DisallowConcurrentExecution
- public class BadJob2 implements Job {
- private static Logger _log = LoggerFactory.getLogger(BadJob2.class);
- public BadJob2() {
- }
- public void execute(JobExecutionContext context)
- throws JobExecutionException {
- JobKey jobKey = context.getJobDetail().getKey();
- _log.info("---" + jobKey + " executing at " + new Date());
- try {
- int zero = 0;
- @SuppressWarnings("unused")
- int calculation = 4815 / zero;
- } catch (Exception e) {
- _log.info("--- Error in job!");
- JobExecutionException e2 =
- new JobExecutionException(e);
- // Quartz will automatically unschedule
- // all triggers associated with this job
- // so that it does not run again
- e2.setUnscheduleAllTriggers(true);
- throw e2;
- }
- _log.info("---" + jobKey + " completed at " + new Date());
- }
- }
JobExceptionExample.java
- package org.quartz.examples.example6;
- import static org.quartz.JobBuilder.newJob;
- import static org.quartz.SimpleScheduleBuilder.simpleSchedule;
- import static org.quartz.TriggerBuilder.newTrigger;
- import static org.quartz.DateBuilder.*;
- import java.util.Date;
- import org.quartz.JobDetail;
- import org.quartz.Scheduler;
- import org.quartz.SchedulerFactory;
- import org.quartz.SchedulerMetaData;
- import org.quartz.SimpleTrigger;
- import org.quartz.impl.StdSchedulerFactory;
- import org.slf4j.Logger;
- import org.slf4j.LoggerFactory;
- /**
- *
- * This job demonstrates how Quartz can handle JobExecutionExceptions that are
- * thrown by jobs. *
- * @author Bill Kratzer
- */
- public class JobExceptionExample {
- public void run() throws Exception {
- Logger log = LoggerFactory.getLogger(JobExceptionExample.class);
- SchedulerFactory sf = new StdSchedulerFactory();
- Scheduler sched = sf.getScheduler();
- Date startTime = nextGivenSecondDate(null, 15);
- JobDetail job = newJob(BadJob1.class)
- .withIdentity("badJob1", "group1")
- .build();
- SimpleTrigger trigger = newTrigger()
- .withIdentity("trigger1", "group1")
- .startAt(startTime)
- .withSchedule(simpleSchedule())
- .build();
- Date ft = sched.scheduleJob(job, trigger);
- log.error(job.getKey() + " will run at: " + ft + " and repeat: "
- + trigger.getRepeatCount() + " times, every "
- + trigger.getRepeatInterval() / 1000 + " seconds");
- job = newJob(BadJob2.class)
- .withIdentity("badJob2", "group1")
- .build();
- trigger = newTrigger()
- .withIdentity("trigger2", "group1")
- .startAt(startTime)
- .withSchedule(simpleSchedule()
- .withIntervalInSeconds(3)
- .repeatForever())
- .build();
- ft = sched.scheduleJob(job, trigger);
- log.error(job.getKey() + " will run at: " + ft + " and repeat: "
- + trigger.getRepeatCount() + " times, every "
- + trigger.getRepeatInterval() / 1000 + " seconds");
- sched.start();
- try {
- // sleep for 60 seconds
- Thread.sleep(60L * 1000L);
- } catch (Exception e) {
- }
- sched.shutdown(true);
- SchedulerMetaData metaData = sched.getMetaData();
- log.error("Executed " + metaData.getNumberOfJobsExecuted() + " jobs.");
- }
- public static void main(String[] args) throws Exception {
- JobExceptionExample example = new JobExceptionExample();
- example.run();
- }
- }
相关推荐
赠送jar包:quartz-2.3.2.jar; 赠送原API文档:quartz-2.3.2-javadoc.jar; 赠送源代码:quartz-2.3.2-sources.jar; 赠送Maven依赖信息文件:quartz-2.3.2.pom; 包含翻译后的API文档:quartz-2.3.2-javadoc-API...
文件里面包括 1:Quartz开发指南.pdf 2:Quartz从入门到进阶.pdf 3:QuartzBeginnerExample一个附带的工程例子 4:quartz-1.6.1.zip Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它...
该压缩包内包含两个quartz的jar包, 分别是quartz-1.6.0.jar和quartz-all-1.6.0.jar
赠送jar包:quartz-2.3.0.jar; 赠送原API文档:quartz-2.3.0-javadoc.jar; 赠送源代码:quartz-2.3.0-sources.jar; 赠送Maven依赖信息文件:quartz-2.3.0.pom; 包含翻译后的API文档:quartz-2.3.0-javadoc-API...
quartz-2.2.3版本的quartz初始化sql语句
quartz简单实例quartz简单实例quartz简单实例quartz简单实例
Autofac.Extras.Quartz, Quartz.Net的Autofac集成 Autofac.Extras.Quartz用于 Quartz.Net的Autofac集成包。Autofac.Extras.Quartz 为每个石英作业创建嵌套的litefime作用域。 完成作业执行后释放嵌套作用域。这允许...
网上能找到的Quartz Web管理的资料都是使用的一个国外人写的Quartz WebApp的东东,功能也很全面。但是作为自己的应用其实用不了那么多功能,一般我们只要可以定义一个job,指定一个Cron表达式完成工作即可,附带的...
quartz quartz-1.8.6 dbTables quartz动态任务调度需要的数据库脚本。
quartz内部表.sql。
Quartz1.5,Quartz1.6,Quartz1.8。Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个...
postgres quatrz初始化sql脚本文件、pg、quartz、qrtz_开头的表 配置文件需求修改 #org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate org.quartz.jobStore....
Quartz.NET框架的核心是调度器。调度器负责管理Quartz.NET应用运行时环境。Quartz不仅仅是线程和线程管理。为确保可伸缩性,Quartz.NET采用了基于多线程的架构。启动时,框架初始化一套worker线程,这套线程被调度器...
lucene quartz 例子lucene quartz 例子lucene quartz 例子lucene quartz 例子lucene quartz 例子lucene quartz 例子lucene quartz 例子lucene quartz 例子lucene quartz 例子lucene quartz 例子
详细介绍CronExpression表达式设定定时任务的规则
Quartz原理及实例,spring4.x+Quartz.2.2.1结合的开发,静态和动态实例
关于spring中quartz的配置
深入解读Quartz的原理,定时任务框架是web开发过程中使用很多的框架之一
Quartz框架的核心是调度器。调度器负责管理Quartz应用运行时环境。调度器不是靠自己做所有的工作,而是依赖框架内一些非常重要的部件。 Quartz不仅仅是线程和线程管理。为确保可伸缩性,Quartz采用了基于多线程的...
quartz自动调度的3种调度形式+传参 1.单纯的quartz调度 2.spring+quartz调度