Spring Quartz任务案例源码实现

admin

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

! p; @8 V3 j8 Q. `% m此篇，见一下spring整合Quartz实现更强大的定时任务。
' v9 h/ b1 `6 B; w! e+ C
  U5 D6 _2 b9 d8 v# _2 m6 i7 `任务介绍
/ _8 {2 Y6 l  G& ZQuartz存储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的状态和信息。
0 g& k( l6 L2 u9 I% u% P
' i; I+ }$ k3 ~8 o5 H. ]. U# J3 n功能实现
这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
, Z% p1 S5 u7 H% Z) i. qQuartz下载地址：http://www.quartz-scheduler.org/downloads
5 `. |3 U8 e( S) F+ C/ o5 J
目前，最新版本为2.2.1，Maven配置如下：
* G: ^. [; Z- A0 f

1. <dependency>
   6 v; G' g: H1 t* k- Z9 S$ z
2.     <groupId>org.quartz-scheduler</groupId>
   3 `2 a3 o* ~* a. {
3.     <artifactId>quartz</artifactId>
   
4.     <version>2.2.1</version>
   
5.   </dependency>
   
6.   <dependency>
   
7.     <groupId>org.quartz-scheduler</groupId>
   ) i5 `6 M- C( V8 K) @$ F, v
8.     <artifactId>quartz-jobs</artifactId>
   1 x6 h7 F: L1 j; U7 r/ A) D4 \
9.     <version>2.2.1</version>
   9 L  ~, g& X7 H7 S/ a/ U: O( G
10.   </dependency>

复制代码

" P$ D' y; I- h% ?$ w( T编写一个JobTest.java:

1. package quartz;
   8 E; `; |0 U  [/ h
2. /**
   
3. * 任务测试 科帮网 http://www.52itstyle.top/
   . j$ {, G8 k7 ^1 ^3 h! e' M2 H
4. * 创建者        张志朋
   
5. * 创建时间        2017年4月22日
   ( P7 J: m, M  m$ P
6. *
   / a( ~$ b' s  M! _+ c
7. */
   ' Q8 X5 |1 U0 i/ q& ?9 U
8. public class JobTest {
   ( P* Q' m7 r- k7 @
9.         public void work(){
   
10.                 System.out.println("任务开始执行");
    ' }0 F: z) W* h( j6 [" t! g
11.         }
    : B) ^  b! |4 M
12. }
    

复制代码

编写applicationContext-job.xml：
) h$ i3 p7 M  G+ o4 o& i9 v8 w

1. <?xml version="1.0" encoding="UTF-8"?>
   - @8 e+ X' d% `9 Q! f' o" |- G
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"
   " m; w) `3 w% u% S+ w
4.         xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
   ; X$ |: g) O3 s' X
5.         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
   8 v/ H% [' o1 q( P/ j. `
6.             http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
   
7.             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
   5 }/ i6 H3 ]" _3 {& ~* l2 s4 _
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">
   4 f( b  ^$ I6 H% b) Y8 O8 c# b
9.             
   
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    1 w5 R7 [0 F8 E2 ]0 k
11.         <!-- 定义调用对象和调用对象的方法 -->
    
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    / U: J# Y) B" a: ]
13.             <!-- 调用的类 -->
      f/ [7 h9 D5 }+ M8 L- V3 S1 L
14.             <property name="targetObject">
    
15.                 <ref bean="testJob"/>
    
16.             </property>
    
17.             <!-- 调用类中的方法 -->
    
18.             <property name="targetMethod">
    
19.                 <value>work</value>
    3 h$ m2 B3 Y8 U
20.             </property>
    
21.         </bean>  
    " P" ]4 q: y) Q, f, B* H
22.         <!-- 调度触发器 -->
    ; h  ~" z7 O' h; f1 I- J, `
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    
24.             <property name="jobDetail">
    5 D6 Q- {. M7 V. {
25.                 <ref bean="testTask"/>
    
26.             </property>
    ( E! C+ O6 F  x$ P# f' r4 @
27.             <!-- cron表达式 -->
    / S! ^$ Q" ~! I9 X& [% b4 m1 Y* o
28.             <property name="cronExpression">
    
29.                            <value>0/5 * * * * ?</value>
    3 C; {- Z( ~. I( D
30.             </property>
    ' K& m+ y* ]$ f) ]. L, z
31.         </bean>
    
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>
    0 K3 y( P" g! G" x* G! h) Y9 [
36.                     <ref bean="jibDoTime"/>
    
37.                 </list>
    3 M$ q/ B3 h7 l% ?6 B# N
38.             </property>
    # f  Z+ F( `: A7 j4 S; s/ c+ T
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    
41.       </bean>
    / W, R4 \) Z8 K0 V4 z! a
42.       <!-- 配置任务并发执行线程池 -->
    7 r* s; O" j3 T' [. Q
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    1 _6 \& w  f* m& z; |
44.                 <property name="corePoolSize" value="3" />
    
45.                 <property name="maxPoolSize" value="5" />
    / Q4 o' b- L7 c: y
46.                 <property name="queueCapacity" value="10" />
    % H) o5 `, N' J6 d' z; i0 A8 [9 C
47.           </bean>
    
48. </beans>

复制代码

- M" j# }6 C6 N' W
web.xml 启动配置：
; I+ Z0 T( e3 P* H/ S: h  I

1. <?xml version="1.0" encoding="UTF-8"?>
   2 E5 ^& m( j  f2 ?6 _$ y$ ^: @( t1 J
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>
   ) J  ?' i' a! p8 G1 I
4.         <context-param>
   
5.             <param-name>contextConfigLocation</param-name>
   # ?) ]$ w* f) G
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   8 [- ?& R8 w/ c7 e9 [2 w4 G
7.     </context-param>
   ; y/ }, N; g% \/ ~/ Z; t" w
8.      <!-- 监听器 -->
   # a. j' z2 @. D1 j$ m
9.          <listener>
   . y& U: O* Q: @" Q
10.                 <listener-class>
    
11.                                 org.springframework.web.context.ContextLoaderListener
    
12.                         </listener-class>
    
13.          </listener>
    " ?/ Y5 T; F7 e: {
14.         <welcome-file-list>
    2 q3 s( |# ]5 g2 q8 \; v8 t+ I
15.                 <welcome-file>index.html</welcome-file>
    
16.         </welcome-file-list>
    
17. </web-app>
    3 W* }, _( q; W. E. u

复制代码

: ?2 z2 W; x$ w
3 d+ B' J' p1 `, [2 s+ D( |7 S  Y运行截图：

% B; `, s9 n/ J! F2 G; \' j/ I
' Z" N6 b9 I* F4 F
$ n0 B6 ~. g# K& w Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

xjs

学习学习
* e$ w5 X8 ~- ^( Q! |7 f) ?