Quartz學(xué)習(xí)之入門學(xué)習(xí)

Pandaaa 發(fā)布于2019-08-16 12:30 / 2314人閱讀

摘要：觸發(fā)器也可以給予名稱和放置在組中，以方便地將它們調(diào)度內(nèi)組織。作業(yè)可以被添加到所述調(diào)度器一次，而是具有多個觸發(fā)器注冊。調(diào)度類鏈接工作和觸發(fā)器到一起，并執(zhí)行它。

簡介

Quartz是一個開源的作業(yè)調(diào)度框架，可以讓計劃的程序任務(wù)一個預(yù)定義的日期和時間運行。Quartz可以用來創(chuàng)建簡單或復(fù)雜的日程安排執(zhí)行幾十，幾百，甚至是十萬的作業(yè)數(shù)。
官方鏈接，戳這里

Quartz是什么? 作業(yè)調(diào)度庫

Quartz 是一種功能豐富的，開放源碼的作業(yè)調(diào)度庫，可以在幾乎任何Java應(yīng)用程序集成 - 從最小的獨立的應(yīng)用程序到規(guī)模最大電子商務(wù)系統(tǒng)。Quartz可以用來創(chuàng)建簡單或復(fù)雜的日程安排執(zhí)行幾十，幾百，甚至是十萬的作業(yè)數(shù) - 作業(yè)被定義為標(biāo)準(zhǔn)的Java組件，可以執(zhí)行幾乎任何東西，可以編程讓它們執(zhí)行。 Quartz調(diào)度包括許多企業(yè)級功能，如JTA事務(wù)和集群支持。

Quartz 是可自由使用，使用Apache 2.0 license授權(quán)方式。

作業(yè)調(diào)度

如果應(yīng)用程序需要在給定時間執(zhí)行任務(wù)，或者如果系統(tǒng)有連續(xù)維護作業(yè)，那么Quartz是理想的解決方案。

作業(yè)被安排在一個給定的觸發(fā)時運行。觸發(fā)器可以使用以下指令的接近任何組合來創(chuàng)建：

在一天中的某個時間（到毫秒）

在一周的某幾天

在每月的某一天

在一年中的某些日期

不在注冊的日歷中列出的特定日期（如商業(yè)節(jié)假日除外）

重復(fù)特定次數(shù)

重復(fù)進行，直到一個特定的時間/日期

無限重復(fù)

重復(fù)的延遲時間間隔

作業(yè)是由其創(chuàng)建者賦予的名字，也可以組織成命名組。觸發(fā)器也可以給予名稱和放置在組中，以方便地將它們調(diào)度內(nèi)組織。作業(yè)可以被添加到所述調(diào)度器一次，而是具有多個觸發(fā)器注冊。在企業(yè)Java環(huán)境中，作業(yè)可以執(zhí)行自己的工作作為分布式（XA）事務(wù)的一部分。

集群

故障切換

負(fù)載均衡

Quartz的內(nèi)置的群集功能，通過JDBCJobStore依靠數(shù)據(jù)庫持久

Terracotta擴展Quartz提供集群功能，而不需要一個支持?jǐn)?shù)據(jù)庫

使用的 jar 包

quartz-2.2.1.jar

quartz-jobs-2.2.1.jar

三個重要的概念簡介 Scheduler

調(diào)度器。所有的調(diào)度都是由它控制。調(diào)度類鏈接“工作”和“觸發(fā)器”到一起，并執(zhí)行它。

scheduler 實例化后，可以啟動(start)、暫停(stand-by)、停止(shutdown)。注意：scheduler 被停止后，除非重新實例化，否則不能重新啟動；只有當(dāng) scheduler 啟動后，即使處于暫停狀態(tài)也不行，trigger 才會被觸發(fā)（job才會被執(zhí)行）

Scheduler的生命期，從SchedulerFactory創(chuàng)建它時開始，到Scheduler調(diào)用shutdown()方法時結(jié)束；Scheduler被創(chuàng)建后，可以增加、刪除和列舉Job和Trigger，以及執(zhí)行其它與調(diào)度相關(guān)的操作（如暫停Trigger）。但是，Scheduler只有在調(diào)用start()方法后，才會真正地觸發(fā)trigger（即執(zhí)行job）

Scheduler scheduler = new StdSchedulerFactory().getScheduler();
scheduler.start();
scheduler.scheduleJob(job, trigger);

Scheduler的主要函數(shù)：

start():啟動

standby():掛起

shutdown()：關(guān)閉

shutdown(true)表示等待所有正在執(zhí)行的job執(zhí)行完畢后，在關(guān)閉scheduler

shutdown(false)即shutdown()表示直接關(guān)閉scheduler

注意關(guān)閉之后，scheduler不能從新開啟，會拋出異常

Trigger

Trigger用于觸發(fā)Job的執(zhí)行。當(dāng)你準(zhǔn)備調(diào)度一個job時，你創(chuàng)建一個Trigger的實例，然后設(shè)置調(diào)度相關(guān)的屬性。Trigger也有一個相關(guān)聯(lián)的JobDataMap，用于給Job傳遞一些觸發(fā)相關(guān)的參數(shù)。Quartz自帶了各種不同類型的Trigger，最常用的主要是SimpleTrigger和CronTrigger。

SimpleTrigger – 允許設(shè)置開始時間，結(jié)束時間，重復(fù)間隔。主要用于一次性執(zhí)行的Job（只在某個特定的時間點執(zhí)行一次），或者Job在特定的時間點執(zhí)行，重復(fù)執(zhí)行N次，每次執(zhí)行間隔T個時間單位。

CronTrigger – 允許UNIX cron表達(dá)式來指定日期和時間來運行作業(yè)。在基于日歷的調(diào)度上非常有用，如“每個星期五的正午”，或者“每月的第十天的上午10:15”等。

SimpleTrigger – 每5秒運行

Trigger trigger = TriggerBuilder
    .newTrigger()
    .withIdentity("dummyTriggerName", "group1")
    .withSchedule(
        SimpleScheduleBuilder.simpleSchedule()
        .withIntervalInSeconds(5).repeatForever())
    .build();

CronTrigger – 每5秒運行。

Trigger trigger = TriggerBuilder
    .newTrigger()
    .withIdentity("dummyTriggerName", "group1")
    .withSchedule(
        CronScheduleBuilder.cronSchedule("0/5 * * * * ?"))
    .build();

JobDetail & Job

JobDetail 定義的是任務(wù)數(shù)據(jù)，而真正的執(zhí)行邏輯是在Job中。

JobDetail對象是在將job加入scheduler時，由客戶端程序（你的程序）創(chuàng)建的。它包含job的各種屬性設(shè)置，以及用于存儲job實例狀態(tài)信息的JobDataMap。

例子說明

1.下載 jar 包

可以從官方網(wǎng)站或 Maven 中央存儲庫下載 Quartz 庫文件；

2.創(chuàng)建一個作業(yè)

HelloJob.java

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class HelloJob implements Job{

    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        // TODO Auto-generated method stub
        System.out.println("Hello Quartz!");
    }
}

3.創(chuàng)建觸發(fā)器，以及通過調(diào)度執(zhí)行作業(yè)

SimpleTrigger.java

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class SimpleTrigger {

    public static void main(String[] args) throws Exception {

        JobDetail job = JobBuilder.newJob(HelloJob.class)
                .withIdentity("dummyJobName", "group1").build();

         // 定義一個Trigger
        Trigger trigger = TriggerBuilder
                .newTrigger()
                .withIdentity("dummyTriggerName", "group1")        // 定義 name/group
                .withSchedule(
                        SimpleScheduleBuilder.simpleSchedule()
                                .withIntervalInSeconds(5).repeatForever())
                .build();
        
        Scheduler scheduler = new StdSchedulerFactory().getScheduler();
        scheduler.start();
        scheduler.scheduleJob(job, trigger);
    }
}

CronTrigger.java

import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class CronTrigger {

    public static void main(String[] args) throws Exception {
        JobDetail job = JobBuilder.newJob(HelloJob.class)
                .withIdentity("dummyJobName", "group").build();

        Trigger trigger = TriggerBuilder
                .newTrigger()
                .withIdentity("dummyJobName", "group")
                .withSchedule(CronScheduleBuilder.cronSchedule("0/5 * * * * ?"))
                .build();

        Scheduler scheduler = new StdSchedulerFactory().getScheduler();
        scheduler.start();
        scheduler.scheduleJob(job, trigger);
    }
}

輸出的結(jié)果如下：

每隔五分鐘就會打印出一條 Hello Quartz!

Hello Quartz!
Hello Quartz!
Hello Quartz!

Quartz 的其他概念

JobExecutionContext

當(dāng) Schedule 調(diào)用一個 Job，就會將 JobExecutionContext 傳遞給 Job 的 execute() 方法

Job 能通過 JobExecutionContext 對象訪問到 Quartz 運行時候的環(huán)境以及 Job本身的明細(xì)數(shù)據(jù)

JobDataMap

在進行任務(wù)調(diào)度時 JobDataMap存儲在JobExecutionContext中，非常方便獲取

JobDataMap 可以用來裝載任何可序列化的數(shù)據(jù)對象，當(dāng)job 實例對象被執(zhí)行時這些參數(shù)對象會傳遞給它

JobDataMap實現(xiàn)了JDK的Map接口，并且添加了一些非常方便的方法用來存取數(shù)據(jù)基本類型

key

將Job和Trigger注冊到Scheduler時，可以為它們設(shè)置key，配置其身份屬性。

Job和Trigger的key（JobKey和TriggerKey）可以用于將Job和Trigger放到不同的分組（group）里，然后基于分組進行操作。

同一個分組下的Job或Trigger的名稱必須唯一，即一個Job或Trigger的key由名稱（name）和分組（group）組成。

實例說明

第一步：創(chuàng)建一個 Job。

在這個類中，我們通過 JobExecutionContext 來獲取 JobDataMap、key以及通過自定義傳入的信息。代碼中有備注，仔細(xì)看下就知道了。

HelloJob.java

import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.TriggerKey;

public class HelloJob implements Job{

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // TODO Auto-generated method stub
        System.out.println("Hello Quartz!");
        
        // 獲取 JobDetail 的 key 和 group
        JobKey key = context.getJobDetail().getKey();
        System.out.println("JobDetail key name: "+key.getName());
        System.out.println("JobDetail key Group: "+key.getGroup());
        
        // 從 JobExecutionContext 中獲取一個實例,  獲取從 jobDetail 傳入的數(shù)據(jù)
        JobDataMap dataMap = context.getJobDetail().getJobDataMap();
        String JobMsg = dataMap.getString("message");
        Float floatMsg = dataMap.getFloat("floatData");
        System.out.println("JobDetial:"+ JobMsg);
        System.out.println("floatMsg:"+ floatMsg);
        
        //獲取 trigger 的 key 和 group
        TriggerKey triggerKey = context.getTrigger().getKey();
        System.out.println("TriggerKey key name: "+triggerKey.getName());
        System.out.println("TriggerKey key Group: "+triggerKey.getGroup());
        
        // 獲取一個 trigger 的 jobDataMap 實例
        JobDataMap triggerMap = context.getTrigger().getJobDataMap();
        String triggerMsg = dataMap.getString("message");
        System.out.println("triggerMsg:"+ triggerMsg);
    }
}

第二步：測試類

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class SimpleTrigger {

    public static void main(String[] args) throws Exception {

        JobDetail job = JobBuilder.newJob(HelloJob.class)
                .withIdentity("dummyJobName", "group1")
                .usingJobData("message", "hello myJob1")    //傳入自定義的數(shù)據(jù)
                .usingJobData("floatData", 1.2F)
                .build();

         // 定義一個Trigger
        Trigger trigger = TriggerBuilder
                .newTrigger()
                .withIdentity("dummyTriggerName", "group1")        // 定義 name/group
                .usingJobData("message", "hello myTrigger")
                .withSchedule(
                        SimpleScheduleBuilder.simpleSchedule()
                                .withIntervalInSeconds(5).repeatForever())
                .build();
        
        Scheduler scheduler = new StdSchedulerFactory().getScheduler();
        scheduler.start();
        scheduler.scheduleJob(job, trigger);
    }
}

輸出結(jié)果

Hello Quartz!
JobDetail key name: dummyJobName
JobDetail key Group: group1
JobDetial:hello myJob1
floatMsg:1.2
TriggerKey key name: dummyTriggerName
TriggerKey key Group: group1
triggerMsg:hello myJob1

附

w3cschool 上的quartz 教程

官方鏈接

GPU云服務(wù)器云服務(wù)器學(xué)習(xí)之substr() 深度學(xué)習(xí)之概要 webrtc學(xué)習(xí)之九 linux學(xué)習(xí)之centos

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://m.hztianpu.com/yun/71215.html

發(fā)表評論

登陸后可評論

0條評論

Pandaaa

男|高級講師

我要關(guān)注我要私信

TA的文章

在anaconda下安裝tensorflow

閱讀 1881·2023-04-25 15:50
怎么看網(wǎng)站是服務(wù)器還是虛擬主機-服務(wù)器與虛擬主機有什么區(qū)別？

閱讀 1366·2021-09-22 15:49
主機優(yōu)勢是什么意思-電信云主機是什么？

閱讀 3082·2021-09-22 15:06
【每日一包0029】merge-descriptors

閱讀 3757·2019-08-30 15:54
RDD的前端背包

閱讀 2394·2019-08-29 11:33
node.js來爬取智聯(lián)全國的競爭最激烈的前十崗位

閱讀 2175·2019-08-23 17:56
WebGL three.js學(xué)習(xí)筆記紋理貼圖模擬太陽系運轉(zhuǎn)

閱讀 2301·2019-08-23 17:06
每日 30 秒 ? 復(fù)制內(nèi)容到剪貼板

閱讀 1353·2019-08-23 15:55

成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲中文字幕日韩无码

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Quartz學(xué)習(xí)之入門學(xué)習(xí)

相關(guān)文章

Quartz學(xué)習(xí)之多作業(yè)、監(jiān)聽

Quartz學(xué)習(xí)之常用Trigger方法記錄

Quartz學(xué)習(xí)之Cron Expressions表達(dá)式

**Vim入門學(xué)習(xí)之二(cheat sheet)**

**Vim入門學(xué)習(xí)之二(cheat sheet)**

發(fā)表評論

0條評論

Pandaaa

男|高級講師

TA的文章

在anaconda下安裝tensorflow

怎么看網(wǎng)站是服務(wù)器還是虛擬主機-服務(wù)器與虛擬主機有什么區(qū)別？

主機優(yōu)勢是什么意思-電信云主機是什么？

【每日一包0029】merge-descriptors

RDD的前端背包

node.js來爬取智聯(lián)全國的競爭最激烈的前十崗位

WebGL three.js學(xué)習(xí)筆記紋理貼圖模擬太陽系運轉(zhuǎn)

每日 30 秒 ? 復(fù)制內(nèi)容到剪貼板

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

Quartz學(xué)習(xí)之入門學(xué)習(xí)

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！