2. 程式人生 > >Spring4實戰（二）-Quartz 2.2 整合

Spring4實戰（二）-Quartz 2.2 整合

阿新 • • 發佈：2019-01-06

前面一篇文章介紹了 Quartz的簡單用法，Spring提供了一些類來簡化Quartz的使用。本篇文章將介紹如何在Spring中整合Quartz。

涉及的開發工具與技術

  • Spring 4.2.4.RELEASE
  • Quartz 2.2.2
  • Maven 3
  • JDK 1.7
  • Eclipse JUNO

Project目錄結構

Eclipse Maven Project最終目錄結構如下： 
這裡寫圖片描述

整合流程

下面將詳細講解整合的每一個細節 
1、Maven 依賴配置

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.ricky.quartz</groupId>
    <artifactId>integrity</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>integrity</name>
    <url>http://maven.apache.org</url>

    <properties>
        <quartz.version>2.2.2</quartz.version>
        <springframework.version>4.2.4.RELEASE</springframework.version>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-core</artifactId>
            <version>${springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${springframework.version}</version>
        </dependency>

        <!-- Transaction dependency is required with Quartz integration -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>${springframework.version}</version>
        </dependency>

        <!-- Quartz framework -->
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>${quartz.version}</version>
        </dependency>


        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.7.13</version>
        </dependency>

        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <configuration>
                    <source>1.7</source>
                    <target>1.7</target>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58
  • 59
  • 60
  • 61
  • 62
  • 63
  • 64
  • 65
  • 66
  • 67
  • 68
  • 69
  • 70
  • 71
  • 72
  • 73
  • 74
  • 75
  • 76
  • 77
  • 78

2、配置Quartz Job 
在Spring中有兩種方法配置Quartz Job 
1） 使用 MethodInvokingJobDetailFactoryBean

<bean id="simpleJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="simpleBean" />
        <property name="targetMethod" value="printMessage" />
    </bean>
  • 1
  • 2
  • 3
  • 4

非常簡便，只需要指定一個bean以及需要被執行的方法。

2）使用 JobDetailFactoryBean

<bean name="complexJobDetail"  class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
        <property name="jobClass" value="com.ricky.quartz.integrity.complex.ComplexScheduledJob" />
        <property name="jobDataMap">
            <map>
                <entry key="complexBean" value-ref="complexBean" />
            </map>
        </property>
        <property name="durability" value="true" />
    </bean>
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9

其中，jobClass需要指定一個 QuartzJobBean的子類（extends QuartzJobBean），jobDataMap 可以向jobClass指定的Job bean 傳引數。 
下面是jobClass 的指定的 QuartzJobBean 實現類

package com.ricky.quartz.integrity.complex;

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

public class ComplexScheduledJob extends QuartzJobBean {

    private ComplexBean complexBean;

    @Override
    protected void executeInternal(JobExecutionContext context)
            throws JobExecutionException {

        complexBean.printMessage();
    }

    public void setComplexBean(ComplexBean complexBean) {
        this.complexBean = complexBean;
    }

}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23

3、配置Quartz Trigger 
Trigger是來定義scheduler何時執行你的job，有兩種配置方式 
1）Simple Trigger , 使用 SimpleTriggerFactoryBean配置

<bean id="simpleTrigger"  class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
        <property name="jobDetail" ref="simpleJobDetail" />
        <property name="startDelay" value="1000" />
        <property name="repeatInterval" value="2000" />
        <property name="repeatCount" value="5" />
    </bean>
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6

2）Cron Trigger , 使用 CronTriggerFactoryBean配置

<bean id="cronTrigger"  class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail" ref="complexJobDetail" />
        <property name="cronExpression" value="0/5 * * * * ?" />
    </bean>
  • 1
  • 2
  • 3
  • 4

4、配置 SchedulerFactoryBean

<bean  class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="jobDetails">
            <list>
                <ref bean="simpleJobDetail" />
                <ref bean="complexJobDetail" />
            </list>
        </property>

        <property name="triggers">
            <list>
                <ref bean="simpleTrigger" />
                <ref bean="cronTrigger" />
            </list>
        </property>

        <property name="configLocation" value="classpath:quartz.properties" />  
    </bean>
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17

quartz-context.xml 完整配置如下：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd">

    <context:component-scan base-package="com.ricky.quartz.integrity" />


    <bean id="simpleJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="simpleBean" />
        <property name="targetMethod" value="printMessage" />
    </bean>

    <bean name="complexJobDetail"  class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
        <property name="jobClass" value="com.ricky.quartz.integrity.complex.ComplexScheduledJob" />
        <property name="jobDataMap">
            <map>
                <entry key="complexBean" value-ref="complexBean" />
            </map>
        </property>
        <property name="durability" value="true" />
    </bean>


    <bean id="simpleTrigger"  class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
        <property name="jobDetail" ref="simpleJobDetail" />
        <property name="startDelay" value="1000" />
        <property name="repeatInterval" value="2000" />
        <property name="repeatCount" value="5" />
    </bean>


    <bean id="cronTrigger"  class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail" ref="complexJobDetail" />
        <property name="cronExpression" value="0/5 * * * * ?" />
    </bean>


    <bean  class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="jobDetails">
            <list>
                <ref bean="simpleJobDetail" />
                <ref bean="complexJobDetail" />
            </list>
        </property>

        <property name="triggers">
            <list>
                <ref bean="simpleTrigger" />
                <ref bean="cronTrigger" />
            </list>
        </property>

        <property name="configLocation" value="classpath:quartz.properties" />  
    </bean>

</beans>
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17
  • 18
  • 19
  • 20
  • 21
  • 22
  • 23
  • 24
  • 25
  • 26
  • 27
  • 28
  • 29
  • 30
  • 31
  • 32
  • 33
  • 34
  • 35
  • 36
  • 37
  • 38
  • 39
  • 40
  • 41
  • 42
  • 43
  • 44
  • 45
  • 46
  • 47
  • 48
  • 49
  • 50
  • 51
  • 52
  • 53
  • 54
  • 55
  • 56
  • 57
  • 58

5、simple POJO’s Task Beans

com.ricky.quartz.integrity.simple.SimpleBean

package com.ricky.quartz.integrity.simple;

import java.util.Date;
import org.springframework.stereotype.Component;

@Component
public class SimpleBean {

    public void printMessage() {
        System.out.println("simple task invoked by using SimpleTriggerFactoryBean"+new Date());
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13

com.ricky.quartz.integrity.complex.ComplexBean

package com.ricky.quartz.integrity.complex;

import java.util.Date;
import org.springframework.stereotype.Component;

@Component
public class ComplexBean {

    public void printMessage(){

        System.out.println("complex task invoked by using CronTriggerFactoryBean"+new Date());
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14

6、啟動Spring容器

package com.ricky.quartz.integrity;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

/**
 * Spring Quartz integration example
 *
 */
public class App {

    public static void main(String[] args) {

        ApplicationContext ctx = new ClassPathXmlApplicationContext("quartz-context.xml");
    }
}
  • 1
  • 2
  • 3
  • 4
  • 5
  • 6
  • 7
  • 8
  • 9
  • 10
  • 11
  • 12
  • 13
  • 14
  • 15
  • 16
  • 17

執行結果如下： 
complex task invoked by using CronTriggerFactoryBeanTue Jan 05 19:32:05 CST 2016 
simple task invoked by using SimpleTriggerFactoryBeanTue Jan 05 19:32:05 CST 2016 
simple task invoked by using SimpleTriggerFactoryBeanTue Jan 05 19:32:07 CST 2016 
simple task invoked by using SimpleTriggerFactoryBeanTue Jan 05 19:32:09 CST 2016 
complex task invoked by using CronTriggerFactoryBeanTue Jan 05 19:32:10 CST 2016 
simple task invoked by using SimpleTriggerFactoryBeanTue Jan 05 19:32:11 CST 2016 
simple task invoked by using SimpleTriggerFactoryBeanTue Jan 05 19:32:13 CST 2016 
complex task invoked by using CronTriggerFactoryBeanTue Jan 05 19:32:15 CST 2016 
simple task invoked by using SimpleTriggerFactoryBeanTue Jan 05 19:32:15 CST 2016 
complex task invoked by using CronTriggerFactoryBeanTue Jan 05 19:32:20 CST 2016

相關推薦

Spring4實戰（二）-Quartz 2.2 整合

前面一篇文章介紹了 Quartz的簡單用法，Spring提供了一些類來簡化Quartz的使用。本篇文章將介紹如何在Spring中整合Quartz。 涉及的開發工具與技術 Spring 4.2.4.RELEASE Quartz 2.2.2 Maven 3 JDK 1.

Redis實戰（二）CentOS 7上搭建redis-3.0.2

str 進程 ps 禁用 安裝redis 結果 redis 啟動服務 pro bin 1.安裝redis wget http://download.redis.io/releases/redis-3.0.2.tar.gz tar zxvf redis-3.0.2.tar

Extjs 6.2 實戰 （二）MVVM模式介紹

MVVM是模型（Model）、檢視（View）和檢視模型（ViewModel）的縮寫，是一種軟體設計模式。MVVM主要作用就是簡化事件驅動變成的使用者介面開發。它把軟體系統劃分為模型、檢視和檢視模型三個基本部分2.1 Extjs中的MVVM模式 Extjs中的MVVM模式將應

linux系統程序安裝（二）yum工具2-yum源管理

內容 centos 備份 hang clean 原生 yum 聯網 系統 繼續我們的yum工具應用之旅，yum工具之所以方便就是因為有方便的在線雲庫，實際工作中我們可能沒辦法鏈接互聯網，或者我們想安裝的程序原生源那麽我們能不能用其他方式應用方便的yum源呢？ 一、使用光盤

（二）Kafka0.8.2官方文檔中文版系列-API

black mat color cte 需要 self 兼容 lec 取數 2. API 我們正在為Kafka重寫JVM客戶端。在Kafka0.8.2中，包含一個新重寫的Java producer。下一個版本將包含一個等效的Java consumer。這些新客戶端旨在取

Spring原始碼解析（二）——元件註冊2

    import com.ken.service.BookService; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.

Spring Boot Actuator詳解與深入應用（二）：Actuator 2.x

《Spring Boot Actuator詳解與深入應用》預計包括三篇，第一篇重點講Spring Boot Actuator 1.x的應用與定製端點；第二篇將會對比Spring Boot Actuator 2.x 與1.x的區別，以及應用和定製2.x的端點；第三篇將會介紹Actuator metric指

設計模式（二）策略模式2

　看了武哥的策略模式，感覺真是易懂哈    策略模式在實際中使用的還是挺多的，先來看一個場景：某個市場人員接到單兒後的報價策略，保價策略很複雜，但是可以簡單做如下歸類： 新客戶小批量報價  新客戶大批量報價  老客戶小批量報價  老客戶大批量報價 　　具體選用哪個報價策

構建機器學習專案（二）- ML strategy(2)

歡迎使用Markdown編輯器寫部落格 本Markdown編輯器使用StackEdit修改而來，用它寫部落格，將會帶來全新的體驗哦： Markdown和擴充套件Markdown簡潔的語法 程式碼塊高亮 圖片連結和圖片上傳 LaTex數學公式 UML序列

Device Tree（二）詳解-2

概念 Linux核心從3.x開始引入裝置樹的概念，用於實現驅動程式碼與裝置資訊相分離。在裝置樹出現以前，所有關於裝置的具體資訊都要寫在驅動裡，一旦外圍裝置變化，驅動程式碼就要重寫。引入了裝置樹之後，驅動程式碼只負責處理驅動的邏輯，而關於裝置的具體資訊存放到裝置樹檔案中，這樣，如果只是硬體介面資訊

QT、VS常見bug及解決辦法（二）——VS錯誤 2 error LNK1120: 1 個無法解析的外部命令

這個問題的原因是有標頭檔案，但是找不到實現。 有兩個原因： 1.只包含了標頭檔案，只有這個函式的宣告，沒有包含這個函式的實現(實現一般放在cpp檔案中的)。所以只能通過編譯，連線不成功。 2.另一個原因是函式的宣告和實現都放在標頭檔案中了，一般要把宣告放標頭檔案中，實現放在c

我眼中的 Nginx（二）：HTTP/2 dynamic table size update

服務 bsp lin revert code 負責 ont mat expect 張超：又拍雲系統開發高級工程師，負責又拍雲 CDN 平臺相關組件的更新及維護。Github ID: tokers，活躍於 OpenResty 社區和 Nginx 郵件列表等開源社區，專註於

J2SE核心開發實戰（二）——字符串與包裝類

刪除 i++ cnblogs amp 分支語句 核心 最大 用途 else 字符串與包裝類 一、實驗簡單介紹 在本章。我們將學習一些用於處理字符串的API以及包裝類的相關知識。 本章知識點 字符串API 包裝類及其應用 二、認識字符

Spring Boot 揭秘與實戰（二） 數據存儲篇 - 聲明式事務管理

public rollback long tar jpa oid config 新的 autowire 文章目錄 1. 聲明式事務 2. Spring Boot默認集成事務 3. 實戰演練4. 源代碼 3.1. 實體對象 3.2. DAO 相關 3.3. Service

Wicket實戰（二）hello world

clas gpo 研究 eth 抽象 http 配置文件 href ont 上次的博文Wicket實戰（一）概述中給大家簡介了一下關於Wicket的概念性內容，今天我們完畢第一個Wicket實例-Hello

Docker從入門到實戰（二）

Docker 虛擬化 一步一步走，寫小白都能看懂的文章，將持續更新中，敬請期待！Docker從入門到實戰（二）一：什麽是dockerDocker是一個開源的應用容器引擎，開發者可以打包他們的應用以及依賴包到一個可移植的容器中，然後發布到主流的Linux、macOS、Windows機器上，實現虛擬化。D

Python 爬蟲實戰（二）：使用 requests-html

分享 -html 調用 交流 html 技術 python-re find 自己的 Python 爬蟲實戰（一）：使用 requests 和 BeautifulSoup，我們使用了 requests 做網絡請求，拿到網頁數據再用 BeautifulSoup 解析，就在前不久

Android項目實戰（二）：安卓應用程序退出的三種方法

eat 延遲 用戶 pre html port length tst 二次 原文:Android項目實戰（二）：安卓應用程序退出的三種方法現在的APP退出的時候都不是讓用戶點擊了“後退鍵”就退出。防止用戶點錯了後退鍵而造成的用戶體檢不好。 一年前搞

Laravel 完整實戰（二） —— 用戶登錄註冊

laravel 實戰 參考網絡上的項目：仿新浪微博簡單功能： 用戶的註冊登錄 用戶個人信息的更改 使用管理員權限刪除用戶 發布微博 關註用戶 查看關註用戶的微博動態 刪除無用頁面 welcome.blade.php 視圖文件 rm re

docker實戰（二）之redis的使用

系統版本 Redis的使用 redis啟動 font height https eight img ont docker中安裝redis的步驟比較簡單，Linux系統版本centos7.4 1.官方倉庫https://hub.docker.com/r/library/red