Spring Quartz任务案例源码实现

admin

写在开始
+ o, I. w2 S& L! S上一篇有讲到 springTask任务案例源码实现 :http://www.52itstyle.top/thread-40036-1-1.html
3 e! h& ]  u) v$ o1 X+ ?
7 g: {" R6 A! ^0 t4 C  n5 W此篇，见一下spring整合Quartz实现更强大的定时任务。
7 A9 W3 B7 k# r% e
# F2 Z3 T: v" E5 l任务介绍
( w/ @2 \% A- w3 Y8 sQuartz存储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 p- ~- T5 O" @
功能实现
这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
! z: g4 r# G) h; vQuartz下载地址：http://www.quartz-scheduler.org/downloads

目前，最新版本为2.2.1，Maven配置如下：
2 b# \( n. I! z0 b

1. <dependency>
   
2.     <groupId>org.quartz-scheduler</groupId>
   7 \0 {; p8 J* A- ~0 A: i4 }7 k
3.     <artifactId>quartz</artifactId>
   
4.     <version>2.2.1</version>
   
5.   </dependency>
   ( w; e! [6 t& h3 f1 c
6.   <dependency>
   
7.     <groupId>org.quartz-scheduler</groupId>
   
8.     <artifactId>quartz-jobs</artifactId>
   
9.     <version>2.2.1</version>
   + L/ r. M  U* I! r
10.   </dependency>

复制代码

2 R+ p3 ?2 d( C& O( Y; s
6 v- h& y, @8 P  q. V* O: x编写一个JobTest.java:
( l3 f- X- v& E( e% G. ~  d

1. package quartz;
   
2. /**
   , |% L" l* q% Q$ p$ K
3. * 任务测试 科帮网 http://www.52itstyle.top/
   
4. * 创建者        张志朋
   1 u3 Y0 g' a  j8 q
5. * 创建时间        2017年4月22日
   9 ^; l; X# g$ G; U0 p7 J9 C
6. *
   
7. */
   0 A$ a8 h3 s+ t) a
8. public class JobTest {
   0 i- J4 K7 T% ~  _: d$ C9 c
9.         public void work(){
   ) V# H; Z! _. M# p: r8 K4 u# D
10.                 System.out.println("任务开始执行");
    . U  u6 P7 r' C4 L: ]# U# i
11.         }
    
12. }
    

复制代码

编写applicationContext-job.xml：

1. <?xml version="1.0" encoding="UTF-8"?>
     J7 y; K& Q7 L; F. A: q
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"
   # P/ m) Z0 i6 y( J4 ?, z1 X9 P
5.         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
   5 h  h! X7 N  H
6.             http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
   " r& u3 m" X5 v  q6 i" S
7.             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
   7 a! U- j0 O' B0 q0 U6 Q+ c: O0 F* ?
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">
   % R; _0 N8 x7 f9 M; |
9.             
   # s+ C% B, O) k) z
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    4 v- i" `1 ]$ F$ T# s. L* e; R
11.         <!-- 定义调用对象和调用对象的方法 -->
    
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    
13.             <!-- 调用的类 -->
    
14.             <property name="targetObject">
    3 G; g+ g6 P" }5 G$ s& W/ u5 X
15.                 <ref bean="testJob"/>
    
16.             </property>
    
17.             <!-- 调用类中的方法 -->
    
18.             <property name="targetMethod">
    
19.                 <value>work</value>
    
20.             </property>
    8 U' j" P# V0 D. U7 Z4 ^- ^+ _
21.         </bean>  
    1 N7 _0 d8 k6 k4 m# Y; D2 Q
22.         <!-- 调度触发器 -->
    " B4 h9 X' `8 |3 j$ i  k- l
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    
24.             <property name="jobDetail">
    : D1 g1 T# k  f
25.                 <ref bean="testTask"/>
    
26.             </property>
    8 @! X. |5 T" z( {# Z' Y7 b1 w
27.             <!-- cron表达式 -->
    % C8 c& u. {7 M! c, l
28.             <property name="cronExpression">
    % C- ^& e  ~1 F- Q7 H$ y1 Q
29.                            <value>0/5 * * * * ?</value>
    ! ^9 q8 ?4 g. x# T/ d5 T5 Q
30.             </property>
      d$ D( I3 r0 L0 B
31.         </bean>
    3 J: }$ L, E9 @$ [' i
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    
34.             <property name="triggers">
    
35.                 <list>
    ' y) B7 @( w) `
36.                     <ref bean="jibDoTime"/>
    ) v+ d. g7 ~6 O  l8 F% [$ e
37.                 </list>
    
38.             </property>
    / b: v# {. W+ V' |! _% t& }6 S* g
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    0 K/ X. c  R; u% D
41.       </bean>
    
42.       <!-- 配置任务并发执行线程池 -->
      c+ }6 Q0 W/ K
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    
44.                 <property name="corePoolSize" value="3" />
    : e" w  @, @9 W1 y- @" j
45.                 <property name="maxPoolSize" value="5" />
    + ?. L: Q/ M" ~* J
46.                 <property name="queueCapacity" value="10" />
    8 F# o3 ?3 H& r) C3 K( m( o5 \
47.           </bean>
    ' {. O& G" y" }2 R, E& {$ a$ ]
48. </beans>

复制代码

! Q' Z( o4 U% y* Z6 x. t% X
& s8 y# ~8 |$ q* @" ^3 eweb.xml 启动配置：

1. <?xml version="1.0" encoding="UTF-8"?>
   ( R" k$ A! y* j& v
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">
   , S8 I' G6 }9 ]( J
3.         <display-name>spring_quartz</display-name>
   
4.         <context-param>
   : T0 q6 T, K  ?/ n
5.             <param-name>contextConfigLocation</param-name>
   
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   
7.     </context-param>
   / d  }* I; o' G. X
8.      <!-- 监听器 -->
   
9.          <listener>
   
10.                 <listener-class>
    
11.                                 org.springframework.web.context.ContextLoaderListener
    , T& w) ^, O# m) C
12.                         </listener-class>
    2 t. d0 b) p# }; s+ ]; h! f
13.          </listener>
    
14.         <welcome-file-list>
    ' E1 N) H/ {3 l7 i$ X# C
15.                 <welcome-file>index.html</welcome-file>
    
16.         </welcome-file-list>
    7 I1 `2 W+ I+ j# h- R6 E
17. </web-app>
    

复制代码

运行截图：
6 t' R- j% q/ ^# S0 H. i+ b! C9 O

6 i, Y2 u7 Z$ J9 ~9 x! W9 ]* w
  A" Y+ z2 C2 I) O) f$ G8 J- f2 j Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

4 [2 b3 O$ `% s9 c5 C, \/ I' B' a

xjs

学习学习
2 a7 V: m8 e! r, q( }