Spring Quartz任务案例源码实现

admin

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

此篇，见一下spring整合Quartz实现更强大的定时任务。
6 _1 F% k) R$ [- Q% w2 k
任务介绍
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的状态和信息。

! v$ X5 t7 o" c功能实现
4 j! _# ?; i) f8 |' b这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
Quartz下载地址：http://www.quartz-scheduler.org/downloads
: }/ A3 C. L1 i' r. _
目前，最新版本为2.2.1，Maven配置如下：
( q- [$ w- V0 r. b

1. <dependency>
   7 X2 V8 T+ ?7 O# q/ i' Z+ p" N: J
2.     <groupId>org.quartz-scheduler</groupId>
   
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>
   3 o* ~9 L8 Z* C+ H) [& k' i5 \. L; m; f
9.     <version>2.2.1</version>
   ' ^6 O, Q$ I1 H) G& D
10.   </dependency>

复制代码

& D4 K3 t9 u1 x9 ]5 r) v1 n' ~
* C4 u9 d5 D4 V% x/ q编写一个JobTest.java:
; o4 s6 \- B8 O2 k+ z

1. package quartz;
   5 ^: r! }, L: U; {; B: H
2. /**
   
3. * 任务测试 科帮网 http://www.52itstyle.top/
   
4. * 创建者        张志朋
   # ?- F1 s! x, M! H! X/ |9 @
5. * 创建时间        2017年4月22日
   9 Z. a' P5 [8 X: |: N/ Q) G
6. *
   " z0 e  r' R; M# \9 f9 y
7. */
   
8. public class JobTest {
   
9.         public void work(){
   ! }7 l& r0 o7 E# L$ c1 `; f
10.                 System.out.println("任务开始执行");
    
11.         }
    8 h% a# ?& ?- x! {1 j9 X5 Q
12. }
    

复制代码

编写applicationContext-job.xml：

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <beans xmlns="http://www.springframework.org/schema/beans"
   & {1 J# U2 a6 e% F% e0 U( e: H
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
   
6.             http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
   + m" _! J, X7 Q: f, c
7.             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
   3 L7 @; ~+ q4 Q: y% t0 o6 H+ j
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">
   $ V! a* w2 A* b- ]! d
9.             
   : B2 ~/ c( f6 }2 o
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    * C1 g( j6 n- C& d, w4 h
11.         <!-- 定义调用对象和调用对象的方法 -->
    % k( H/ {1 [0 {- H
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
      b8 k- F$ W; Z5 c4 j) E$ L: J& g
13.             <!-- 调用的类 -->
    
14.             <property name="targetObject">
    * ~; K0 [3 j+ V2 h
15.                 <ref bean="testJob"/>
    ! o! I( O0 p6 A3 C
16.             </property>
    # l' \$ c+ v7 D/ d4 K+ E" ]0 d' R
17.             <!-- 调用类中的方法 -->
    
18.             <property name="targetMethod">
    ) p: |9 Z7 y4 {$ @
19.                 <value>work</value>
    
20.             </property>
    ( s0 @* j1 W" ]  ^! D
21.         </bean>  
    
22.         <!-- 调度触发器 -->
    
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    
24.             <property name="jobDetail">
    
25.                 <ref bean="testTask"/>
    5 n! `+ f3 m* s9 R$ K1 c" j; u
26.             </property>
    ' ?& ]6 E* E, ]: o/ O% U. |+ C3 t
27.             <!-- cron表达式 -->
    
28.             <property name="cronExpression">
    1 M9 |& x/ \; M$ D" k3 ^% U
29.                            <value>0/5 * * * * ?</value>
    
30.             </property>
    
31.         </bean>
    
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    ! ?* a& U( M' b+ h7 f. I+ D. c
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    - x' ^# ]& @- R0 s6 K+ z% T& G
34.             <property name="triggers">
    , G1 F7 F( I6 e6 G' F1 o( a. e
35.                 <list>
    , h; {2 A4 i, L2 y2 j0 c
36.                     <ref bean="jibDoTime"/>
    
37.                 </list>
    ; t8 h  a: ]6 n
38.             </property>
    , X4 Y' N) `1 o1 W4 a
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    % L, t7 j- {1 B1 Q
40.             <property name="startupDelay" value="5" />
    
41.       </bean>
    
42.       <!-- 配置任务并发执行线程池 -->
    
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    
44.                 <property name="corePoolSize" value="3" />
    
45.                 <property name="maxPoolSize" value="5" />
    1 V+ r" z* e5 Z: l1 L/ ]
46.                 <property name="queueCapacity" value="10" />
    * h) ^1 m% F' o1 y4 F* E
47.           </bean>
    9 f. `5 ]9 P: L; b+ }+ R" @1 S2 ]
48. </beans>

复制代码

web.xml 启动配置：

1. <?xml version="1.0" encoding="UTF-8"?>
   * _1 T* _: f: H! a6 a" `! C( }
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.         <context-param>
   
5.             <param-name>contextConfigLocation</param-name>
   ! U, x# P! G( L1 y( o, f
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   
7.     </context-param>
   
8.      <!-- 监听器 -->
   ! H9 N1 ~* ?2 x5 n
9.          <listener>
   
10.                 <listener-class>
    
11.                                 org.springframework.web.context.ContextLoaderListener
    + d4 F  c) W; I( K- Z* X
12.                         </listener-class>
    
13.          </listener>
    6 q' j+ L& X  y6 _+ I) }( ~; e
14.         <welcome-file-list>
    
15.                 <welcome-file>index.html</welcome-file>
    
16.         </welcome-file-list>
    
17. </web-app>
    - T# n4 E# I& j& k7 |5 L

复制代码

' r, h& a& k/ C9 G4 \
运行截图：
8 h9 d: P8 G8 g+ Q7 V" x6 y


; l: j4 G& A' Y: w# I$ |+ F Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

xjs

学习学习
2 f( P( q! I7 _% B2 e7 x0 p