Spring Quartz任务案例源码实现

admin

写在开始
% s/ [# N* {" e2 s8 v1 Q6 K上一篇有讲到 springTask任务案例源码实现 :http://www.52itstyle.top/thread-40036-1-1.html

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

任务介绍
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的状态和信息。

( J9 Q' W( X; X/ e  l功能实现
- B' p) A" P# d这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
3 l0 Q" k- d  A- e* Q% s, QQuartz下载地址：http://www.quartz-scheduler.org/downloads

目前，最新版本为2.2.1，Maven配置如下：
& m7 X: P. Q. F6 V! p

1. <dependency>
   7 ^8 D+ O6 B; T, K
2.     <groupId>org.quartz-scheduler</groupId>
   
3.     <artifactId>quartz</artifactId>
   
4.     <version>2.2.1</version>
   - m# K( i0 f3 ]- A7 R
5.   </dependency>
   
6.   <dependency>
   
7.     <groupId>org.quartz-scheduler</groupId>
   
8.     <artifactId>quartz-jobs</artifactId>
   
9.     <version>2.2.1</version>
   % X0 p6 s- Q* c2 w* y7 A6 D6 p
10.   </dependency>

复制代码

. Q5 G" ?& r; g! q; w3 _
编写一个JobTest.java:
8 I8 N; G+ z9 ?$ h( E7 W' o, L% M% p

1. package quartz;
   5 K2 [6 V) M! S1 S4 E; N
2. /**
   
3. * 任务测试 科帮网 http://www.52itstyle.top/
   
4. * 创建者        张志朋
   5 \8 k, T1 m6 k+ E
5. * 创建时间        2017年4月22日
   
6. *
   6 ?: ^" |( o. |- g3 i( I
7. */
   
8. public class JobTest {
   
9.         public void work(){
   6 B1 y; f6 ]: O! m6 Z8 g  I- z
10.                 System.out.println("任务开始执行");
    : J2 K0 m# N) g8 e. w% h3 ?
11.         }
    
12. }
    

复制代码

编写applicationContext-job.xml：

1. <?xml version="1.0" encoding="UTF-8"?>
   + Z* g1 w! Q4 [$ Y9 b% o9 T
2. <beans xmlns="http://www.springframework.org/schema/beans"
   9 `: d: N* t. U, V2 W8 P
3.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
   6 a: D# P. V3 n' k% K& Z( \8 C
4.         xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
   & |2 l: q0 A% V: h; U& C8 D
5.         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
   ; k& o* k& ?* i: ~7 P
6.             http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
     ^0 D7 _$ }! R! X+ Z8 O0 `; t$ M
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">
   " Q, d# L6 [4 x+ n
9.             
   
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    " _4 O& V; y* g, L% I$ A4 i
11.         <!-- 定义调用对象和调用对象的方法 -->
    
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    ! G; Y5 [% p8 l# @
13.             <!-- 调用的类 -->
    + s$ Z& V) j) z! [
14.             <property name="targetObject">
    , N3 z# M4 k; E8 t4 p) r5 K7 K! T; `0 h
15.                 <ref bean="testJob"/>
    2 K, |$ @/ ]5 U  o4 J* T
16.             </property>
    
17.             <!-- 调用类中的方法 -->
    
18.             <property name="targetMethod">
    ) ~" L3 y+ x# R0 j  K2 A  s
19.                 <value>work</value>
    4 m! }% z, ^, L( t9 H
20.             </property>
    
21.         </bean>  
    1 W( U4 \5 L, x
22.         <!-- 调度触发器 -->
    
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    ( z/ \" I4 V7 |9 o
24.             <property name="jobDetail">
    
25.                 <ref bean="testTask"/>
    
26.             </property>
    9 S+ J) ~! G' r0 t/ S" M: Z
27.             <!-- cron表达式 -->
    & N5 k0 d7 H2 W! Y3 U4 W2 p
28.             <property name="cronExpression">
    2 h& f" q, p  p
29.                            <value>0/5 * * * * ?</value>
    3 j. ^3 I5 b( {$ @. o- h" p0 `
30.             </property>
    
31.         </bean>
    
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
      g* [; ?% l  U" C) L8 Q: ^- K
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    
34.             <property name="triggers">
    ) _) w  K7 q! p; P4 }- n
35.                 <list>
    
36.                     <ref bean="jibDoTime"/>
    8 V7 [* q& r/ d2 ?
37.                 </list>
    2 O8 U, @* u  D) S; ^
38.             </property>
    
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    % D8 w2 ], F2 f& N
41.       </bean>
      |8 [1 b/ O0 _% R
42.       <!-- 配置任务并发执行线程池 -->
    
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    6 R% h9 E4 Q3 A  T: H9 z
44.                 <property name="corePoolSize" value="3" />
    
45.                 <property name="maxPoolSize" value="5" />
    
46.                 <property name="queueCapacity" value="10" />
    
47.           </bean>
    ( k. v8 q3 N9 X+ K6 v6 w
48. </beans>

复制代码

( g( ~) q8 |4 t% Y' k- r' ^. @/ Gweb.xml 启动配置：

1. <?xml version="1.0" encoding="UTF-8"?>
   6 p2 k1 O: w5 }
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">
   & X2 ]; d/ k5 W8 N/ E* L4 a/ k* R
3.         <display-name>spring_quartz</display-name>
   
4.         <context-param>
   
5.             <param-name>contextConfigLocation</param-name>
   
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   
7.     </context-param>
   
8.      <!-- 监听器 -->
   
9.          <listener>
   
10.                 <listener-class>
    / H& e* \. P# k3 o3 e) j
11.                                 org.springframework.web.context.ContextLoaderListener
    * B5 {& @# M: F" t: B/ o+ w
12.                         </listener-class>
    
13.          </listener>
    8 O: `& {8 x  \6 z
14.         <welcome-file-list>
    
15.                 <welcome-file>index.html</welcome-file>
    
16.         </welcome-file-list>
    
17. </web-app>
    

复制代码

1 i9 ?/ s( Q% J4 [. J+ C运行截图：

( ]0 h/ S; ], m) f, ]0 L- t2 ~
" i2 T7 H3 m& N& {
+ A" [+ |/ @' r Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

xjs

学习学习