Quartz初級教程

lncwwn 發布于2019-08-15 15:53 / 3411人閱讀

摘要：是一個任務日程管理系統，一個在預先確定被納入日程的時間到達時，負責執行或者通知其他軟件組件的系統。核心接口核心調度器任務任務描述觸發器和是同時相互依賴存在的，和觸發器一起注冊到核心調度器。

一、Quartz簡介 1. Quartz

Quartz是OpenSymphony開源組織在Job scheduling領域又一個開源項目,它可以與J2EE與J2SE應用程序相結合也可以多帶帶使用。Quartz可以用來創建簡單或為運行十個，百個，甚至是好幾萬個Jobs這樣復雜的日程序表。Jobs可以做成標準的Java組件或 EJBs。

Quartz是一個任務日程管理系統，一個在預先確定（被納入日程）的時間到達時，負責執行（或者通知）其他軟件組件的系統。

Quartz用一個小Java庫發布文件（.jar文件），這個庫文件包含了所有Quartz核心功能。這些功能的主要接口(API)是Scheduler接口。

2. Quartz核心接口

Scheduler – 核心調度器

Job – 任務

JobDetail – 任務描述

Trigger -- 觸發器

Job和JobDetail是同時相互依賴存在的，和觸發器一起注冊到核心調度器。
Quartz的執行過程： Scheduler--> Trigger --> JobDetail --> Job

3. Tigger

SimpleTrigger

CronTrigger

SimpleTrigger

SimpleTrigger用來觸發只需執行一次或者在給定時間觸發并且重復N次且每次執行延遲一定時間的任務。

CronTrigger

像日歷那樣按日程來觸發任務，而不是像SimpleTrigger 那樣每隔特定的間隔時間觸發，CronTriggers通常比SimpleTrigger更有用。

二、Cron Expressions 1. CronTrigger

CronTriggers往往比SimpleTrigger更有用，如果您需要基于日歷的概念，而非SimpleTrigger完全指定的時間間隔，復發的發射工作的時間表。
CronTrigger，你可以指定觸發的時間表如“每星期五中午”，或“每個工作日9:30時”，甚至“每5分鐘一班9:00和10:00逢星期一上午，星期三星期五“。
即便如此，SimpleTrigger一樣，CronTrigger擁有的startTime指定的時間表時生效，指定的時間表時，應停止（可選）結束時間。

2. Cron Expressions

cron的表達式被用來配置CronTrigger實例。 cron的表達式是字符串，實際上是由七子表達式，描述個別細節的時間表。這些子表達式是分開的空白，代表：

1 . 1. Seconds
2 . 2. Minutes
3 . 3. Hours
4 . 4. Day-of-Month
5 . 5. Month
6 . 6. Day-of-Week
7 . 7. Year (可選字段)

例: "0 0 12 ? * WED" 在每星期三下午12:00 執行。

個別子表達式可以包含范圍, 例如，在前面的例子里("WED")可以替換成 "MON-FRI", "MON, WED, FRI"甚至"MON-WED,SAT".
“*” 代表整個時間段.
每一個字段都有一套可以指定有效值，如
Seconds (秒)：可以用數字0－59 表示，
Minutes(分)：可以用數字0－59 表示，
Hours(時)：可以用數字0-23表示,
Day-of-Month(天)：可以用數字1-31 中的任一一個值，但要注意一些特別的月份
Month(月)：可以用0-11 或用字符串 “JAN, FEB, MAR, APR, MAY, JUN, JUL, AUG, SEP, OCT, NOV and DEC” 表示
Day-of-Week(每周)：可以用數字1-7表示（1 ＝星期日）或用字符口串“SUN, MON, TUE, WED, THU, FRI and SAT”表示

“/”：為特別單位，表示為“每”如“0/15”表示每隔15分鐘執行一次,“0”表示為從“0”分開始, “3/20”表示表示每隔20分鐘執行一次，“3”表示從第3分鐘開始執行
“?”：表示每月的某一天，或第周的某一天
“L”：用于每月，或每周，表示為每月的最后一天，或每個月的最后星期幾如“6L”表示“每月的最后一個星期五”
“W”：表示為最近工作日，如“15W”放在每月（day-of-month）字段上表示為“到本月15日最近的工作日”
““#”：是用來指定“的”每月第n個工作日,例在每周（day-of-week）這個字段中內容為"6#3" or "FRI#3" 則表示“每月第三個星期五”

1). Cron表達式的格式：秒分時日月周年(可選)。

字段名	允許的值	允許的特殊字符
秒	0-59	, - * /
分	0-59	, - * /
小時	0-23	, - * /
日	1-31	, - * ? / L W C
月	1-12 or JAN-DEC	, - * /
周幾	1-7 or SUN-SAT	, - * ? / L C #
年（可選字段）	empty, 1970-2099	, - * /

 “?”字符：表示不確定的值
 “,”字符：指定數個值
 “-”字符：指定一個值的范圍
 “/”字符：指定一個值的增加幅度。n/m表示從n開始，每次增加m
 “L”字符：用在日表示一個月中的最后一天，用在周表示該月最后一個星期X
 “W”字符：指定離給定日期最近的工作日(周一到周五)
 “#”字符：表示該月第幾個周X。6#3表示該月第3個周五

2). Cron表達式范例：

每隔5秒執行一次：/5 * ?
每隔1分鐘執行一次：0 /1 ?
每天23點執行一次：0 0 23 ?
每天凌晨1點執行一次：0 0 1 ?
每月1號凌晨1點執行一次：0 0 1 1 * ?
每月最后一天23點執行一次：0 0 23 L * ?
每周星期天凌晨1點實行一次：0 0 1 ? * L
在26分、29分、33分執行一次：0 26,29,33 * ?
每天的0點、13點、18點、21點都執行一次：0 0 0,13,18,21 ?

三、Quartz 觸發器Tigger的簡單案例

前面對Tigger進行過簡單描述，現在用Demo進行演示

Quartz的Maven依賴


          org.quartz-scheduler
          quartz
          2.2.1

1 . 實現一個Job接口

/* 
 * All content copyright Terracotta, Inc., unless otherwise indicated. All rights reserved. 
 * 
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not 
 * use this file except in compliance with the License. You may obtain a copy 
 * of the License at 
 * 
 *   http://www.apache.org/licenses/LICENSE-2.0 
 *   
 * Unless required by applicable law or agreed to in writing, software 
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT 
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the 
 * License for the specific language governing permissions and limitations 
 * under the License.
 * 
 */
 
package org.ouhei.quartz.example;

import java.util.Date;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

/**
 * 
 * This is just a simple job that says "Hello" to the world.
 * 
 * 
 * @author Bill Kratzer
 */
public class HelloJob implements Job {

    private static Logger _log = LoggerFactory.getLogger(HelloJob.class);

    /**
     * 
     * Empty constructor for job initilization
     * 
     * 
     * Quartz requires a public empty constructor so that the
     * scheduler can instantiate the class whenever it needs.
     * 
     */
    public HelloJob() {
    }

    /**
     * 
     * Called by the {@link org.quartz.Scheduler} when a
     * {@link org.quartz.Trigger} fires that is associated with
     * the Job.
     * 
     * 
     * @throws JobExecutionException
     *             if there is an exception while executing the job.
     */
    public void execute(JobExecutionContext context)
        throws JobExecutionException {

        // Say Hello to the World and display the date/time
        _log.info("Hello World! - " + new Date());
    }

}

2 . SimpleTrigger觸發器進行模擬

SimpleExample代碼

/* 
 * All content copyright Terracotta, Inc., unless otherwise indicated. All rights reserved. 
 * 
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not 
 * use this file except in compliance with the License. You may obtain a copy 
 * of the License at 
 * 
 *   http://www.apache.org/licenses/LICENSE-2.0 
 *   
 * Unless required by applicable law or agreed to in writing, software 
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT 
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the 
 * License for the specific language governing permissions and limitations 
 * under the License.
 * 
 */

package org.ouhei.quartz.example;

import static org.quartz.DateBuilder.evenMinuteDate;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Date;

/**
 * This Example will demonstrate how to start and shutdown the Quartz scheduler and how to schedule
 * a job to run in Quartz.
 * 
 * @author Bill Kratzer
 */
public class SimpleExample {

    public void run() throws Exception {
        Logger log = LoggerFactory.getLogger(SimpleExample.class);

        log.info("------- Initializing ----------------------");

        // 定義調度器
        SchedulerFactory sf = new StdSchedulerFactory();
        Scheduler sched = sf.getScheduler();

        log.info("------- Initialization Complete -----------");

        // 獲取當前時間的下一分鐘
        Date runTime = evenMinuteDate(new Date());

        log.info("------- Scheduling Job  -------------------");

        // 定義job
        // 在quartz中，有組的概念，組+job名稱 唯一的
        JobDetail job = newJob(HelloJob.class).withIdentity("job1", "group1").build();

        // 定義觸發器，在下一分鐘啟動
        Trigger trigger = newTrigger().withIdentity("trigger1", "group1").startAt(runTime).build();

        // 將job注冊到調度器
        sched.scheduleJob(job, trigger);
        log.info(job.getKey() + " will run at: " + runTime);

        // 啟動調度器
        sched.start();

        log.info("------- Started Scheduler -----------------");

        // 等待65秒
        log.info("------- Waiting 65 seconds... -------------");
        try {
            // wait 65 seconds to show job
            Thread.sleep(65L * 1000L);
            // executing...
        } catch (Exception e) {
            //
        }

        // 關閉調度器
        log.info("------- Shutting Down ---------------------");
        sched.shutdown(true);
        log.info("------- Shutdown Complete -----------------");
    }

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

        SimpleExample example = new SimpleExample();
        example.run();

    }

}

3 . 添加日志文件log4j.properties

log4j.rootLogger=DEBUG,A1
log4j.logger.com.taotao = DEBUG
log4j.logger.org.mybatis = DEBUG

log4j.appender.A1=org.apache.log4j.ConsoleAppender
log4j.appender.A1.layout=org.apache.log4j.PatternLayout
log4j.appender.A1.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss,SSS} [%t] [%c]-[%p] %m%n

運行main方法，觀察控制臺。

如果模擬CronTrigger觸發器，把上述的SimpleExample代碼用SimpleCronExample代碼替換

SimpleCronExample代碼：

/* 
 * All content copyright Terracotta, Inc., unless otherwise indicated. All rights reserved. 
 * 
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not 
 * use this file except in compliance with the License. You may obtain a copy 
 * of the License at 
 * 
 *   http://www.apache.org/licenses/LICENSE-2.0 
 *   
 * Unless required by applicable law or agreed to in writing, software 
 * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT 
 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the 
 * License for the specific language governing permissions and limitations 
 * under the License.
 * 
 */

package org.ouhei.quartz.example;

import static org.quartz.CronScheduleBuilder.cronSchedule;
import static org.quartz.DateBuilder.evenMinuteDate;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;

import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.impl.StdSchedulerFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.Date;

/**
 * This Example will demonstrate how to start and shutdown the Quartz scheduler and how to schedule
 * a job to run in Quartz.
 * 
 * @author Bill Kratzer
 */
public class SimpleCronExample {

    public void run() throws Exception {
        Logger log = LoggerFactory.getLogger(SimpleCronExample.class);

        log.info("------- Initializing ----------------------");

        // 定義調度器
        SchedulerFactory sf = new StdSchedulerFactory();
        Scheduler sched = sf.getScheduler();

        log.info("------- Initialization Complete -----------");

        // 獲取當前時間的下一分鐘
        Date runTime = evenMinuteDate(new Date());

        log.info("------- Scheduling Job  -------------------");

        // 定義job
        JobDetail job = newJob(HelloJob.class).withIdentity("job1", "group1").build();

        // 定義觸發器，每2秒執行一次
        Trigger trigger = newTrigger().withIdentity("trigger1", "group1")
                .withSchedule(cronSchedule("0 0/1 * * * ?")).build();

        // 將job注冊到調度器
        sched.scheduleJob(job, trigger);
        log.info(job.getKey() + " will run at: " + runTime);

        // 啟動調度器
        sched.start();

        log.info("------- Started Scheduler -----------------");

        // 等待1分鐘
        log.info("------- Waiting 60 seconds... -------------");
        try {
            Thread.sleep(60L * 1000L);
        } catch (Exception e) {
            //
        }

        // 關閉調度器
        log.info("------- Shutting Down ---------------------");
        sched.shutdown(true);
        log.info("------- Shutdown Complete -----------------");
    }

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

        SimpleCronExample example = new SimpleCronExample();
        example.run();

    }

}

四、spring整合Quartz

前面用案例介紹過SimpleTrigger和CronTrigger，
下面用spring整合Quartz,分四步：

導入依賴

編寫Job

編寫spring配置文件

啟動spring容器（啟動調度器）

1. 導入maven依賴


  4.0.0
  org.ouhei.quartz
  ouhei-quartz
  1.0.0-SNAPSHOT
  
      
          org.springframework
          spring-context-support
          4.0.6.RELEASE
      
      
          org.quartz-scheduler
          quartz
          2.2.1
      
      
          org.slf4j
          slf4j-log4j12
          1.7.7
      
      
          org.springframework
          spring-tx
          4.0.6.RELEASE

2. 編寫Job

package org.ouhei.quartz;

import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.context.ApplicationContext;
import org.springframework.scheduling.quartz.QuartzJobBean;

/**
 * QuartzJobBean實現了Job接口
 * 
 */
public class MyJob extends QuartzJobBean {
    
    @Override
    protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
        System.out.println("myJob 執行了............." + context.getTrigger().getKey().getName());
        ApplicationContext applicationContext = (ApplicationContext) context.getJobDetail().getJobDataMap()
                .get("applicationContext");
        System.out.println("獲取到的Spring容器是： " + applicationContext);
        
    }

}

3. 編寫spring配置文件applicationContext-scheduler.xml

4. 啟動spring容器（啟動調度器）

package org.ouhei.quartz;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Main {
    
    public static void main(String[] args) {
        new ClassPathXmlApplicationContext("classpath:applicationContext-scheduler.xml");
    }

}

5. 添加日志文件

log4j.rootLogger=DEBUG,A1
log4j.logger.com.taotao = DEBUG
log4j.logger.org.mybatis = DEBUG

log4j.appender.A1=org.apache.log4j.ConsoleAppender
log4j.appender.A1.layout=org.apache.log4j.PatternLayout
log4j.appender.A1.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss,SSS} [%t] [%c]-[%p] %m%n

GPU云服務器云服務器 quartz?? Quartz quartz-2d quartz集群

文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。

轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/69308.html

Quartz學習之入門學習

摘要：觸發器也可以給予名稱和放置在組中，以方便地將它們調度內組織。作業可以被添加到所述調度器一次，而是具有多個觸發器注冊。調度類鏈接工作和觸發器到一起，并執行它。簡介 Quartz是一個開源的作業調度框架，可以讓計劃的程序任務一個預定義的日期和時間運行。Quartz可以用來創建簡單或復雜的日程安排執行幾十，幾百，甚至是十萬的作業數。官方鏈接，戳這里 Quartz是什么? 作業調度庫 Qua...

Pandaaa 2019-08-16 12:30 評論0 收藏0
[筆記]springboot集成Quartz簡單使用+數據庫

摘要：教程二十一使用定時任務文章目錄環境一簡單使用二配合數據庫環境一簡單使用二配合數據庫 ??Spring Boot教程(二十一)：Spring Boot使用Quartz定時任務?? 文章目錄??環境????一、簡單使用????二、配合數據庫??環境??quartz 2.3??一、簡單使用...

hikui 2021-11-23 09:51 評論0 收藏0
兩個月的Java實習結束，繼續努力

摘要：花了將近兩個星期完成了功能，期間我編寫的能力也算是有所提升了。所以能看到這篇文章的同學都是大佬如果想看更多的原創技術文章，歡迎大家關注我的微信公眾號。可能感興趣的鏈接文章的目錄導航微信公眾號端文章的目錄導航端海量精美腦圖前言只有光頭才能變強 2018年8月30日，今天我辭職了。在6月25號入職，到現在也有兩個月時間了。感受：第一天是期待的：第一次將項目拉到本地上看的時候，代碼...

snifes 2019-08-19 11:04 評論0 收藏0
Quartz學習之多作業、監聽

摘要：多作業例子在這個例子中，我們將介紹如何通過多個作業。在調度框架中，每個作業將被連接到一個唯一的觸發，并且由調度器運行它。備注說明在中，一個觸發器觸發多個作業是不可以的。第一步創建個作業，，和。多作業例子在這個例子中，我們將介紹如何通過Quartz API 多個作業。在Quartz調度框架中，每個作業將被連接到一個唯一的觸發，并且由調度器運行它。備注說明：在 Quartz 中，一個...

miracledan 2019-08-16 12:31 評論0 收藏0