Spring Quartz任务案例源码实现

admin

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

此篇，见一下spring整合Quartz实现更强大的定时任务。
1 Z8 W0 Y, T2 q" x
7 x: n9 Y* m3 O任务介绍
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的状态和信息。
5 J1 {4 T' ]8 J
功能实现
这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
* E/ i' T: |" y& x$ xQuartz下载地址：http://www.quartz-scheduler.org/downloads

目前，最新版本为2.2.1，Maven配置如下：
2 g7 w" N! @0 [2 `6 V# ^

1. <dependency>
   5 B; K/ B$ g3 R( J
2.     <groupId>org.quartz-scheduler</groupId>
   + M8 l, G4 y; j3 u
3.     <artifactId>quartz</artifactId>
   ) P6 r% |$ _4 G( h8 L% I; F0 `8 X
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>
   * p: g" L2 U: T2 D$ l- V( l
10.   </dependency>

复制代码

5 k( F7 {, t+ `! P9 y
编写一个JobTest.java:

1. package quartz;
   ; [9 j9 {1 {$ D. e) W" v6 Q
2. /**
   4 [- R! o) ^- N; b/ W! s) r, t8 u
3. * 任务测试 科帮网 http://www.52itstyle.top/
   
4. * 创建者        张志朋
   1 h/ \4 P+ m: E; t; B
5. * 创建时间        2017年4月22日
   . X5 B, _4 N2 a4 y* z
6. *
   
7. */
   . L' O/ f6 ^' C. I3 T
8. public class JobTest {
   8 O- M! R4 @  z% A. a% g2 U
9.         public void work(){
   
10.                 System.out.println("任务开始执行");
    
11.         }
    ( L5 `& Q% e* a. x" K! e/ \7 u
12. }
    

复制代码

编写applicationContext-job.xml：

1. <?xml version="1.0" encoding="UTF-8"?>
   5 [& A# H5 W7 `, Y1 L' \9 a
2. <beans xmlns="http://www.springframework.org/schema/beans"
   # T- t6 C; i0 Y9 u1 x
3.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
   , u7 X3 M# u, [' I  J" ?. h
4.         xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
   9 y5 Z; n% Z; T5 h; x' m
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
   
7.             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
   + @* @& n1 w! ^
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>     
    & {! d6 ]/ N  [6 H  J2 q3 P/ \
11.         <!-- 定义调用对象和调用对象的方法 -->
    $ [% W. x* U- ?' i7 {
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    $ e" p8 n8 v! r) y6 e
13.             <!-- 调用的类 -->
    ' E3 j. B4 D8 b
14.             <property name="targetObject">
    
15.                 <ref bean="testJob"/>
    
16.             </property>
    , t6 ^6 l8 w1 V. O
17.             <!-- 调用类中的方法 -->
    * Q; [" B* M! h7 r
18.             <property name="targetMethod">
    0 e6 B. H( ^! I6 h, g
19.                 <value>work</value>
    
20.             </property>
    
21.         </bean>  
    4 f& l& w' X+ C0 ~! l6 w3 l' |! F5 S
22.         <!-- 调度触发器 -->
    4 D2 i2 K2 V- c7 N. K
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    / G" A6 S% e' B9 i
24.             <property name="jobDetail">
    + {$ g* X: f! ^) r( {0 ]. i+ s
25.                 <ref bean="testTask"/>
    3 v9 a* c0 U+ d+ r. {6 `$ u
26.             </property>
    
27.             <!-- cron表达式 -->
    
28.             <property name="cronExpression">
    
29.                            <value>0/5 * * * * ?</value>
    1 ^. y& r( @8 U8 g0 G
30.             </property>
    
31.         </bean>
    
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    9 J: [+ F( a& H* u: q! D
34.             <property name="triggers">
    - {" U% ~1 d1 e# }+ F
35.                 <list>
    # a: A/ V8 F. T* @
36.                     <ref bean="jibDoTime"/>
    % F# p0 G, C9 N
37.                 </list>
    % \" T- C/ w3 B/ q0 _
38.             </property>
    9 m6 ?3 t( A6 s, P& ~
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    & h* v# G# I& h! e7 ?
40.             <property name="startupDelay" value="5" />
    
41.       </bean>
    2 O- a6 o/ {/ F. B( o
42.       <!-- 配置任务并发执行线程池 -->
    
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    
44.                 <property name="corePoolSize" value="3" />
    
45.                 <property name="maxPoolSize" value="5" />
    - E( v6 N; y" _; H
46.                 <property name="queueCapacity" value="10" />
    2 f( ?% ]2 _5 e7 a2 r+ m
47.           </bean>
    : W9 [# a& x& e) F7 f) o; a  A
48. </beans>

复制代码

+ o4 [) ~, Z# e' O1 V5 m
" K$ t  r+ o( f- o" D+ m0 B9 ^web.xml 启动配置：

1. <?xml version="1.0" encoding="UTF-8"?>
   " ~( r3 _2 _, I
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>
   # Q" `" b: U1 V" N
5.             <param-name>contextConfigLocation</param-name>
   0 [5 s/ L; C" F3 C
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   5 C: h: {; ~# Q' P
7.     </context-param>
   ( M9 G  t" ~- P% w
8.      <!-- 监听器 -->
   9 ?$ |1 ^7 g1 L
9.          <listener>
   ; d6 A- X  F; z* b
10.                 <listener-class>
    
11.                                 org.springframework.web.context.ContextLoaderListener
    0 `1 t% k# W) v, X* G8 X
12.                         </listener-class>
    
13.          </listener>
    $ N6 u4 }2 C0 Y1 E7 i/ p9 h7 l
14.         <welcome-file-list>
    ' U( E3 S8 P8 q; V0 C7 t
15.                 <welcome-file>index.html</welcome-file>
    9 x+ a9 O: x/ e0 A( J. k
16.         </welcome-file-list>
    
17. </web-app>
    4 }2 B6 N5 P, T" Y

复制代码

- e! Y2 T) C1 L* W3 g4 ~3 ^4 q运行截图：



! J0 M. c, L1 H; q; V2 W Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

! X% H4 a8 i1 m5 m& X

xjs

学习学习
' h! _( t1 ?  ^# C0 N2 p) T