Spring Quartz任务案例源码实现

admin

写在开始
上一篇有讲到 springTask任务案例源码实现 :http://www.52itstyle.top/thread-40036-1-1.html
3 r' o( A% P3 e9 b1 R
此篇，见一下spring整合Quartz实现更强大的定时任务。
) L" T/ X& M% T# J
任务介绍
" Z5 w4 \0 k( O- N4 DQuartz存储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的状态和信息。

8 f1 J+ [4 q9 |; s6 ]) y8 G# @功能实现
4 B! ?" j. u: X3 @" N1 Q这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
Quartz下载地址：http://www.quartz-scheduler.org/downloads

; Z1 \  G  A  D) D2 M目前，最新版本为2.2.1，Maven配置如下：
% H- d: [2 D$ u0 C7 r5 F/ l

1. <dependency>
   * E% f# ^& K8 O; ]
2.     <groupId>org.quartz-scheduler</groupId>
   4 Y9 Q- p3 J! P5 I4 T# D
3.     <artifactId>quartz</artifactId>
   , e: u  v0 q' |; a/ w- f' S* n
4.     <version>2.2.1</version>
   3 ^/ ^4 a5 z! `7 n( v
5.   </dependency>
   
6.   <dependency>
   % e# \: ^) |; Z* ]
7.     <groupId>org.quartz-scheduler</groupId>
   
8.     <artifactId>quartz-jobs</artifactId>
   
9.     <version>2.2.1</version>
   7 ?% O5 G5 w' Q: A2 r9 p8 r( N
10.   </dependency>

复制代码

5 l$ J! k- z/ k) e
6 ]5 f& j+ q6 G* H$ ?编写一个JobTest.java:
2 a4 n1 ^9 s0 J+ o

1. package quartz;
   : }, B' w2 a  ?9 g
2. /**
   + z7 }8 ~2 A" W* {0 w/ G9 M2 U/ D7 M
3. * 任务测试 科帮网 http://www.52itstyle.top/
   6 ~5 r9 {5 O1 E# F" x4 j1 B8 s+ Z( X- ?
4. * 创建者        张志朋
   # Z! d7 l. a% a+ u* L" c
5. * 创建时间        2017年4月22日
   0 v: i' K! a6 D  l# F( k
6. *
   
7. */
   ( o! ]/ Q2 ?1 l2 `' n
8. public class JobTest {
   8 k6 w3 s9 a$ u- [% U' W, w
9.         public void work(){
   , f3 F( _* ?5 _* P0 l7 l
10.                 System.out.println("任务开始执行");
    4 a# L. e; S& v* n3 w, ?$ y$ F
11.         }
    : M* H' w$ `3 E) s
12. }
    9 K  S% W+ h6 a% }4 G3 J0 E

复制代码

编写applicationContext-job.xml：

1. <?xml version="1.0" encoding="UTF-8"?>
   * X, h+ O" }8 x* t4 J  R
2. <beans xmlns="http://www.springframework.org/schema/beans"
   : V& {% P0 A; s3 v
3.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
   3 p4 Y4 C: X3 A: j1 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
   0 w  L( U, R$ a; v! g( t6 Q
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">
   2 T- y, u2 F6 \2 [2 e! a
9.             
   . U( o# {1 E8 u. f; s
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    
11.         <!-- 定义调用对象和调用对象的方法 -->
    , C% w. m" d- }3 d% Q1 _; @) X
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    
13.             <!-- 调用的类 -->
    : W8 P8 l9 |/ e6 B
14.             <property name="targetObject">
    
15.                 <ref bean="testJob"/>
    
16.             </property>
    4 G6 x" T* v3 B4 P8 q
17.             <!-- 调用类中的方法 -->
    ! T, T  A9 r3 r7 g
18.             <property name="targetMethod">
    
19.                 <value>work</value>
    & @  c7 f' z+ h5 O9 X
20.             </property>
    $ h7 T( a2 H, I7 R
21.         </bean>  
    
22.         <!-- 调度触发器 -->
    
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    7 K9 v' C, l1 @( q: X
24.             <property name="jobDetail">
    0 E. c. @- m  v/ S- H2 k2 c
25.                 <ref bean="testTask"/>
    
26.             </property>
    - @- J- |0 o/ w& J$ b( o* I* a
27.             <!-- cron表达式 -->
    3 ~: C' x' L9 C1 M+ g% H7 U1 Q% ^
28.             <property name="cronExpression">
    , i$ [9 X, t5 s. U$ E7 M
29.                            <value>0/5 * * * * ?</value>
    / C) _8 h1 M1 g
30.             </property>
    , \+ |6 o$ I& ]$ R1 H5 n% ^
31.         </bean>
    
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    5 ^% P( Z0 n* Q* y+ i% a
34.             <property name="triggers">
    ) E: P! f+ x; ~$ m& ~- Z1 R. h. ~
35.                 <list>
    
36.                     <ref bean="jibDoTime"/>
    
37.                 </list>
    
38.             </property>
    
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    4 G1 g  j: b: c% e+ a
41.       </bean>
    
42.       <!-- 配置任务并发执行线程池 -->
    
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    5 Z3 B/ R' h. O; p" U
44.                 <property name="corePoolSize" value="3" />
    
45.                 <property name="maxPoolSize" value="5" />
    0 S; w  ~: u3 |% F  c9 F- M7 J
46.                 <property name="queueCapacity" value="10" />
    4 W# B/ @( X9 `
47.           </bean>
    ' h$ C0 U: _$ D$ d: i
48. </beans>

复制代码

+ K" i1 }. n/ S
" A) x4 Y0 I% ?9 C( ^) ]+ [web.xml 启动配置：
) R9 j8 `+ U$ a) S% F0 N

1. <?xml version="1.0" encoding="UTF-8"?>
   8 y. {& ?; C, ]5 a" B* Z$ \" j8 B
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 T- m$ r  e
4.         <context-param>
   . s7 @9 p% f5 {3 p! p. V) {1 g
5.             <param-name>contextConfigLocation</param-name>
   * u9 `6 ^% ?+ C
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   
7.     </context-param>
   ( C- {: E/ {/ d0 \
8.      <!-- 监听器 -->
   
9.          <listener>
   5 E8 X' x: @8 H9 P, c" p
10.                 <listener-class>
    
11.                                 org.springframework.web.context.ContextLoaderListener
    
12.                         </listener-class>
    , B8 @( d. n$ S
13.          </listener>
    $ `6 G3 m  K5 b, a; U; D
14.         <welcome-file-list>
    * Z4 }5 h9 q/ \) L  B
15.                 <welcome-file>index.html</welcome-file>
    9 L7 ?" x$ T, I6 ?) u, M: v. I
16.         </welcome-file-list>
    8 ?3 O  ^. [0 i# [
17. </web-app>
    2 K* g6 s$ [. H% O& H& M$ I1 P# D; f

复制代码

' w6 f) B( Y+ P8 @( {
7 ~# l* b- l( E; n+ b运行截图：
1 z6 p; y1 h5 L9 g

5 Q- m) o7 l( t! x% J
Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

xjs

学习学习