Spring Quartz任务案例源码实现

admin

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

此篇，见一下spring整合Quartz实现更强大的定时任务。

, ]9 d: f8 D7 c3 E任务介绍
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的状态和信息。
3 ]) ~9 E3 b) J& p0 m+ I. d" D) i
* J4 g/ R' L  m8 }# Z. s) [功能实现
6 x# O/ M9 E, F9 C9 z这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
Quartz下载地址：http://www.quartz-scheduler.org/downloads
2 O2 |9 f+ d, D! @
目前，最新版本为2.2.1，Maven配置如下：
. [2 O; @' A! {% m. o- J/ Z- _

1. <dependency>
     u* e' J5 h. D1 ~0 r
2.     <groupId>org.quartz-scheduler</groupId>
   ' b& m) e4 Y3 f8 {
3.     <artifactId>quartz</artifactId>
   
4.     <version>2.2.1</version>
   
5.   </dependency>
   / C9 R  C! V* n& m; J7 `" h% M
6.   <dependency>
   
7.     <groupId>org.quartz-scheduler</groupId>
   . w" O" p1 w; b  P9 A# `+ M( |
8.     <artifactId>quartz-jobs</artifactId>
   . z0 L! V5 Y* C4 F1 R" R
9.     <version>2.2.1</version>
   - r- n1 I! ^! i# X9 s
10.   </dependency>

复制代码

5 P2 _9 s( m! X: A' G$ o* q" G6 X
编写一个JobTest.java:
" r0 Q1 M8 h' q% T- y

1. package quartz;
   ( |, H+ ^7 g* U+ p4 q; f
2. /**
   / i3 z& o0 z* V& A
3. * 任务测试 科帮网 http://www.52itstyle.top/
   
4. * 创建者        张志朋
   
5. * 创建时间        2017年4月22日
   ! A4 g8 U. t5 }: Z' S! q
6. *
   
7. */
   
8. public class JobTest {
   , \! {9 M3 R, n) k* N  Q5 y
9.         public void work(){
   8 c' `1 q8 v7 \3 g
10.                 System.out.println("任务开始执行");
    
11.         }
    
12. }
    0 J- n  D! Z; _5 |# ^5 t3 M& u

复制代码

编写applicationContext-job.xml：
1 j# N- {( g1 k1 o! u3 O

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <beans xmlns="http://www.springframework.org/schema/beans"
   . Z  f4 H. Y( Y1 T5 C8 i
3.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
   ) W- s* U( E' b: w) ?; F8 F
4.         xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
   6 C+ F% \  y( a. ], q
5.         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
   9 }+ C: B) r" F, n; N" J0 b
6.             http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
   * U' v& e5 P, k: B9 R7 i; w1 d/ H8 z
7.             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
   # ]5 b. h3 a6 t0 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>     
    3 R$ Z# `$ x( d2 L
11.         <!-- 定义调用对象和调用对象的方法 -->
    
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    
13.             <!-- 调用的类 -->
    
14.             <property name="targetObject">
    4 a% d- g. ?5 H
15.                 <ref bean="testJob"/>
    , P$ x8 k5 X* c8 ?7 Y
16.             </property>
    
17.             <!-- 调用类中的方法 -->
    + t! x- ~9 R8 r4 U" x/ ^
18.             <property name="targetMethod">
    5 f1 _) m8 [5 i% {% ?
19.                 <value>work</value>
    6 j, r' j# u; V% H& _
20.             </property>
    , D5 F& D% ?4 Y: i
21.         </bean>  
      J* H/ `% x6 h. g
22.         <!-- 调度触发器 -->
    
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    
24.             <property name="jobDetail">
    
25.                 <ref bean="testTask"/>
      h- h% b" Z0 b- s. F6 J
26.             </property>
      a8 x- G5 W1 N* u  ~3 _
27.             <!-- cron表达式 -->
    
28.             <property name="cronExpression">
    
29.                            <value>0/5 * * * * ?</value>
    ; N9 R) J0 t/ x/ I! j
30.             </property>
    % O- J9 c3 c! }! q
31.         </bean>
    
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    ! M; U9 @8 M& U7 Q: R1 s
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    
34.             <property name="triggers">
    
35.                 <list>
    
36.                     <ref bean="jibDoTime"/>
    ) n/ l  j' a. O7 W3 @
37.                 </list>
    
38.             </property>
    
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    3 W& I5 c6 u; P- v; q: N
41.       </bean>
    
42.       <!-- 配置任务并发执行线程池 -->
    
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    
44.                 <property name="corePoolSize" value="3" />
    $ ^" n. r8 G$ ^! R0 c5 Z
45.                 <property name="maxPoolSize" value="5" />
    
46.                 <property name="queueCapacity" value="10" />
    
47.           </bean>
    
48. </beans>

复制代码

web.xml 启动配置：
, s+ o: T) M4 ~& L

1. <?xml version="1.0" encoding="UTF-8"?>
   / k( _& _6 n# M& s$ [9 q
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>
   / r: v# W! p8 z0 T$ d
4.         <context-param>
   * [7 n7 o% B8 F3 o* T
5.             <param-name>contextConfigLocation</param-name>
   + j: h5 ~* V: [' E  q. j8 P
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   
7.     </context-param>
   
8.      <!-- 监听器 -->
   # U# \# ~" K+ h9 a+ n& L  x
9.          <listener>
   
10.                 <listener-class>
    * W1 @$ N8 N5 G! }
11.                                 org.springframework.web.context.ContextLoaderListener
    + X5 a6 e# g: N& a0 a  C# Z
12.                         </listener-class>
    
13.          </listener>
    3 J- f6 Q9 d) C& \0 ?4 x, P
14.         <welcome-file-list>
    
15.                 <welcome-file>index.html</welcome-file>
    4 y/ B% l; F+ s
16.         </welcome-file-list>
    & X) ]) |8 J  V4 z9 p# z
17. </web-app>
    

复制代码

& i1 G6 D+ w9 H! \2 Q
运行截图：



+ w$ b! o3 W; M6 C/ a8 u5 X3 F Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

xjs

学习学习