1. 程式人生 > >Spring和Quartz的整合

Spring和Quartz的整合

一 點睛

1 使用Quartz配置作業,兩種方式

第一種:MethodInvokingJobDetailFactoryBean

呼叫myBean的printMessage方法

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

MyBean類如下:

@Component("myBean")
public class MyBean {
    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("MyBean Executes!" + sf.format(date));
    }
}

第二種:JobDetailFactoryBean

需要給作業傳遞資料,想更加靈活的話就使用這種方式

<bean id="firstComplexJobDetail"
    class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass"
        value="com.imooc.springquartz.quartz.FirstScheduledJob" />
    <property name="jobDataMap">
        <map>
            <entry key="anotherBean" value-ref="anotherBean" />
        </map>
    </property>
    <property name="Durability" value="true"/>                
</bean>

FirstScheduledJob類為:

public class FirstScheduledJob extends QuartzJobBean{
     private AnotherBean anotherBean;
     
     public void setAnotherBean(AnotherBean anotherBean){
         this.anotherBean = anotherBean;
     }

    @Override
    protected void executeInternal(JobExecutionContext arg0)
            throws JobExecutionException {
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("FirstScheduledJob Executes!" + sf.format(date));
        this.anotherBean.printAnotherMessage();        
    }
}

AnotherBean類為:

@Component("anotherBean")
public class AnotherBean {
    public void printAnotherMessage() {
        System.out.println("AnotherMessage");
    }
}

二 實戰

1 配置檔案dispatcher-servlet.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"
       xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:p="http://www.springframework.org/schema/p"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/mvc
http://www.springframework.org/schema/mvc/spring-mvc.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd"
       default-lazy-init="true">
       <!-- 通過mvc:resources設定靜態資源,這樣servlet就會處理這些靜態資源,而不通過控制器 -->
       <!-- 設定不過濾內容,比如:css,jquery,img 等資原始檔 -->
       <mvc:resources location="/*.html" mapping="/**.html" />
       <mvc:resources location="/css/*" mapping="/css/**" />
       <mvc:resources location="/js/*" mapping="/js/**" />
       <mvc:resources location="/images/*" mapping="/images/**" />
       <!-- 設定訊息轉換的編碼為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 />
       <!-- 預設掃描的包路徑 -->
       <context:component-scan base-package="com.imooc.springquartz" />
       <!-- mvc:view-controller可以在不需要Controller處理request的情況,轉向到設定的View -->
       <!-- 像下面這樣設定,如果請求為/,則不通過controller,而直接解析為/index.jsp -->
       <mvc:view-controller path="/" view-name="index" />
       <bean class="org.springframework.web.servlet.view.UrlBasedViewResolver">
              <property name="viewClass"
                     value="org.springframework.web.servlet.view.JstlView"></property>
              <!-- 配置jsp路徑字首 -->
              <property name="prefix" value="/"></property>
              <!-- 配置URl字尾 -->
              <property name="suffix" value=".jsp"></property>
       </bean>
       <bean id="simpleJobDetail"
              class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
              <property name="targetObject" ref="myBean" />
              <property name="targetMethod" value="printMessage" />
       </bean>
       <bean id="firstComplexJobDetail"
              class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
              <property name="jobClass"
                     value="com.imooc.springquartz.quartz.FirstScheduledJob" />
              <property name="jobDataMap">
                     <map>
                           <entry key="anotherBean" value-ref="anotherBean" />
                     </map>
              </property>
              <property name="Durability" value="true"/>                           
       </bean>
       <!-- 距離當前時間1秒之後執行,之後每隔兩秒鐘執行一次 -->
       <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秒鐘執行一次 -->
       <bean id="myCronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
           <property name="jobDetail"  ref="firstComplexJobDetail"/>
           <property name="cronExpression"  value="0/5 * * ? * *"/>
       </bean>
       
       <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>
</beans> 

2 MyBean

package com.imooc.springquartz.quartz;

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

import org.springframework.stereotype.Component;

@Component("myBean")
public class MyBean {
    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("MyBean Executes!" + sf.format(date));
    }
}

3 FirstScheduledJob

package com.imooc.springquartz.quartz;

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

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

public class FirstScheduledJob extends QuartzJobBean{
     private AnotherBean anotherBean;
     
     public void setAnotherBean(AnotherBean anotherBean){
         this.anotherBean = anotherBean;
     }

    @Override
    protected void executeInternal(JobExecutionContext arg0)
            throws JobExecutionException {
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("FirstScheduledJob Executes!" + sf.format(date));
        this.anotherBean.printAnotherMessage();        
    }
}

4 AnotherBean

package com.imooc.springquartz.quartz;

import org.springframework.stereotype.Component;

@Component("anotherBean")
public class AnotherBean {
    public void printAnotherMessage() {
        System.out.println("AnotherMessage");
    }
}

三 測試結果

MyBean Executes!2018-11-17 16:30:38

FirstScheduledJob Executes!2018-11-17 16:30:40

AnotherMessage

MyBean Executes!2018-11-17 16:30:40

MyBean Executes!2018-11-17 16:30:42

MyBean Executes!2018-11-17 16:30:44

FirstScheduledJob Executes!2018-11-17 16:30:45

AnotherMessage

MyBean Executes!2018-11-17 16:30:46

MyBean Executes!2018-11-17 16:30:48

FirstScheduledJob Executes!2018-11-17 16:30:50

AnotherMessage

MyBean Executes!2018-11-17 16:30:50