關(guān)于任務(wù)調(diào)度框架quartz使用(異常處理,解決恢復(fù)后多次調(diào)度處理)
更新時(shí)間：2023年12月14日 10:05:34 作者：栗子~~
這篇文章主要介紹了關(guān)于任務(wù)調(diào)度框架quartz使用(異常處理,解決恢復(fù)后多次調(diào)度處理),具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
首先先說說什么是調(diào)度框架
大白話所謂的調(diào)度框架你可以把它看成一個(gè)定時(shí)任務(wù)管理框架，并且quartz框架是多線程的，
quartz最主要的三大基本特性
(1)調(diào)度器 Scheduler(控制調(diào)度)
(2)Trigger(定義觸發(fā)的條件)這里的條件 ，可以用類似于‘0/20 * * * * ?’這種表達(dá)式來表示
(3)JobDetail & Job JobDetail 定義的是任務(wù)數(shù)據(jù)，而真正的執(zhí)行邏輯是在Job中
首先看以下代碼講解了如何新增了一個(gè)調(diào)度任務(wù)
QuartzEntity quartz = new QuartzEntity();
quartz.setJobName("test01");
quartz.setJobGroup("test");
quartz.setDescription("測(cè)試任務(wù)");
quartz.setJobClassName("com.itstyle.quartz.job.ChickenJob");
quartz.setCronExpression("0/20 * * * * ?");
Class cls = Class.forName(quartz.getJobClassName()) ;
cls.newInstance();
//構(gòu)建job信息
JobDetail job = JobBuilder.newJob(cls).withIdentity(quartz.getJobName(),
quartz.getJobGroup())
.withDescription(quartz.getDescription()).build();
// 觸發(fā)時(shí)間點(diǎn)
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(quartz.getCronExpression());
Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger"+quartz.getJobName(), quartz.getJobGroup())
.startNow().withSchedule(cronScheduleBuilder).build();
//交由Scheduler安排觸發(fā)
scheduler.scheduleJob(job, trigger);不過這里有個(gè)問題!，那就是調(diào)度任務(wù)停止恢復(fù)后多次調(diào)度的問題。
如何解決，首先在properties配置一文件中配置一行代碼
org.quartz.jobStore.misfireThreshold = 5000
這里先介紹下 CronTrigger
這里有三種模式：
withMisfireHandlingInstructionDoNothing
- 不觸發(fā)立即執(zhí)行
- 等待下次Cron觸發(fā)頻率到達(dá)時(shí)刻開始按照Cron頻率依次執(zhí)行
withMisfireHandlingInstructionIgnoreMisfires
- 以錯(cuò)過的第一個(gè)頻率時(shí)間立刻開始執(zhí)行
- 重做錯(cuò)過的所有頻率周期后
- 當(dāng)下一次觸發(fā)頻率發(fā)生時(shí)間大于當(dāng)前時(shí)間后，再按照正常的Cron頻率依次執(zhí)行
withMisfireHandlingInstructionFireAndProceed
- 以當(dāng)前時(shí)間為觸發(fā)頻率立刻觸發(fā)一次執(zhí)行
- 然后按照Cron頻率依次執(zhí)行
我們用第一種模式,就是生成Trigger的時(shí)候添加第一種模式，以下為代碼可以參考下
QuartzEntity quartz = new QuartzEntity();
quartz.setJobName("test01");
quartz.setJobGroup("test");
quartz.setDescription("測(cè)試任務(wù)");
quartz.setJobClassName("com.itstyle.quartz.job.ChickenJob");
quartz.setCronExpression("0/20 * * * * ?");
Class cls = Class.forName(quartz.getJobClassName()) ;
cls.newInstance();
//構(gòu)建job信息
JobDetail job = JobBuilder.newJob(cls).withIdentity(quartz.getJobName(),
quartz.getJobGroup())
.withDescription(quartz.getDescription()).build();
// 觸發(fā)時(shí)間點(diǎn)
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(quartz.getCronExpression());
Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger"+quartz.getJobName(), quartz.getJobGroup())
.withSchedule(cronScheduleBuilder.withMisfireHandlingInstructionDoNothing()).build();
//交由Scheduler安排觸發(fā)
scheduler.scheduleJob(job, trigger);
好了，以上的方式就能解決恢復(fù)后多次調(diào)度的問題
停止調(diào)度：
try {
//quartz.getJobName() 代表任務(wù)id，quartz.getJobGroup()代表任務(wù)組
JobKey key = new JobKey(quartz.getJobName(),quartz.getJobGroup());
scheduler.pauseJob(key);
} catch (SchedulerException e) {
e.printStackTrace();
return Result.error();
}恢復(fù)調(diào)度：
try {
//quartz.getJobName() 代表任務(wù)id，quartz.getJobGroup()代表任務(wù)組
JobKey key = new JobKey(quartz.getJobName(),quartz.getJobGroup());
scheduler.resumeJob(key);
} catch (SchedulerException e) {
e.printStackTrace();
return Result.error();
}刪除調(diào)度：
try {
//quartz.getJobName() 代表任務(wù)id，quartz.getJobGroup()代表任務(wù)組
TriggerKey triggerKey = TriggerKey.triggerKey(quartz.getJobName(), quartz.getJobGroup());
// 停止觸發(fā)器
scheduler.pauseTrigger(triggerKey);
// 移除觸發(fā)器
scheduler.unscheduleJob(triggerKey);
// 刪除任務(wù)
scheduler.deleteJob(JobKey.jobKey(quartz.getJobName(), quartz.getJobGroup()));
System.out.println("removeJob:"+JobKey.jobKey(quartz.getJobName()));
} catch (Exception e) {
e.printStackTrace();
return Result.error();
} 在調(diào)度過程中出現(xiàn)異常怎么辦，如何處理
請(qǐng)看以下代碼：
/**
* 實(shí)現(xiàn)序列化接口、防止重啟應(yīng)用出現(xiàn)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 {
//任務(wù)調(diào)度ID
String work = context.getJobDetail().getKey().getName();
try{
//定時(shí)器任務(wù)start
//定時(shí)器任務(wù)end
}catch (Exception e){
JobExecutionException e2 = new JobExecutionException(e);
//自動(dòng)停止job相關(guān)的觸發(fā)器，job停止
//e2.setUnscheduleAllTriggers(true);
//自動(dòng)任務(wù)報(bào)錯(cuò)繼續(xù)執(zhí)行
e2.setRefireImmediately(true);
LOGGER.error(e2.toString());
}
}
}這里分兩種有兩種方法：
//自動(dòng)停止job相關(guān)的觸發(fā)器，job停止 e2.setUnscheduleAllTriggers(true); //自動(dòng)任務(wù)報(bào)錯(cuò)繼續(xù)執(zhí)行 e2.setRefireImmediately(true);
總結(jié)
以上是關(guān)于調(diào)度任務(wù)出現(xiàn)異常后如何處理的相關(guān)代碼。
好了，這些為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
Java中Easypoi實(shí)現(xiàn)excel多sheet表導(dǎo)入導(dǎo)出功能
這篇文章主要介紹了Java中Easypoi實(shí)現(xiàn)excel多sheet表導(dǎo)入導(dǎo)出功能，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-01-01
Java處理字節(jié)類型數(shù)據(jù)的實(shí)現(xiàn)步驟
字節(jié)（Byte）是計(jì)算機(jī)信息技術(shù)用于計(jì)量存儲(chǔ)容量的一種基本單位,通常簡(jiǎn)寫為B,在ASCII編碼中1Byte可以表示一個(gè)標(biāo)準(zhǔn)的英文字符,包括大寫字母、小寫字母、數(shù)字、標(biāo)點(diǎn)符號(hào)和控制字符等,本文給大家介紹了Java如何優(yōu)雅的處理字節(jié)類型數(shù)據(jù),需要的朋友可以參考下2024-07-07
IDEA?2022最新激活碼注冊(cè)碼超詳細(xì)教程(親測(cè)激活有效)
這篇文章主要介紹了IDEA?2022最新激活碼超詳細(xì)教程(親測(cè)激活至2099年)，本文通過圖文并茂的形式給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-12-12
通常在面試中,只要是疑問句一般答案都是“否定”的,因?yàn)槿绻恰按_定”和“正?！钡?那面試官就沒有必要再問了嘛,本文想和大家聊聊finally中的代碼一定會(huì)執(zhí)行嗎？,感興趣的朋友跟著小編一起來看看吧2023-12-12
Java協(xié)程編程之Loom項(xiàng)目實(shí)戰(zhàn)記錄
這篇文章主要介紹了Java協(xié)程編程之Loom項(xiàng)目嘗鮮,如果用嘗鮮的角度去使用Loom項(xiàng)目，可以提前窺探JVM開發(fā)者們是如何基于協(xié)程這個(gè)重大特性進(jìn)行開發(fā)的，這對(duì)于提高學(xué)習(xí)JDK內(nèi)核代碼的興趣有不少幫助，需要的朋友可以參考下2021-08-08
SpringBoot高效實(shí)現(xiàn)API限流的多種方法實(shí)戰(zhàn)
本文介紹了在SpringBoot項(xiàng)目中實(shí)現(xiàn)限流的多種方法,包括使用Guava庫的GuavaRateLimiter、基于Redis的分布式限流、Resilience4j限流器以及通過自定義過濾器實(shí)現(xiàn)API限流,感興趣的可以了解一下2026-01-01
Java中的強(qiáng)制類型轉(zhuǎn)換 大數(shù)轉(zhuǎn)小數(shù)
這里主要討論一下大數(shù)轉(zhuǎn)小數(shù)，比如int類型轉(zhuǎn)short類型。小數(shù)轉(zhuǎn)大數(shù)，如short 轉(zhuǎn) int不做討論,需要的朋友可以參考下2020-02-02
詳解Nacos中注冊(cè)中心和配置中心的實(shí)現(xiàn)
Spring?Cloud?Alibaba?是阿里巴巴提供的一站式微服務(wù)開發(fā)解決方案。而?Nacos?作為?Spring?Cloud?Alibaba?的核心組件之一，提供了兩個(gè)非常重要的功能：注冊(cè)中心和配置中心，我們今天來了解和實(shí)現(xiàn)一下二者2022-08-08
JavaWeb簡(jiǎn)單文件上傳流程的實(shí)戰(zhàn)記錄
在Web應(yīng)用系統(tǒng)開發(fā)中,文件上傳和下載功能是非常常用的功能,下面這篇文章主要給大家介紹了關(guān)于JavaWeb實(shí)現(xiàn)簡(jiǎn)單文件上傳流程的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),需要的朋友可以參考下2022-03-03
淺析Spring IOC bean為什么默認(rèn)是單例
單例的意思就是說在 Spring IoC 容器中只會(huì)存在一個(gè) bean 的實(shí)例,無論一次調(diào)用還是多次調(diào)用,始終指向的都是同一個(gè) bean 對(duì)象,本文小編將和大家一起分析Spring IOC bean為什么默認(rèn)是單例,需要的朋友可以參考下2023-12-12