Java?任務調度框架?Quartz實操
更新時間：2021年12月14日 11:41:46 作者：一枚方糖
這篇文章主要介紹了Java?任務調度框架?Quartz,Quartz是OpenSymphony開源組織在Job?scheduling領域又一個開源項目，完全由Java開發(fā)，可以用來執(zhí)行定時任務，類似于java.util.Timer。,下面我們來學習一下關于?Quartz更多的詳細內容,需要的朋友可以參考一下
?Quartz相較于Timer， Quartz增加了很多功能：
- 持久性作業(yè) - 就是保持調度定時的狀態(tài);
- 作業(yè)管理 - 對調度作業(yè)進行有效的管理;
1、Quartz
1.1 引入依賴
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.3.2</version>
</dependency>
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz-jobs</artifactId>
<version>2.3.2</version>
</dependency>
1.2 入門案例
任務：將任務類執(zhí)行 10 次，每次間隔 3 秒。
任務類,需要實現 Job 接口
package com.sugar.quartz.utils;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* 功能描述: 任務
*
* @author XiaoNianXin
* @date 2021/12/13 20:52
*/
public class HelloJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// 獲取當前時間,并格式化
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateSrting = format.format(date);
// 業(yè)務功能模擬
System.out.println("開始備份數據庫,時間：" + dateSrting);
}
}
定時器類
package com.sugar.quartz.utils;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
/**
* 功能描述: 定時器配置
*
* @author XiaoNianXin
* @date 2021/12/13 21:08
*/
public class HelloSchedulerDemo {
public static void main(String[] args) throws SchedulerException {
// 1、調度器 - 從工廠獲取調度實例
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
// 2、任務實例 - 執(zhí)行的任務對象
JobDetail job = JobBuilder.newJob(HelloJob.class)
.withIdentity("job1", "group1") // 任務名稱,組名稱
.build();
// 3、觸發(fā)器 - 控制執(zhí)行次數和執(zhí)行時間
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "group1") // 同上
.startNow() // 立刻啟動
.withSchedule(SimpleScheduleBuilder.simpleSchedule().
withIntervalInSeconds(3).
withRepeatCount(10)) // 循環(huán)10次,每次間隔3s
.build();
// 調度器關聯觸發(fā)器,并啟動
scheduler.scheduleJob(job,trigger);
scheduler.start();
}
}
1.3 Job 與 JobDetail
Job：基于反射的任務調度接口，所有任務類都要實現該接口，在接口的 execute 里編寫自己的業(yè)務邏輯。Job 生命周期：每次執(zhí)行 Job，在 execute 方法前會創(chuàng)建新的 Job實例，調用后實例被釋放，再被GC回收。JobDetail：封裝 Job，給 Job 實例提供許多屬性。JobDetail 屬性：name、group、jobClass、jobDataMap。
1.4 JobExecutionContext
下文將 JobExecutionContext 簡稱為 JEC
JEC：當調度器調用 Job 時，會將 JEC 傳遞給 Job 的 execute 方法。JEC 作用：Job 通過 JEC 獲取運行環(huán)境信息，以及 Job 信息。
1.5 JobDataMap
下文將 JobDataMap 簡稱為 JDM
JDM：任務調度時，JDM 存儲在 JEC 中，方便獲取。JDM 優(yōu)點：實現 Map 接口，可以存取任何可序列化對象，Job 執(zhí)行時會將參數傳給 JDM。
手動獲取 JDM 參數案例
HelloSchedulerDemo：
package com.sugar.quartz.utils;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
/**
* 功能描述: 定時器配置
*
* @author XiaoNianXin
* @date 2021/12/13 21:08
*/
public class HelloSchedulerDemo {
public static void main(String[] args) throws SchedulerException {
// 1、調度器 - 從工廠獲取調度實例
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
// 2、任務實例 - 執(zhí)行的任務對象
JobDetail job = JobBuilder.newJob(HelloJob.class)
.withIdentity("job1", "group1") // 任務名稱,組名稱
.usingJobData("msg","JDM使用 - Detail") // JDM 傳遞參數
.build();
// 3、觸發(fā)器 - 控制執(zhí)行次數和執(zhí)行時間
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "group1") // 同上
.startNow() // 立刻啟動
.withSchedule(SimpleScheduleBuilder.simpleSchedule().
withIntervalInSeconds(3).
withRepeatCount(10)) // 循環(huán)10次,每次間隔3s
.usingJobData("msg","JDM使用 - Trigger")
.build();
// 調度器關聯觸發(fā)器,并啟動
scheduler.scheduleJob(job,trigger);
scheduler.start();
}
}
HelloJob：
package com.sugar.quartz.utils;
import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* 功能描述: 定時業(yè)務功能
*
* @author XiaoNianXin
* @date 2021/12/13 20:52
*/
public class HelloJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// 獲取當前時間,并格式化
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateSrting = format.format(date);
// 獲取 JDM
JobDataMap Detail_JDM = context.getJobDetail().getJobDataMap();
JobDataMap Trigger_JDM = context.getTrigger().getJobDataMap();
String detail_jdmString = Detail_JDM.getString("msg");
String trigger_jdmString = Trigger_JDM.getString("msg");
System.out.println("---------------------------------------------------");
System.out.println("detail_jdmString = " + detail_jdmString);
System.out.println("trigger_jdmString = " + trigger_jdmString);
// 業(yè)務功能模擬
System.out.println("開始備份數據庫,時間：" + dateSrting);
// 其他內容
System.out.println("Job 運行時間：" + context.getJobRunTime());
System.out.println("Job 當前運行時間：" + context.getFireTime());
System.out.println("Job 下次運行時間：" + context.getNextFireTime());
System.out.println("---------------------------------------------------");
}
}
2、Job 類實現 JDM 參數的 Setter 方法，實例化時自動綁定參數
HelloJob：
// 實例化時自動綁定 JDM key對應的值
private String msg;
public void setMsg(String msg) {
this.msg = msg;
}
// 獲取 JDM
System.out.println(Trigger JDM ： " + msg);
- 問題：上文中 JobDetail 和 Trigger 中的 JDM 的 key 均為 "msg"，那此 msg 是哪一個？
- E.g：遇到同名key，Trigger 會覆蓋 JobDetail 的值，所以 msg 為 Trigger JDM 的值。
1.6 Job 狀態(tài)
- 有狀態(tài) Job：多次調用 Job 期間，公用同一個 JDM。
- 有狀態(tài) Job：多次調用 Job 期間，每次新建一個新的 JDM。
有無狀態(tài) Job 區(qū)別案例
預期：無狀態(tài) count 輸出永遠為 1，有狀態(tài) count 輸出累加。
HelloSchedulerDemo：
// JobDeatil 添加一個 JDM，用做計數器
.usingJobData("count",0)
無狀態(tài) HelloJob：
package com.sugar.quartz.utils;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* 功能描述: 任務類
*
* @author XiaoNianXin
* @date 2021/12/13 20:52
*/
public class HelloJob implements Job {
// 實例化時自動綁定 JDM key對應的值
private String msg;
private Integer count;
public void setMsg(String msg) {
this.msg = msg;
}
public void setCount(Integer count) {
this.count = count;
}
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// 獲取當前時間,并格式化
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateSrting = format.format(date);
// 獲取 JDM
System.out.println("---------------------------------------------------");
System.out.println("Trigger JDM ： " + msg);
System.out.println("Count ： " + count);
// 更新 JobDetail JDM 的 count
count++;
context.getJobDetail().getJobDataMap().put("count",count);
// 業(yè)務功能模擬
System.out.println("開始備份數據庫,時間：" + dateSrting);
// 其他內容
System.out.println("Job 運行時間：" + context.getJobRunTime());
System.out.println("Job 當前運行時間：" + context.getFireTime());
System.out.println("Job 下次運行時間：" + context.getNextFireTime());
System.out.println("---------------------------------------------------");
}
}
有狀態(tài) HelloJob：
// 任務類加上下面注解，多次調用 Job，會持久化 Job，JDM 的數據會被保存，供下次使用 @PersistJobDataAfterExecution
1.7 Trigger
Trigger 常用：SimpleTrigger、CronTrigger。JobKey：Job 實例標識，觸發(fā)器觸發(fā)時，執(zhí)行 JobKey 對應任務。StartTime：第一次觸發(fā)時間。EndTime：終止觸發(fā)時間。
Trigger 獲取參數案例
HelloSchedulerTriggerDemo：
package com.sugar.quartz.utils;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.util.Date;
/**
* 功能描述: 定時器配置2
*
* @author XiaoNianXin
* @date 2021/12/13 21:08
*/
public class HelloSchedulerTriggerDemo {
public static void main(String[] args) throws SchedulerException {
// 任務開始時間推遲 3 s,結束時間推遲 10 s
Date startData = new Date();
startData.setTime(startData.getTime() + 3000);
Date endData = new Date();
endData.setTime(endData.getTime() + 10000);
// 1、調度器 - 從工廠獲取調度實例
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
// 2、任務實例 - 執(zhí)行的任務對象
JobDetail job = JobBuilder.newJob(helloJobTrigger.class)
.withIdentity("job1", "group1") // 任務名稱,組名稱
.usingJobData("msg","JDM使用 - Detail") // JDM 傳遞參數
.build();
// 3、觸發(fā)器 - 控制執(zhí)行次數和執(zhí)行時間
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("trigger1", "group1") // 同上
.startNow() // 立刻啟動
.startAt(startData)
.endAt(endData)
.build();
// 調度器關聯觸發(fā)器,并啟動
scheduler.scheduleJob(job,trigger);
scheduler.start();
}
}
helloJobTrigger：
package com.sugar.quartz.utils;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.PersistJobDataAfterExecution;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* 功能描述: 任務類2
*
* @author XiaoNianXin
* @date 2021/12/13 20:52
*/
@PersistJobDataAfterExecution
public class helloJobTrigger implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
// 獲取當前時間,并格式化
Date date = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String dateSrting = format.format(date);
// 業(yè)務功能模擬
System.out.println("---------------------------------------------------");
System.out.println("開始備份數據庫,時間：" + dateSrting);
// 獲取 JobKey,StartTime,EndTime
System.out.println("JobKey ： " + context.getTrigger().getJobKey());
System.out.println("StartTime ： " + format.format(context.getTrigger().getStartTime()));
System.out.println("EndTime ： " + format.format(context.getTrigger().getEndTime()));
System.out.println("---------------------------------------------------");
}
}
// 運行結果
---------------------------------------------------
開始備份數據庫,時間：2021-12-13 23:25:06
JobKey ： group1.job1
StartTime ： 2021-12-13 23:25:06
EndTime ： 2021-12-13 23:25:13
---------------------------------------------------
1.8 SimpleTripper
下文將 SimpleTripper 簡稱為 ST
ST：特定時間范圍啟動/結束，且以一個時間間隔重復 n 次 Job 所設計。- ST 屬性：開始時間、結束時間、重復次數和時間間隔。
- ST 提示：指定了結束時間，那么結束時間優(yōu)先級 > 重復次數。
到此這篇關于Java 任務調度框架 Quartz實操的文章就介紹到這了,更多相關Java 任務調度框架 Quartz內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！
相關文章
mybatis if test判斷BigDecimal遇到的坑及解決
這篇文章主要介紹了mybatis if test判斷BigDecimal遇到的坑及解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-03-03
Elasticsearch查詢及聚合類DSL語句寶典示例詳解
這篇文章主要為大家介紹了Elasticsearch查詢及聚合類DSL語句寶典示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-01-01
這篇文章主要介紹了Java中Range函數的簡單介紹，Java中的range方法用于返回IntStream和LongStream在函數參數范圍內的順序值2022-07-07
這篇文章主要介紹了springboot接收json數據時,接收到空值問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-05-05
這篇文章主要介紹了Java HashMap 如何正確遍歷并刪除元素的方法小結,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-05-05
這篇文章主要介紹了MyBatis使用注解開發(fā)實現過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-03-03
這篇文章主要給大家介紹了關于java利用遞歸實現類別樹的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2020-12-12
這篇文章主要介紹了Spring MVC整合Shiro權限控制，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-05-05
使用java基礎類寫的一個簡單的zip壓縮解壓工具類，實現了指定目錄壓縮到和該目錄同名的zip文件和將zip文件解壓到指定的目錄的功能2014-03-03
這篇文章主要介紹了Java?Spring?循環(huán)依賴解析，Spring?現在其實是我們?Java?程序開發(fā)離不開的基礎框架，個人覺得除了?JDK?我們用得最多的?Java?中間件就是?Spring?,今天我們一起來學習一下?Spring?的循環(huán)依賴。下面詳細內容需要的小伙伴可以參考一下2022-02-02