Java?任務調度框架?Quartz實操

更新時間：2021年12月14日 11:41:46 作者：一枚方糖

這篇文章主要介紹了Java?任務調度框架?Quartz,Quartz是OpenSymphony開源組織在Job?scheduling領域又一個開源項目，完全由Java開發(fā)，可以用來執(zhí)行定時任務，類似于java.util.Timer。,下面我們來學習一下關于?Quartz更多的詳細內容,需要的朋友可以參考一下

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 秒。

任務類,需要實現(xiàn) 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("開始備份數(shù)據庫,時間：" + 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í)行次數(shù)和執(zhí)行時間
        Trigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("trigger1", "group1") // 同上
                .startNow() // 立刻啟動
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().
                        withIntervalInSeconds(3).
                        withRepeatCount(10))   // 循環(huán)10次,每次間隔3s
                .build();

        // 調度器關聯(lián)觸發(fā)器,并啟動
        scheduler.scheduleJob(job,trigger);
        scheduler.start();
    }
}

1.3 Job 與 JobDetail

Job：基于反射的任務調度接口，所有任務類都要實現(xiàn)該接口，在接口的 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)點：實現(xiàn) Map 接口，可以存取任何可序列化對象，Job 執(zhí)行時會將參數(shù)傳給 JDM。

手動獲取 JDM 參數(shù)案例

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 傳遞參數(shù)
                .build();

        // 3、觸發(fā)器 - 控制執(zhí)行次數(shù)和執(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();

        // 調度器關聯(lián)觸發(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("開始備份數(shù)據庫,時間：" + dateSrting);

        // 其他內容
        System.out.println("Job 運行時間：" + context.getJobRunTime());
        System.out.println("Job 當前運行時間：" + context.getFireTime());
        System.out.println("Job 下次運行時間：" + context.getNextFireTime());
        System.out.println("---------------------------------------------------");
    }
}

2、Job 類實現(xiàn) JDM 參數(shù)的 Setter 方法，實例化時自動綁定參數(shù)

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，用做計數(shù)器
.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("開始備份數(shù)據庫,時間：" + 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 的數(shù)據會被保存，供下次使用
@PersistJobDataAfterExecution

1.7 Trigger

Trigger 常用：SimpleTrigger、CronTrigger。
JobKey：Job 實例標識，觸發(fā)器觸發(fā)時，執(zhí)行 JobKey 對應任務。
StartTime：第一次觸發(fā)時間。
EndTime：終止觸發(fā)時間。

Trigger 獲取參數(shù)案例

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 傳遞參數(shù)
                .build();

        // 3、觸發(fā)器 - 控制執(zhí)行次數(shù)和執(zhí)行時間
        Trigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("trigger1", "group1") // 同上
                .startNow() // 立刻啟動
                .startAt(startData)
                .endAt(endData)
                .build();

        // 調度器關聯(lián)觸發(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("開始備份數(shù)據庫,時間：" + 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("---------------------------------------------------");
    }
}

// 運行結果
---------------------------------------------------
開始備份數(shù)據庫,時間：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 屬性：開始時間、結束時間、重復次數(shù)和時間間隔。
ST 提示：指定了結束時間，那么結束時間優(yōu)先級 > 重復次數(shù)。

到此這篇關于Java 任務調度框架 Quartz實操的文章就介紹到這了,更多相關Java 任務調度框架 Quartz內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

Java
Quartz

mybatis if test判斷BigDecimal遇到的坑及解決
這篇文章主要介紹了mybatis if test判斷BigDecimal遇到的坑及解決方案，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2023-03-03
Elasticsearch查詢及聚合類DSL語句寶典示例詳解
這篇文章主要為大家介紹了Elasticsearch查詢及聚合類DSL語句寶典示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪
2023-01-01
Java中Range函數(shù)的簡單介紹
這篇文章主要介紹了Java中Range函數(shù)的簡單介紹，Java中的range方法用于返回IntStream和LongStream在函數(shù)參數(shù)范圍內的順序值
2022-07-07
springboot接收json數(shù)據時,接收到空值問題
這篇文章主要介紹了springboot接收json數(shù)據時,接收到空值問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
2024-05-05
Java HashMap 如何正確遍歷并刪除元素的方法小結
這篇文章主要介紹了Java HashMap 如何正確遍歷并刪除元素的方法小結,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2019-05-05
MyBatis使用注解開發(fā)實現(xiàn)過程詳解
這篇文章主要介紹了MyBatis使用注解開發(fā)實現(xiàn)過程詳解,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2020-03-03
java利用遞歸實現(xiàn)類別樹示例代碼
這篇文章主要給大家介紹了關于java利用遞歸實現(xiàn)類別樹的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2020-12-12
Spring MVC整合Shiro權限控制的方法
這篇文章主要介紹了Spring MVC整合Shiro權限控制，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2018-05-05
使用java基礎類實現(xiàn)zip壓縮和zip解壓工具類分享
使用java基礎類寫的一個簡單的zip壓縮解壓工具類，實現(xiàn)了指定目錄壓縮到和該目錄同名的zip文件和將zip文件解壓到指定的目錄的功能
2014-03-03
Java?Spring?循環(huán)依賴解析
這篇文章主要介紹了Java?Spring?循環(huán)依賴解析，Spring?現(xiàn)在其實是我們?Java?程序開發(fā)離不開的基礎框架，個人覺得除了?JDK?我們用得最多的?Java?中間件就是?Spring?,今天我們一起來學習一下?Spring?的循環(huán)依賴。下面詳細內容需要的小伙伴可以參考一下
2022-02-02

最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Java?任務調度框架?Quartz實操

目錄

1、Quartz

1.1 引入依賴

1.2 入門案例

任務類,需要實現(xiàn) Job 接口

定時器類

1.3 Job 與 JobDetail

1.4 JobExecutionContext

1.5 JobDataMap

手動獲取 JDM 參數(shù)案例

2、Job 類實現(xiàn) JDM 參數(shù)的 Setter 方法，實例化時自動綁定參數(shù)

1.6 Job 狀態(tài)

有無狀態(tài) Job 區(qū)別案例

1.7 Trigger

Trigger 獲取參數(shù)案例

1.8 SimpleTripper

相關文章

最新評論

大家感興趣的內容

最近更新的內容

常用在線小工具

最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Java?任務調度框架?Quartz實操

目錄

1、Quartz

1.1 引入依賴

1.2 入門案例

任務類,需要實現(xiàn) Job 接口

定時器類

1.3 Job 與 JobDetail

1.4 JobExecutionContext

1.5 JobDataMap

手動獲取 JDM 參數(shù)案例

2、Job 類實現(xiàn) JDM 參數(shù)的 Setter 方法，實例化時自動綁定參數(shù)

1.6 Job 狀態(tài)

有無狀態(tài) Job 區(qū)別案例

1.7 Trigger

Trigger 獲取參數(shù)案例

1.8 SimpleTripper

相關文章

最新評論

大家感興趣的內容

最近更新的內容

常用在線小工具

1、Quartz

2、Job 類實現(xiàn) JDM 參數(shù)的 Setter 方法，實例化時自動綁定參數(shù)