Spring Quartz任务案例源码实现

admin

写在开始
上一篇有讲到 springTask任务案例源码实现 :http://www.52itstyle.top/thread-40036-1-1.html

* N# y* O6 o! m9 v) O/ N, `1 b9 o3 n此篇，见一下spring整合Quartz实现更强大的定时任务。

" c. ^7 K; V& r& Q$ H任务介绍
Quartz存储job方式就分三种，我们最常用的也是quartz默认的是RAMJobStore，RAMJobStore顾名思义就是把job的相关信息存储在内存里，如果用spring配置quartz的job信息的话，所有信息是配置在xml里，当spirng context启动的时候就把xml里的job信息装入内存。这一性质就决定了一旦JVM挂掉或者容器挂掉，内存中的job信息就随之消失，无法持久化。另外两种方式是JobStoreTX和JobStoreCMT，暂时不讨论这两者的区别，使用这两种JobStore，quartz就会通过jdbc直连或者应用服务器jndi连接数据库，读取配置在数据库里的job初始化信息，并且把job通过java序列化到数据库里，这样就使得每个job信息得到了持久化，即使在jvm或者容器挂掉的情况下，也能通过数据库感知到其他job的状态和信息。

" e8 m7 [& }; t- \- q/ i功能实现
! a. Y+ ?4 G2 ^# D- J* k这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
; `1 s/ R; B0 _" g# fQuartz下载地址：http://www.quartz-scheduler.org/downloads
# C) y$ P2 o* D' c, H! }
3 v7 I3 x/ q7 [  M3 \0 g$ [" |目前，最新版本为2.2.1，Maven配置如下：
! ~9 \( p5 O) ?* n% a  I

1. <dependency>
   
2.     <groupId>org.quartz-scheduler</groupId>
   : {# ?5 F7 l, T$ k9 B4 N( ]3 a; D
3.     <artifactId>quartz</artifactId>
   
4.     <version>2.2.1</version>
   
5.   </dependency>
   
6.   <dependency>
   
7.     <groupId>org.quartz-scheduler</groupId>
   
8.     <artifactId>quartz-jobs</artifactId>
   
9.     <version>2.2.1</version>
   
10.   </dependency>

复制代码

1 k  X& |; J% ]' {- ~
编写一个JobTest.java:
7 `% r9 w/ R* S, {$ Z

1. package quartz;
   
2. /**
   + g$ A) R: P% k6 L" p
3. * 任务测试 科帮网 http://www.52itstyle.top/
   3 M! w  b) t% `$ x' T& F
4. * 创建者        张志朋
   
5. * 创建时间        2017年4月22日
   
6. *
   
7. */
   
8. public class JobTest {
   ' y5 K# c9 s3 _  f4 d
9.         public void work(){
   
10.                 System.out.println("任务开始执行");
    
11.         }
    % V% s) b5 R: a
12. }
    8 X9 Q+ |! _3 s# j7 o

复制代码

编写applicationContext-job.xml：

1. <?xml version="1.0" encoding="UTF-8"?>
   8 {8 R4 k: G) _
2. <beans xmlns="http://www.springframework.org/schema/beans"
   
3.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
   
4.         xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
   
5.         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
   : }; H/ a, ?7 i2 c. J
6.             http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
   ( |, h; Z" A6 Q, K! }  m0 a+ [
7.             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
   
8.             http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd" default-autowire="byName" default-lazy-init="true">
   
9.             
   
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    
11.         <!-- 定义调用对象和调用对象的方法 -->
    
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    
13.             <!-- 调用的类 -->
    : r6 W# L& ?5 Q. O5 U
14.             <property name="targetObject">
    
15.                 <ref bean="testJob"/>
    0 a. O9 I4 L8 ^& P
16.             </property>
    + ]: }$ ?3 l6 J! J5 X. y
17.             <!-- 调用类中的方法 -->
    
18.             <property name="targetMethod">
    $ \( p5 r+ T9 h' v+ t
19.                 <value>work</value>
    
20.             </property>
    
21.         </bean>  
    . f' `. ]" O% t( n
22.         <!-- 调度触发器 -->
    1 ^  K% l5 r0 N7 q+ q1 `1 v
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    
24.             <property name="jobDetail">
    
25.                 <ref bean="testTask"/>
    5 T* H/ y# O6 ^
26.             </property>
    0 C9 n# p7 P- w5 f7 n! w6 q2 @
27.             <!-- cron表达式 -->
    4 ?6 R* t* p7 N8 N+ f& U9 p& Y
28.             <property name="cronExpression">
    
29.                            <value>0/5 * * * * ?</value>
    ; B2 }" r7 n2 a" p9 I8 Q& g
30.             </property>
    ) X" h- A" g, R3 k% \! p
31.         </bean>
    3 z6 e+ d7 x; O( S9 h# A9 I$ s9 n
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    9 r; }; }/ I- X' Q1 z8 U- R4 J
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    
34.             <property name="triggers">
    6 H# s! d6 H8 A/ V2 |8 u
35.                 <list>
    
36.                     <ref bean="jibDoTime"/>
    
37.                 </list>
    
38.             </property>
    : s5 o7 `9 b  s# ~, W. j8 W
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    " t/ q$ l1 Q: i
40.             <property name="startupDelay" value="5" />
    
41.       </bean>
    
42.       <!-- 配置任务并发执行线程池 -->
    
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    9 D; U7 U2 M' W# Q
44.                 <property name="corePoolSize" value="3" />
    4 h3 A9 L6 V3 V- H
45.                 <property name="maxPoolSize" value="5" />
    - \; z# K, l  C' h3 ]" W8 i
46.                 <property name="queueCapacity" value="10" />
    4 `0 w2 Q8 X; `% i/ `9 {
47.           </bean>
    
48. </beans>

复制代码

, N, c5 v5 U, S2 N1 Q$ I' uweb.xml 启动配置：

1. <?xml version="1.0" encoding="UTF-8"?>
   * _2 ?2 |+ d; |- K9 @
2. <web-app id="WebApp_ID" version="2.4" xmlns="http://java.sun.com/xml/ns/j2ee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">
   
3.         <display-name>spring_quartz</display-name>
   4 G: L3 T$ _3 Y- ^% n
4.         <context-param>
     ^3 M, O) Q9 g
5.             <param-name>contextConfigLocation</param-name>
   : ], m3 o9 `& A% t
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   
7.     </context-param>
     v, E6 r" P& N! `8 J6 \, O
8.      <!-- 监听器 -->
   " d; Y3 E( C5 n7 N' }4 U
9.          <listener>
   ) s( D% b2 N+ j9 g* ?
10.                 <listener-class>
    " D6 c- U6 B( b( C
11.                                 org.springframework.web.context.ContextLoaderListener
    
12.                         </listener-class>
    # L. Y( F) g- N5 H
13.          </listener>
    3 t' L( s$ R, c. X# j+ }# A
14.         <welcome-file-list>
    % R% r+ W' ^/ M7 {4 M5 H
15.                 <welcome-file>index.html</welcome-file>
    
16.         </welcome-file-list>
    " w. n) c- S9 x1 i$ R8 b5 M9 p
17. </web-app>
    

复制代码

- n7 j& {6 i! N" ~" p# d* ~0 ~运行截图：
4 s0 J- X! T: Z+ x! W9 Q2 h

- z, u5 e& v+ Z$ s( B
Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

点击文件名下载附件
售价: 1 IT币  [记录]  [购买]

xjs

学习学习