Spring Quartz任务案例源码实现

admin

写在开始
* C. R  M) j: @- @7 s上一篇有讲到 springTask任务案例源码实现 :http://www.52itstyle.top/thread-40036-1-1.html

此篇，见一下spring整合Quartz实现更强大的定时任务。
8 y$ ?1 e& {8 h+ ?
! G% V$ E5 f% d. f任务介绍
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的状态和信息。
4 @8 P1 G" \8 T3 r! A. O
功能实现
! N1 E, e4 ~7 |2 L# D7 l这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
& ~1 P# P4 z4 @( l' n& D, ~, x  oQuartz下载地址：http://www.quartz-scheduler.org/downloads

目前，最新版本为2.2.1，Maven配置如下：
2 k  L5 n9 v+ e: G: h

1. <dependency>
   
2.     <groupId>org.quartz-scheduler</groupId>
   ' X' z9 R6 m0 E& f# L
3.     <artifactId>quartz</artifactId>
   
4.     <version>2.2.1</version>
   
5.   </dependency>
   " `, W$ X7 a; ]/ ^6 I8 p
6.   <dependency>
   
7.     <groupId>org.quartz-scheduler</groupId>
   ' g: Q* {5 U1 S* |- W' ?
8.     <artifactId>quartz-jobs</artifactId>
   
9.     <version>2.2.1</version>
   6 Y  ]; R! H0 G0 ?6 y4 h5 ~) L
10.   </dependency>

复制代码

0 Q: ~1 U9 |% B. D0 [" r% k编写一个JobTest.java:

1. package quartz;
   
2. /**
   ! ?  {3 r+ t! [8 A0 Q9 Y
3. * 任务测试 科帮网 http://www.52itstyle.top/
   5 v& ]+ H" |  N; D- N
4. * 创建者        张志朋
   
5. * 创建时间        2017年4月22日
   
6. *
   1 L. e8 o/ z. W5 W  x1 A3 B
7. */
   
8. public class JobTest {
   
9.         public void work(){
   6 A" @7 \2 z# F/ S! e
10.                 System.out.println("任务开始执行");
    
11.         }
    1 D7 Q. o; B9 v4 T( D- `; N
12. }
    % a( O7 L( ~/ V0 w1 M

复制代码

编写applicationContext-job.xml：

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <beans xmlns="http://www.springframework.org/schema/beans"
   
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"
   4 \$ w7 [' O  }7 N& P; Y) w" d
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
   3 R# a. M2 @4 c+ F" t0 B! o6 c
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">
   ( b$ U' ~/ ]1 l
9.             
   
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    
11.         <!-- 定义调用对象和调用对象的方法 -->
    
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    
13.             <!-- 调用的类 -->
    7 P6 ^1 W5 k) G7 v) Z( o2 y2 l: ]
14.             <property name="targetObject">
    / G( B9 i0 P; V: S9 u, o
15.                 <ref bean="testJob"/>
    5 W1 C2 ^* a5 t
16.             </property>
    & _; f2 r2 ?& `& U
17.             <!-- 调用类中的方法 -->
    . `$ o1 ]/ c6 |
18.             <property name="targetMethod">
    
19.                 <value>work</value>
    
20.             </property>
    " D) v, X/ d/ |7 [1 K3 z
21.         </bean>  
    % y( w4 d1 R5 H7 x9 _: W
22.         <!-- 调度触发器 -->
    
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    1 c. i; K$ v) c5 P5 y" _
24.             <property name="jobDetail">
    + n; R! }- T+ C9 ^2 T$ l
25.                 <ref bean="testTask"/>
    
26.             </property>
    , F: N5 ]* l* O; K4 _  {
27.             <!-- cron表达式 -->
    
28.             <property name="cronExpression">
    
29.                            <value>0/5 * * * * ?</value>
    
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">
      H1 ]0 M5 Z. O4 B7 y0 R
34.             <property name="triggers">
    
35.                 <list>
    9 K: w) t2 a1 o, {4 @% w
36.                     <ref bean="jibDoTime"/>
    
37.                 </list>
    
38.             </property>
    
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    $ A8 O: R7 L, F( w7 R& I) d) K
41.       </bean>
    + P1 p6 ?/ t+ [4 M1 Y
42.       <!-- 配置任务并发执行线程池 -->
    
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    
44.                 <property name="corePoolSize" value="3" />
    9 |! n6 M- q4 m  i
45.                 <property name="maxPoolSize" value="5" />
    % F8 h8 Q" {$ e9 e* h1 f& [/ o
46.                 <property name="queueCapacity" value="10" />
    ) l/ o" }$ V$ L3 d8 a8 u
47.           </bean>
    
48. </beans>

复制代码

0 r+ q) e# k) D6 x
3 S% H* @% D- c" ^web.xml 启动配置：
  {7 d/ i/ l# E( l7 u% x+ R4 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">
   
3.         <display-name>spring_quartz</display-name>
   
4.         <context-param>
   4 u) V6 n0 D3 \! v. X
5.             <param-name>contextConfigLocation</param-name>
   
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   0 X$ N7 i& {4 v; s5 c
7.     </context-param>
   $ ^$ e8 V  `1 u3 S, g/ A
8.      <!-- 监听器 -->
   
9.          <listener>
   + `1 f, f5 Y2 ^" Z+ p  m2 `+ c6 B
10.                 <listener-class>
    
11.                                 org.springframework.web.context.ContextLoaderListener
    
12.                         </listener-class>
    % S/ X: r- x9 O3 D5 F$ `  V
13.          </listener>
    
14.         <welcome-file-list>
    . e& b) d5 g; N' y7 s
15.                 <welcome-file>index.html</welcome-file>
    
16.         </welcome-file-list>
    
17. </web-app>
    * T/ D4 q2 ?& S2 ^- f) k8 X) |- N

复制代码

/ m& ]6 n( K$ o运行截图：
/ \/ _" q# U% z7 W  K) c
; J) }) f: [0 `6 W
: D' [* Y3 h  g1 e. X
; f' ?; i& j  y4 J Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

  a* U1 E4 K( _9 v

xjs

学习学习
7 i4 |' c+ M5 B' m) |; n