Spring Quartz任务案例源码实现

admin

写在开始
" r- q% E; v6 ?* g5 \! K- {: Z上一篇有讲到 springTask任务案例源码实现 :http://www.52itstyle.top/thread-40036-1-1.html

此篇，见一下spring整合Quartz实现更强大的定时任务。
2 P- ~! L! ^  `: ^: z
/ t  _5 Y! k( _' r任务介绍
0 H( j: A! [& r# d* }( D4 i, ZQuartz存储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的状态和信息。
2 U. O* T" U4 n
  l/ K4 s  ]6 x) g( ~, x& w& ~功能实现
这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
Quartz下载地址：http://www.quartz-scheduler.org/downloads
/ ~+ d# w: i8 R6 |
目前，最新版本为2.2.1，Maven配置如下：
' \, a4 D7 a( T; l* a7 Z3 k6 a

1. <dependency>
   0 [8 y7 q( v7 j4 m7 `; ?) P3 X" Y
2.     <groupId>org.quartz-scheduler</groupId>
   
3.     <artifactId>quartz</artifactId>
   
4.     <version>2.2.1</version>
   ; n& O" r2 V$ t1 [2 Y6 g
5.   </dependency>
   
6.   <dependency>
   $ p; @8 S+ S5 J3 a* i) c0 S: ]7 r
7.     <groupId>org.quartz-scheduler</groupId>
   ! O1 g0 k3 P, T* d
8.     <artifactId>quartz-jobs</artifactId>
   3 y  A( [% c" O/ Z
9.     <version>2.2.1</version>
   
10.   </dependency>

复制代码

9 s( m; k+ T+ F8 i8 F
编写一个JobTest.java:
: v. y7 [& ~. y' N) u

1. package quartz;
     I& Y: Z* U  T7 N
2. /**
   % j9 B# d- O. [& C; S* o" A# x
3. * 任务测试 科帮网 http://www.52itstyle.top/
   
4. * 创建者        张志朋
   
5. * 创建时间        2017年4月22日
   
6. *
   ' l/ i" g9 i6 ?7 W4 X
7. */
   
8. public class JobTest {
   
9.         public void work(){
   & x# {+ V! r* u# H2 k$ P" v2 c
10.                 System.out.println("任务开始执行");
    % u- P/ z0 a. W8 f. s' ]- _- F1 x8 c
11.         }
    
12. }
    

复制代码

编写applicationContext-job.xml：

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <beans xmlns="http://www.springframework.org/schema/beans"
   6 r! Z7 M  `" y) ^6 \. m
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
   / g+ F9 g2 H9 z7 F" R1 y' l8 b
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
   + h6 y. o% q; p9 o+ p  S% B
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.             
   , Y0 `, w7 Z/ u8 {/ \
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    
11.         <!-- 定义调用对象和调用对象的方法 -->
    6 n! O/ l4 M2 y" i5 @, ]
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    0 [& N- }* B3 a4 t! c, @5 d
13.             <!-- 调用的类 -->
    
14.             <property name="targetObject">
    . m' Y! ~2 v0 @% {; h) I
15.                 <ref bean="testJob"/>
    ! [" O0 q4 y/ s: \0 K2 f5 a
16.             </property>
    4 q( B! J, X8 M7 l# `+ L) S
17.             <!-- 调用类中的方法 -->
    
18.             <property name="targetMethod">
    9 q$ @1 M/ B' x" ?0 R
19.                 <value>work</value>
    
20.             </property>
    
21.         </bean>  
    
22.         <!-- 调度触发器 -->
    
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    
24.             <property name="jobDetail">
    
25.                 <ref bean="testTask"/>
    8 S3 E( }. h: ^
26.             </property>
    
27.             <!-- cron表达式 -->
    " O# P/ K; z' `1 @- ?3 ]
28.             <property name="cronExpression">
    $ f5 {! p/ S; S% f) h
29.                            <value>0/5 * * * * ?</value>
    
30.             </property>
    + {7 N8 ~5 m+ `& ^% y& M
31.         </bean>
      E5 j! G; g" m. S5 m
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    : W: J; p) w* _" v5 a( F3 O
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
      r+ v" p: D- Y: K) W' j8 C! @
34.             <property name="triggers">
    - n! _  U" E2 i4 q1 {
35.                 <list>
    
36.                     <ref bean="jibDoTime"/>
    
37.                 </list>
    
38.             </property>
    
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    
41.       </bean>
    
42.       <!-- 配置任务并发执行线程池 -->
    ' u; s0 `5 G0 {9 w8 L
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    
44.                 <property name="corePoolSize" value="3" />
    $ N; G. \/ o0 w( W" O
45.                 <property name="maxPoolSize" value="5" />
    
46.                 <property name="queueCapacity" value="10" />
    
47.           </bean>
    9 h, v3 j$ f" D* T' Z( h" K
48. </beans>

复制代码

! f8 f! c; A1 y! U8 ^7 n" A
web.xml 启动配置：

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">
   
3.         <display-name>spring_quartz</display-name>
   ( h8 b) B0 c% c) a" ^/ J2 M+ H
4.         <context-param>
   9 s0 |& h7 A/ E# P( r) g/ O8 L! e: v
5.             <param-name>contextConfigLocation</param-name>
   - a  M7 A1 E) f; R+ w/ N
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   ' K' n! o2 I. h, O8 X1 i0 {7 h
7.     </context-param>
   0 r1 r  v* B) J- F4 C. q+ s: e& x$ h, N
8.      <!-- 监听器 -->
   $ p0 e/ q/ ^* f* I' q/ ?8 x3 K6 w
9.          <listener>
   
10.                 <listener-class>
    ( g4 M2 f6 ^  N1 r- \9 N
11.                                 org.springframework.web.context.ContextLoaderListener
    . V9 Z; Q0 t" t) h" N$ A
12.                         </listener-class>
    7 r8 W6 ]7 x' s4 I
13.          </listener>
    + T: ?* q) u4 A, H3 \# _5 S6 {! M
14.         <welcome-file-list>
    
15.                 <welcome-file>index.html</welcome-file>
    3 B3 v) X0 u( Q
16.         </welcome-file-list>
    
17. </web-app>
    

复制代码

0 x$ c! l4 K) U; @, p运行截图：



- n# ]0 J3 H3 T6 r, {$ z3 ` Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

% T# W2 _4 R/ c; M. d8 M

xjs

学习学习