关于任务调度框架quartz使用(异常处理,解决恢复后多次调度处理)

更新时间：2023年12月14日 10:05:34 作者：栗子~~

这篇文章主要介绍了关于任务调度框架quartz使用(异常处理,解决恢复后多次调度处理),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

首先先说说什么是调度框架

大白话所谓的调度框架你可以把它看成一个定时任务管理框架，并且quartz框架是多线程的，

quartz最主要的三大基本特性

(1)调度器 Scheduler(控制调度)

(2)Trigger(定义触发的条件)这里的条件，可以用类似于‘0/20 * * * * ?’这种表达式来表示

(3)JobDetail & Job JobDetail 定义的是任务数据，而真正的执行逻辑是在Job中

首先看以下代码讲解了如何新增了一个调度任务

	QuartzEntity quartz = new QuartzEntity();
    		quartz.setJobName("test01");
    		quartz.setJobGroup("test");
    		quartz.setDescription("测试任务");
    		quartz.setJobClassName("com.itstyle.quartz.job.ChickenJob");
    		quartz.setCronExpression("0/20 * * * * ?");
   	        Class cls = Class.forName(quartz.getJobClassName()) ;
   	        cls.newInstance();
   	        //构建job信息
   	        JobDetail job = JobBuilder.newJob(cls).withIdentity(quartz.getJobName(),
   	        		quartz.getJobGroup())
   	        		.withDescription(quartz.getDescription()).build();
   	        // 触发时间点
   	        CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(quartz.getCronExpression());
   	        Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger"+quartz.getJobName(), quartz.getJobGroup())
   	                .startNow().withSchedule(cronScheduleBuilder).build();	
   	        //交由Scheduler安排触发
   	        scheduler.scheduleJob(job, trigger);

不过这里有个问题!，那就是调度任务停止恢复后多次调度的问题。

如何解决，首先在properties配置一文件中配置一行代码

org.quartz.jobStore.misfireThreshold = 5000

这里先介绍下 CronTrigger

这里有三种模式：

withMisfireHandlingInstructionDoNothing

不触发立即执行
等待下次Cron触发频率到达时刻开始按照Cron频率依次执行

withMisfireHandlingInstructionIgnoreMisfires

以错过的第一个频率时间立刻开始执行
重做错过的所有频率周期后
当下一次触发频率发生时间大于当前时间后，再按照正常的Cron频率依次执行

withMisfireHandlingInstructionFireAndProceed

以当前时间为触发频率立刻触发一次执行
然后按照Cron频率依次执行

我们用第一种模式,就是生成Trigger的时候添加第一种模式，以下为代码可以参考下

 
	QuartzEntity quartz = new QuartzEntity();
    		quartz.setJobName("test01");
    		quartz.setJobGroup("test");
    		quartz.setDescription("测试任务");
    		quartz.setJobClassName("com.itstyle.quartz.job.ChickenJob");
    		quartz.setCronExpression("0/20 * * * * ?");
   	        Class cls = Class.forName(quartz.getJobClassName()) ;
   	        cls.newInstance();
   	        //构建job信息
   	        JobDetail job = JobBuilder.newJob(cls).withIdentity(quartz.getJobName(),
   	        		quartz.getJobGroup())
   	        		.withDescription(quartz.getDescription()).build();
   	        // 触发时间点
   	        CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(quartz.getCronExpression());
   	        Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger"+quartz.getJobName(), quartz.getJobGroup())
                    .withSchedule(cronScheduleBuilder.withMisfireHandlingInstructionDoNothing()).build();
   	        //交由Scheduler安排触发
   	        scheduler.scheduleJob(job, trigger);

好了，以上的方式就能解决恢复后多次调度的问题

停止调度：

               try {
                     //quartz.getJobName() 代表任务id，quartz.getJobGroup()代表任务组
		     JobKey key = new JobKey(quartz.getJobName(),quartz.getJobGroup());
		     scheduler.pauseJob(key);
		} catch (SchedulerException e) {
			 e.printStackTrace();
			 return Result.error();
		}

恢复调度：

               try {
                     //quartz.getJobName() 代表任务id，quartz.getJobGroup()代表任务组
		     JobKey key = new JobKey(quartz.getJobName(),quartz.getJobGroup());
		     scheduler.resumeJob(key);
		} catch (SchedulerException e) {
			 e.printStackTrace();
			 return Result.error();
		}

删除调度：

       try {  
           //quartz.getJobName() 代表任务id，quartz.getJobGroup()代表任务组
			  
            TriggerKey triggerKey = TriggerKey.triggerKey(quartz.getJobName(), quartz.getJobGroup());  
            // 停止触发器  
            scheduler.pauseTrigger(triggerKey);  
            // 移除触发器  
            scheduler.unscheduleJob(triggerKey);  
            // 删除任务  
            scheduler.deleteJob(JobKey.jobKey(quartz.getJobName(), quartz.getJobGroup()));  
            System.out.println("removeJob:"+JobKey.jobKey(quartz.getJobName()));  
        } catch (Exception e) {  
        	e.printStackTrace();
            return Result.error();
        }

在调度过程中出现异常怎么办，如何处理

请看以下代码：

/**
 * 实现序列化接口、防止重启应用出现quartz Couldn't retrieve job because a required class was not found 的问题
 */
public class TestJob extends AddXxBase implements  Job,Serializable {
	private final static Logger LOGGER = LoggerFactory.getLogger(TestJob.class);
	private static final long serialVersionUID = 1L;
		/**
	 * 模板
	 * **/
	@Override
	public void execute(JobExecutionContext context) throws JobExecutionException {
		//任务调度ID
                String work = context.getJobDetail().getKey().getName();
		try{
			//定时器任务start
	
 
			//定时器任务end
		}catch (Exception e){
			JobExecutionException e2 = new JobExecutionException(e);
			//自动停止job相关的触发器，job停止
			//e2.setUnscheduleAllTriggers(true);
                        //自动任务报错继续执行
			e2.setRefireImmediately(true);
			LOGGER.error(e2.toString());
			
		}
	}
}

这里分两种有两种方法：

//自动停止job相关的触发器，job停止
e2.setUnscheduleAllTriggers(true);
//自动任务报错继续执行
e2.setRefireImmediately(true);

总结

以上是关于调度任务出现异常后如何处理的相关代码。

好了，这些为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

Java中Easypoi实现excel多sheet表导入导出功能
这篇文章主要介绍了Java中Easypoi实现excel多sheet表导入导出功能，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2021-01-01
Java处理字节类型数据的实现步骤
字节（Byte）是计算机信息技术用于计量存储容量的一种基本单位,通常简写为B,在ASCII编码中1Byte可以表示一个标准的英文字符,包括大写字母、小写字母、数字、标点符号和控制字符等,本文给大家介绍了Java如何优雅的处理字节类型数据,需要的朋友可以参考下
2024-07-07
IDEA 2022最新激活码注册码超详细教程(亲测激活有效)
这篇文章主要介绍了IDEA 2022最新激活码超详细教程(亲测激活至2099年)，本文通过图文并茂的形式给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2020-12-12
聊聊finally中的代码一定会执行吗
通常在面试中,只要是疑问句一般答案都是“否定”的,因为如果是“确定”和“正常”的,那面试官就没有必要再问了嘛,本文想和大家聊聊finally中的代码一定会执行吗？,感兴趣的朋友跟着小编一起来看看吧
2023-12-12
Java协程编程之Loom项目实战记录
这篇文章主要介绍了Java协程编程之Loom项目尝鲜,如果用尝鲜的角度去使用Loom项目，可以提前窥探JVM开发者们是如何基于协程这个重大特性进行开发的，这对于提高学习JDK内核代码的兴趣有不少帮助，需要的朋友可以参考下
2021-08-08
SpringBoot高效实现API限流的多种方法实战
本文介绍了在SpringBoot项目中实现限流的多种方法,包括使用Guava库的GuavaRateLimiter、基于Redis的分布式限流、Resilience4j限流器以及通过自定义过滤器实现API限流,感兴趣的可以了解一下
2026-01-01
Java中的强制类型转换大数转小数
这里主要讨论一下大数转小数，比如int类型转short类型。小数转大数，如short 转 int不做讨论,需要的朋友可以参考下
2020-02-02
详解Nacos中注册中心和配置中心的实现
Spring Cloud Alibaba 是阿里巴巴提供的一站式微服务开发解决方案。而 Nacos 作为 Spring Cloud Alibaba 的核心组件之一，提供了两个非常重要的功能：注册中心和配置中心，我们今天来了解和实现一下二者
2022-08-08
JavaWeb简单文件上传流程的实战记录
在Web应用系统开发中,文件上传和下载功能是非常常用的功能,下面这篇文章主要给大家介绍了关于JavaWeb实现简单文件上传流程的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下
2022-03-03
浅析Spring IOC bean为什么默认是单例
单例的意思就是说在 Spring IoC 容器中只会存在一个 bean 的实例,无论一次调用还是多次调用,始终指向的都是同一个 bean 对象,本文小编将和大家一起分析Spring IOC bean为什么默认是单例,需要的朋友可以参考下
2023-12-12