Spring集成quartz

　　

　　與spring集成實際就是將Jobdetail、Trigger、Scheduler交給spring管理。經常使用的集成方式每一個都有兩種

 

1.  使用Quartz配置做業(JobDetail)兩種方式:

MethodInvokingJobDetailFactoryBean
JobDetailFactoryBean

 

 

方式一:使用MethodInvokingJobDetailFactoryBean(簡單，須要注入一個執行任務的bean對象和執行的方法名稱)

1.調用firstBean的printMessage方法

2.FirstBean類(普通的java類，交給spring管理)

package cn.qlq.quartz;


import java.text.SimpleDateFormat;
import java.util.Date;

import org.springframework.stereotype.Component;

@Component("firstBean")
public class FirstBean {
    public void printMessage() {
        // 打印當前的執行時間，格式爲2017-01-01 00:00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("FirstBean Executes!" + sf.format(date));
    }
}

 

 

 方式二：使用JobDetailFactoryBean(想要更加靈活的話就是用這種方式，能夠使用jobDataMap傳遞參數)

 1.須要給做業傳遞數據，想要更加靈活的話就是用這種方式

 

2.FirstScheduleJob類（繼承QuartzJobBean，重寫executeInternal方法,使用jobDataMap注入一個SecondBean）

package cn.qlq.quartz;


import java.text.SimpleDateFormat;
import java.util.Date;

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

public class FirstScheduledJob extends QuartzJobBean{
     private SecondBean secondBean;
     public void setSecondBean(SecondBean secondBean) {
        this.secondBean = secondBean;
    }

    @Override
    protected void executeInternal(JobExecutionContext arg0)
            throws JobExecutionException {
        //能夠獲取JobDetail的標識信息
        JobKey key = arg0.getJobDetail().getKey();
        System.out.println("job key:"+"name\t"+key.getName());
        System.out.println("job key:"+"group\t"+key.getGroup());
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("FirstScheduledJob Executes!" + sf.format(date));
        this.secondBean.printMessage();        
    }
}

 3.SecondBean .java

package cn.qlq.quartz;


import java.text.SimpleDateFormat;
import java.util.Date;

import org.springframework.stereotype.Component;

@Component("secondBean")
public class SecondBean {
    public void printMessage() {
        // 打印當前的執行時間，格式爲2017-01-01 00:00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("SecondBean Executes:" + sf.format(date));
    }
}

 

2.  trigger也有兩種常見的配置方式(SimpleTrigger和CronTrigger)----須要將JobDetail注入到trigger中

1.第一種:simpletrigger

    <!-- 第一種: 距離當前時間1秒以後執行，以後每隔兩秒鐘執行一次(SimpleTrigger用法) -->
    <bean id="mySimpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
        <property name="jobDetail"  ref="simpleJobDetail"/>
        <property name="startDelay"  value="1000"/>
        <property name="repeatInterval"  value="2000"/>
    </bean>

 

 

2.第二種:cronTrigger

    <!-- 第二種:每隔5秒鐘執行一次  (CronTrigger用法)-->
    <bean id="myCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail"  ref="firstComplexJobDetail"/>
        <property name="cronExpression"  value="0/5 * * ? * *"/>
    </bean>
    <bean id="fetchDataTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail"  ref="fetchDataJobDetail"/>
        <property name="cronExpression"  value="0/5 * * ? * *"/>
    </bean>

 

 

3.Scheduler也有兩種配置方式:

1.第一種：分別注入JobDetails和Triggers

    <!-- 第一種:Schduler的建立以及指定jobDetail和trigger-->
     <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="jobDetails">
            <list>
                <ref bean="simpleJobDetail"/>
                <ref bean="firstComplexJobDetail"/>
            </list>
        </property>
        <property name="triggers">
            <list>
                <ref bean="mySimpleTrigger"/>
                <ref bean="myCronTrigger"/>
            </list>
        </property>
    </bean>

 

2.第二種:只注入triggers，實際是在第一種的基礎上取消注入jobDetails

    <!--第二種方式:只指定trigger  -->
    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="fetchDataTrigger"/>
                <!--<ref bean="fetchDataTrigger2"/> -->
            </list>
        </property>
    </bean>

 

 

 

------------------------- 例如:兩種方式與spring整合的完整例子:--------------------------------

0.pom.xml

<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>cn.qlq</groupId>
    <artifactId>SpringQuartz</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>war</packaging>
    <!-- 聲明變量，下面用相似於el表達式提取 -->
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <spring.version>4.3.6.RELEASE</spring.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>3.8.1</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version>${spring.version}</version>
        </dependency>

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

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

        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>${spring.version}</version>
        </dependency>

        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.2.3</version>
        </dependency>


        <!-- JSP和Servlet的包 -->
        <dependency>
            <groupId>javax.servlet</groupId>
            <artifactId>jsp-api</artifactId>
            <version>2.0</version>
        </dependency>
    </dependencies>

    <build>
        <!-- 配置了不少插件 -->
        <plugins>

            <!-- 編譯插件 -->
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.5.1</version>
                <configuration>
                    <source>1.7</source>
                    <target>1.7</target>
                    <encoding>UTF-8</encoding>
                </configuration>
            </plugin>

            <!-- tomcat7插件 -->
            <plugin>
                <groupId>org.apache.tomcat.maven</groupId>
                <artifactId>tomcat7-maven-plugin</artifactId>
                <version>2.2</version>
                <configuration>
                    <port>80</port>
                    <path>/springQuartz</path>
                    <uriEncoding>UTF-8</uriEncoding>
                    <server>tomcat7</server>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

 

1.applicationContext.xml (quartz配置在這裏，注意兩種定義jobDetail的方法)

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
xmlns="http://www.springframework.org/schema/beans" 
xmlns:context="http://www.springframework.org/schema/context" 
xmlns:aop="http://www.springframework.org/schema/aop" 
xmlns:tx="http://www.springframework.org/schema/tx" 
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd ">
    <!-- 掃描@Controler @Service -->
    <context:component-scan base-package="cn.qlq" />
    
    <!-- 1.JobDatail的兩種建立方式 -->
    <!--第一種: 用MethodInvokingJobDetailFactoryBean建立第一個簡單的JobDetail，執行FirstBean的 printMessage方法 -->
    <bean id="simpleJobDetail"
        class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="firstBean" />
        <property name="targetMethod" value="printMessage" />
    </bean>
    <bean id="fetchDataJobDetail"
        class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="fetchData" />
        <property name="targetMethod" value="work" />
    </bean>
    <!--第二種:用JobDetailFactoryBean建立一個jobDetail -->
    <bean id="firstComplexJobDetail"
        class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
        <!-- 指明QuartzJobBean的類全路徑 -->
        <property name="jobClass" value="cn.qlq.quartz.FirstScheduledJob" />
        <!-- 使用jobDataMap傳入數據(map的key與屬性名相同且屬性要有set方法) -->
        <property name="jobDataMap">
            <map>
                <entry key="secondBean" value-ref="secondBean" />
            </map>
        </property>
        <property name="Durability" value="true" />
    </bean>

    <!-- 2.兩種Trigger的建立-->
    <!-- 第一種: 距離當前時間1秒以後執行，以後每隔兩秒鐘執行一次(SimpleTrigger用法) -->
    <bean id="mySimpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">
        <property name="jobDetail"  ref="simpleJobDetail"/>
        <property name="startDelay"  value="1000"/>
        <property name="repeatInterval"  value="2000"/>
    </bean>
    <!-- 第二種:每隔5秒鐘執行一次  (CronTrigger用法)-->
    <bean id="myCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail"  ref="firstComplexJobDetail"/>
        <property name="cronExpression"  value="0/5 * * ? * *"/>
    </bean>
    <bean id="fetchDataTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail"  ref="fetchDataJobDetail"/>
        <property name="cronExpression"  value="0/5 * * ? * *"/>
    </bean>

    <!-- 3. 兩種 scheduler的建立方式。二選一便可-->
    <!-- 第一種:Schduler的建立以及指定jobDetail和trigger-->
     <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="jobDetails">
            <list>
                <ref bean="simpleJobDetail"/>
                <ref bean="firstComplexJobDetail"/>
            </list>
        </property>
        <property name="triggers">
            <list>
                <ref bean="mySimpleTrigger"/>
                <ref bean="myCronTrigger"/>
            </list>
        </property>
    </bean>
    <!--第二種方式:只指定trigger  -->
    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="fetchDataTrigger"/>
                <!--<ref bean="fetchDataTrigger2"/> -->
            </list>
        </property>
    </bean>
</beans>

 

 

 2.springmvc.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:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:aop="http://www.springframework.org/schema/aop"
    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 http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd ">



    <!-- 處理請求返回json字符串的中文亂碼問題 -->
    <!-- 設定消息轉換的編碼爲utf-8防止controller返回中文亂碼 -->
    <bean
        class="org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter">
        <property name="messageConverters">
            <list>
                <bean
                    class="org.springframework.http.converter.StringHttpMessageConverter">
                    <property name="supportedMediaTypes">
                        <list>
                            <value>text/html;charset=UTF-8</value>
                        </list>
                    </property>
                </bean>
            </list>
        </property>
    </bean>
    <mvc:annotation-driven/>

    <!-- 視圖解釋器 -->
    <bean
        class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="prefix" value="/" />
        <property name="suffix" value=".jsp" />
    </bean>



</beans>

 

 3.web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">
  <display-name>springmvc-mybatis</display-name>
  <welcome-file-list>
    <welcome-file>index.jsp</welcome-file>
  </welcome-file-list>
  
  <context-param>
      <param-name>contextConfigLocation</param-name>
      <param-value>classpath:applicationContext.xml</param-value>
  </context-param>
  
  <!-- Spring監聽器 -->
  <listener>
      <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>
  
  <!-- 處理POST提交亂碼問題 -->
  <filter>
      <filter-name>encoding</filter-name>
      <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
      <init-param>
          <param-name>encoding</param-name>
          <param-value>UTF-8</param-value>
      </init-param>
  </filter>
  
  <filter-mapping>
      <filter-name>encoding</filter-name>
      <url-pattern>*.action</url-pattern>
  </filter-mapping>
  
  
    <!-- 前端控制器 -->
  <servlet>
      <servlet-name>springmvc</servlet-name>
      <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
      <!-- 默認找 /WEB-INF/[servlet的名稱]-servlet.xml -->
      <init-param>
          <param-name>contextConfigLocation</param-name>
          <param-value>classpath:springmvc.xml</param-value>
      </init-param>
  </servlet>
  
  <servlet-mapping>
      <servlet-name>springmvc</servlet-name>
      <!-- 
          1. /*  攔截全部   jsp  js png .css  真的全攔截   建議不使用
          2. *.action *.do 攔截以do action 結尾的請求     確定能使用   ERP  
          3. /  攔截全部 （不包括jsp) (包含.js .png.css)  強烈建議使用     前臺 面向消費者  www.jd.com/search   /對靜態資源放行
       -->
      <url-pattern>*.action</url-pattern>
  </servlet-mapping>
  
  
</web-app>

 

 4.主要的java類:

 FirstBean.java

package cn.qlq.quartz;


import java.text.SimpleDateFormat;
import java.util.Date;

import org.springframework.stereotype.Component;

@Component("firstBean")
public class FirstBean {
    public void printMessage() {
        // 打印當前的執行時間，格式爲2017-01-01 00:00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("FirstBean Executes!" + sf.format(date));
    }
}

 

 

 

SecodeBean.java

package cn.qlq.quartz;


import java.text.SimpleDateFormat;
import java.util.Date;

import org.springframework.stereotype.Component;

@Component("secondBean")
public class SecondBean {
    public void printMessage() {
        // 打印當前的執行時間，格式爲2017-01-01 00:00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("SecondBean Executes:" + sf.format(date));
    }
}

 

 FirstScheduledJob.java

package cn.qlq.quartz;


import java.text.SimpleDateFormat;
import java.util.Date;

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

public class FirstScheduledJob extends QuartzJobBean{
     private SecondBean secondBean;
     public void setSecondBean(SecondBean secondBean) {
        this.secondBean = secondBean;
    }

    @Override
    protected void executeInternal(JobExecutionContext arg0)
            throws JobExecutionException {
        //能夠獲取JobDetail的標識信息
        JobKey key = arg0.getJobDetail().getKey();
        System.out.println("job key:"+"name\t"+key.getName());
        System.out.println("job key:"+"group\t"+key.getGroup());
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("FirstScheduledJob Executes!" + sf.format(date));
        this.secondBean.printMessage();        
    }
}

 

 

 

 結果:

FirstBean Executes!2018-04-05 16:57:18
job key:name    firstComplexJobDetail
job key:group    DEFAULT
FirstScheduledJob Executes!2018-04-05 16:57:20
SecondBean Executes:2018-04-05 16:57:20
FirstBean Executes!2018-04-05 16:57:20
FirstBean Executes!2018-04-05 16:57:22
FirstBean Executes!2018-04-05 16:57:24
job key:name    firstComplexJobDetail
job key:group    DEFAULT
FirstScheduledJob Executes!2018-04-05 16:57:25
SecondBean Executes:2018-04-05 16:57:25
FirstBean Executes!2018-04-05 16:57:26
FirstBean Executes!2018-04-05 16:57:28
job key:name    firstComplexJobDetail
job key:group    DEFAULT
FirstScheduledJob Executes!2018-04-05 16:57:30
SecondBean Executes:2018-04-05 16:57:30
FirstBean Executes!2018-04-05 16:57:30
.......

 

 總結:

 　　spring整合quartz的時候也是將quartz的三個主要元素交給spring管理，JobDatail、Trigger、Scheduler。

　　JobDetail有兩種方式，MethodInvokingJobDetailFactoryBean  和 JobDetailFactoryBean (推薦這種，更加靈活，能夠傳入利用jobDataMap參數),須要將執行任務的bean和bean的方法注入

 　　Trigger主要也是使用SimpleTrigger和CronTrigger(推薦這種，更加靈活)，須要將jobDetail傳入Trigger

　　Scheduler使用SchedulerFactoryBean工廠建立，須要傳入jobDetails集合(可選，不注入這個也能夠)和triggers集合，能夠配置多個jobDetail(可選，能夠不注入)和Trigger

 

　　　　在測試的時候咱們能夠先http接口進行測試，通常定時任務也會暴露一個http接口 進行手動的進行定時任務的操做。並且定時任務最好不要太過於頻繁的拉取數據，相似於同步拉取數據等操做最好是夜間進行操做。不過具體的也是看業務需求。。。。。。。。。。。。。。。。。。。。。。

 

 

固然也能夠用java.util.concurrent併發包中的ScheduledThreadPoolExecutor內容實現任務調度的功能，參考:http://www.javashuo.com/article/p-klhtnatt-bo.html

一個定時打印信息與定時獲取http接口信息的Git地址:  https://github.com/qiao-zhi/SpringQuartz