Spring Quartz任务案例源码实现

admin

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

% D8 h8 P1 U  Q: W此篇，见一下spring整合Quartz实现更强大的定时任务。
, M% B- [* [/ [
* M- A2 Z. }9 k1 L' l7 D- p* Y8 i任务介绍
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 O8 o2 c5 Z" T. p9 Z
$ w. g6 D- C: v) b# B功能实现
这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
Quartz下载地址：http://www.quartz-scheduler.org/downloads
  J/ W3 W% a2 g8 @- h* |' k% n
目前，最新版本为2.2.1，Maven配置如下：
; ]8 l7 U9 q- D: {& |' }  E$ s) k, [

1. <dependency>
   + s( M9 J2 f0 [! {2 Q$ G: o' K
2.     <groupId>org.quartz-scheduler</groupId>
   
3.     <artifactId>quartz</artifactId>
   
4.     <version>2.2.1</version>
   ( t1 D% [$ ?6 O
5.   </dependency>
   
6.   <dependency>
   8 n2 m1 q$ @. J( P" c
7.     <groupId>org.quartz-scheduler</groupId>
   " J8 S  Q0 e' P
8.     <artifactId>quartz-jobs</artifactId>
   * m" a6 v2 a9 }4 |, N, i1 B
9.     <version>2.2.1</version>
   
10.   </dependency>

复制代码

* g: k- `; h8 M  [' T
编写一个JobTest.java:

1. package quartz;
   
2. /**
   
3. * 任务测试 科帮网 http://www.52itstyle.top/
   
4. * 创建者        张志朋
   
5. * 创建时间        2017年4月22日
   $ f" Y# M& g) T$ o& s
6. *
   $ f( h/ P% f1 ?2 F* v' f
7. */
   
8. public class JobTest {
   " n0 b* _0 r, n% B, ^
9.         public void work(){
   : {: o# G$ Y3 f( q% B7 E5 A2 a0 E; `
10.                 System.out.println("任务开始执行");
    
11.         }
    6 f4 w0 X- \5 z; b$ q0 w
12. }
    0 j8 o3 U' ~% i/ L! K

复制代码

编写applicationContext-job.xml：
3 j# n, W) _0 \) {0 f# M% \- J& V

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <beans xmlns="http://www.springframework.org/schema/beans"
   2 f% w1 L  Y2 r
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
   8 ~, _, q' D) S/ d
6.             http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
   
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">
   4 w  }" o' e/ F
9.             
   / {/ b, o  A" E: `% i4 E6 @
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    
11.         <!-- 定义调用对象和调用对象的方法 -->
    
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    2 N: x7 y% r, ?5 M& u4 w0 }
13.             <!-- 调用的类 -->
    : @" t% m. @2 \/ v9 P0 m2 J( p7 [
14.             <property name="targetObject">
    , S7 X9 W4 m1 a+ o
15.                 <ref bean="testJob"/>
    
16.             </property>
    2 f/ u* I$ t0 U  a( ?2 Z1 c3 V
17.             <!-- 调用类中的方法 -->
    $ B% }6 Q; ?4 U8 d  N* }
18.             <property name="targetMethod">
    
19.                 <value>work</value>
    + E* x( }4 y* i- S5 U# q
20.             </property>
      C" e9 [/ M9 G7 W
21.         </bean>  
    
22.         <!-- 调度触发器 -->
    + H5 F' [7 ]7 o
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    3 @! X. U5 V& }6 G
24.             <property name="jobDetail">
    6 S+ m7 u. C% h9 l
25.                 <ref bean="testTask"/>
    ! l# P3 A/ |, m; ?! s, o0 n
26.             </property>
    3 L7 Q$ l( b3 J' i' O
27.             <!-- cron表达式 -->
    " t( A0 z0 ?- s* j8 \# w% F1 Z
28.             <property name="cronExpression">
    
29.                            <value>0/5 * * * * ?</value>
    
30.             </property>
    4 ^) m6 L4 X: N$ P
31.         </bean>
    
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    ( o8 e3 \$ d, g3 p8 h! B$ d
34.             <property name="triggers">
    ) {1 x  ]3 h4 [
35.                 <list>
    + }! }6 M0 w- V1 v/ D
36.                     <ref bean="jibDoTime"/>
    
37.                 </list>
    5 Z$ `/ k& P8 d0 e; h. t8 I
38.             </property>
    
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    
41.       </bean>
    
42.       <!-- 配置任务并发执行线程池 -->
    1 u' ]' N0 o" |8 O( y$ g& |. r2 x, s; U
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    
44.                 <property name="corePoolSize" value="3" />
    0 B$ ]' L: e+ b# T/ R
45.                 <property name="maxPoolSize" value="5" />
    7 R. D0 h/ k2 v1 o. E; ]
46.                 <property name="queueCapacity" value="10" />
    4 O3 Z( w, a- S7 C1 @4 y* c7 H
47.           </bean>
    
48. </beans>

复制代码

; j' D4 f. c( G* F) m$ m7 \
web.xml 启动配置：
$ x" l% Q7 J; Y/ W& v" j

1. <?xml version="1.0" encoding="UTF-8"?>
   
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">
   $ A: v: Y. n# T- D* f
3.         <display-name>spring_quartz</display-name>
   2 O5 |; ?6 a, ^7 u* B9 l) E
4.         <context-param>
   ; t; m$ L: X+ p8 e4 i
5.             <param-name>contextConfigLocation</param-name>
   
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   
7.     </context-param>
   1 [& c  _* t+ B. \/ W
8.      <!-- 监听器 -->
   
9.          <listener>
   2 C; r, r; b# A# l% O
10.                 <listener-class>
    6 b* K5 w4 d* O6 P
11.                                 org.springframework.web.context.ContextLoaderListener
    
12.                         </listener-class>
    ) L# O$ D( L& U0 c  H
13.          </listener>
    
14.         <welcome-file-list>
    
15.                 <welcome-file>index.html</welcome-file>
    1 J# d& ~* ]# r& |9 }
16.         </welcome-file-list>
    
17. </web-app>
    

复制代码

, [6 a4 _1 ^2 y8 R2 d' w2 D
: J1 }' u4 Z7 Z! E; N3 N  Z2 r( w运行截图：
$ W4 @8 _' a- _# d& H, P1 U
8 H1 j0 K( S& L  S7 A2 a, y5 h

Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

xjs

学习学习