溫馨提示×

溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊×
獲取短信驗證碼
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
登 錄 注冊有禮
云服務器 香港服務器 高防服務器
最新更新 網站標簽 地圖導航
產品

Java任務調度框架Quartz怎么使用

發布時間：2021-12-14 14:07:09 來源：億速云 閱讀：144 作者：iii 欄目：開發技術

本篇內容介紹了“Java任務調度框架Quartz怎么使用”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠學有所成！

     Quartz相較于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 入門案例

    任務：將任務類執行 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);
        // 業務功能模擬
        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、任務實例 - 執行的任務對象
        JobDetail job = JobBuilder.newJob(HelloJob.class)
                .withIdentity("job1", "group1") // 任務名稱,組名稱
                .build();

        // 3、觸發器 - 控制執行次數和執行時間
        Trigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("trigger1", "group1") // 同上
                .startNow() // 立刻啟動
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().
                        withIntervalInSeconds(3).
                        withRepeatCount(10))   // 循環10次,每次間隔3s
                .build();

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

    1.3 Job 與 JobDetail

    • Job：基于反射的任務調度接口，所有任務類都要實現該接口，在接口的 execute 里編寫自己的業務邏輯。

    • Job 生命周期：每次執行 Job，在 execute 方法前會創建新的 Job實例，調用后實例被釋放，再被GC回收。

    • JobDetail：封裝 Job，給 Job 實例提供許多屬性。

    • JobDetail 屬性：name、group、jobClass、jobDataMap。

    1.4 JobExecutionContext

    下文將 JobExecutionContext 簡稱為 JEC

    • JEC ：當調度器調用 Job 時，會將 JEC 傳遞給 Job 的 execute 方法。

    • JEC 作用：Job 通過 JEC 獲取運行環境信息，以及 Job 信息。

    1.5 JobDataMap

    下文將 JobDataMap 簡稱為 JDM

    • JDM：任務調度時，JDM 存儲在 JEC 中，方便獲取。

    • JDM 優點：實現 Map 接口，可以存取任何可序列化對象，Job 執行時會將參數傳給 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、任務實例 - 執行的任務對象
        JobDetail job = JobBuilder.newJob(HelloJob.class)
                .withIdentity("job1", "group1") // 任務名稱,組名稱
                .usingJobData("msg","JDM使用 - Detail")    // JDM 傳遞參數
                .build();

        // 3、觸發器 - 控制執行次數和執行時間
        Trigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("trigger1", "group1") // 同上
                .startNow() // 立刻啟動
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().
                        withIntervalInSeconds(3).
                        withRepeatCount(10))   // 循環10次,每次間隔3s
                .usingJobData("msg","JDM使用 - Trigger")
                .build();

        // 調度器關聯觸發器,并啟動
        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;

/**
 * 功能描述: 定時業務功能
 *
 * @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);

        // 業務功能模擬
        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 狀態

    • 有狀態 Job：多次調用 Job 期間，公用同一個 JDM。

    • 有狀態 Job：多次調用 Job 期間，每次新建一個新的 JDM。

    有無狀態 Job 區別案例

    預期：無狀態 count 輸出永遠為 1，有狀態 count 輸出累加。

    HelloSchedulerDemo：

    // JobDeatil 添加一個 JDM，用做計數器
.usingJobData("count",0)

    無狀態 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);

        // 業務功能模擬
        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("---------------------------------------------------");
    }
}

    有狀態 HelloJob：

    // 任務類加上下面注解，多次調用 Job，會持久化 Job，JDM 的數據會被保存，供下次使用
@PersistJobDataAfterExecution

    1.7 Trigger

    • Trigger 常用：SimpleTrigger、CronTrigger。

    • JobKey：Job 實例標識，觸發器觸發時，執行 JobKey 對應任務。

    • StartTime：第一次觸發時間。

    • EndTime：終止觸發時間。

    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、任務實例 - 執行的任務對象
        JobDetail job = JobBuilder.newJob(helloJobTrigger.class)
                .withIdentity("job1", "group1") // 任務名稱,組名稱
                .usingJobData("msg","JDM使用 - Detail")    // JDM 傳遞參數
                .build();

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

        // 調度器關聯觸發器,并啟動
        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);

        // 業務功能模擬
        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 提示：指定了結束時間，那么結束時間優先級 > 重復次數。

    “Java任務調度框架Quartz怎么使用”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站，小編將為大家輸出更多高質量的實用文章！

    向AI問一下細節
    推薦閱讀：
    1. Java分布式任務調度框架XXL-Job的介紹
    2. Quartz.Net調度框架配置解析

    免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。

    java quartz

    猜你喜歡

    最新資訊
    相關推薦

    相關標簽

    java學習 凱哥java javamail java學習路線 java編程思想 javassist java技術 java web java配置 java架構 java異常 javaweb項目 java嵌入 javajava筆記編程學習 java類 java包 java對象 java api java鎖 javamailsender
    AI
    助
    手
    產品服務
    地區劃分
    專題活動
    幫助支持
    關于我們
    售后咨詢
    7*24小時在線電話：400-100-2938
    7*24小時在線 QQ：800811969
    關注億速云

    億速云公眾號

    手機網站二維碼

    Copyright ? Yisu Cloud Ltd. All Rights Reserved. 2018 版權所有

    廣州億速云計算有限公司粵ICP備17096448號-1 粵公網安備 44010402001142號增值電信業務經營許可證編號：B1-20181529

    亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女