Spring Quartz任务案例源码实现

admin

写在开始
6 T* K, V5 S2 j上一篇有讲到 springTask任务案例源码实现 :http://www.52itstyle.top/thread-40036-1-1.html
* {1 P1 ]6 N# N8 v
此篇，见一下spring整合Quartz实现更强大的定时任务。

任务介绍
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的状态和信息。

+ [9 @) C) F. r功能实现
这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
Quartz下载地址：http://www.quartz-scheduler.org/downloads
0 z, q& m( ^9 s, ~9 D$ [% j+ p( L
目前，最新版本为2.2.1，Maven配置如下：
; ^; m: Q: P9 U, w1 Z8 k" W: L

1. <dependency>
   $ A  Q4 T& S% P: r% l, `. n3 M* l  `
2.     <groupId>org.quartz-scheduler</groupId>
   5 i, L* A; K  A$ y  Q9 E3 N
3.     <artifactId>quartz</artifactId>
   + y! _. {2 R& |$ z
4.     <version>2.2.1</version>
   
5.   </dependency>
   . b' t. _) B, |
6.   <dependency>
   
7.     <groupId>org.quartz-scheduler</groupId>
   $ ^; _& r/ }9 R$ \
8.     <artifactId>quartz-jobs</artifactId>
   & U. m* O9 J! v) U8 _
9.     <version>2.2.1</version>
   1 w3 {$ O7 l: F6 R
10.   </dependency>

复制代码

2 H2 I* Z! f6 J9 |& r7 q
编写一个JobTest.java:

1. package quartz;
   : a) L( {! r: c+ u3 V, z) @
2. /**
   $ _3 U+ J$ Z: o* L) T! V; g
3. * 任务测试 科帮网 http://www.52itstyle.top/
   ! u) D% e$ c, x$ `3 b; s# Y
4. * 创建者        张志朋
   
5. * 创建时间        2017年4月22日
   
6. *
   # B; i( E  q1 G: H  `" M, p9 }
7. */
   & F7 ^7 ]3 \& T; s
8. public class JobTest {
   
9.         public void work(){
   1 K8 I. e% X+ n1 s* ^4 s
10.                 System.out.println("任务开始执行");
    
11.         }
    
12. }
    

复制代码

编写applicationContext-job.xml：
) N, k) e; p/ _1 ]: [

1. <?xml version="1.0" encoding="UTF-8"?>
   
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"
   ' n$ @/ @5 A# t
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
   % W- Z! x$ O9 a& y0 e. F
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.             
   2 `  G& y4 Y) I+ N, Q2 S. A  j9 m
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    
11.         <!-- 定义调用对象和调用对象的方法 -->
    ; z* |8 ?4 m1 O' V! k+ P- @
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    0 o% [. S# r; N+ q% ]
13.             <!-- 调用的类 -->
    
14.             <property name="targetObject">
    
15.                 <ref bean="testJob"/>
    , [9 `& R) i+ l' k; w& ^# j* n
16.             </property>
    
17.             <!-- 调用类中的方法 -->
    
18.             <property name="targetMethod">
    0 r) U8 s; }6 r: G8 N) x
19.                 <value>work</value>
    6 Y5 o. Z' Y7 `* N! ?
20.             </property>
    ) o) p  @% Y; z7 F
21.         </bean>  
    
22.         <!-- 调度触发器 -->
    " ^3 N4 }( W* S
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
      s6 D4 u/ B' t
24.             <property name="jobDetail">
    
25.                 <ref bean="testTask"/>
    4 G; @, [7 l/ V7 M% }6 `
26.             </property>
    2 ?- b7 k+ q6 f0 r1 v
27.             <!-- cron表达式 -->
    . Y* h  W& ?  F5 d
28.             <property name="cronExpression">
    
29.                            <value>0/5 * * * * ?</value>
    0 d6 p7 x9 ]2 F- u: E) E
30.             </property>
    , `" I" Z* V! C4 e9 t& y4 U% u
31.         </bean>
    
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    9 E; k) a3 ^( S1 ~$ ?" c
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    8 u: _6 W; _/ s! W0 e
34.             <property name="triggers">
    ( I- B( f1 U& s- @1 }+ J
35.                 <list>
    
36.                     <ref bean="jibDoTime"/>
    5 d9 I: {) V3 l9 P, a
37.                 </list>
    " \1 F5 }0 G: A# |
38.             </property>
    " j) g% D/ Y0 X7 r2 H
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    
41.       </bean>
    # x7 L* U, ^$ C0 E6 |6 c+ |9 S
42.       <!-- 配置任务并发执行线程池 -->
    ; Z9 Y) A9 ~$ ^& k! Q( p
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    : N( Z! D4 ?7 C/ m3 _
44.                 <property name="corePoolSize" value="3" />
    
45.                 <property name="maxPoolSize" value="5" />
    0 h) k% ~. j( d" ?. _1 n6 S
46.                 <property name="queueCapacity" value="10" />
    
47.           </bean>
    5 x9 g$ n' T! t7 d+ t; `1 v+ E
48. </beans>

复制代码

& K9 z6 k; m( q# U$ T6 t
web.xml 启动配置：
" ]9 R* V7 H8 y1 [* Z

1. <?xml version="1.0" encoding="UTF-8"?>
   8 ?! O; U1 d$ I2 ^, ?" [8 o0 X
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>
   0 v; g2 x& }# B/ n
4.         <context-param>
     A+ {6 j) F& T( |& }9 n( P
5.             <param-name>contextConfigLocation</param-name>
   
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   $ J/ q& O" N5 a8 B" E
7.     </context-param>
   
8.      <!-- 监听器 -->
   
9.          <listener>
   
10.                 <listener-class>
    
11.                                 org.springframework.web.context.ContextLoaderListener
    
12.                         </listener-class>
    + Z# {' e: t1 W6 @6 u* b
13.          </listener>
    
14.         <welcome-file-list>
    
15.                 <welcome-file>index.html</welcome-file>
    
16.         </welcome-file-list>
    5 r/ }0 L3 i0 m4 U
17. </web-app>
    

复制代码

6 W" N+ I( H- U9 O0 C8 v8 Y/ Y" L
运行截图：
- G9 L% @  N1 m$ w7 c
0 w; d7 b/ H: j& d% x
& ]% O1 |* O" s. @, R, n7 K9 b& C; x
Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

xjs

学习学习