Spring Quartz任务案例源码实现

admin

写在开始
1 f7 Y2 B4 N. d/ t0 E' z8 w上一篇有讲到 springTask任务案例源码实现 :http://www.52itstyle.top/thread-40036-1-1.html

此篇，见一下spring整合Quartz实现更强大的定时任务。
8 j/ X, X; ^# o' N; q3 V5 t
8 y# c+ Q: O& _6 Q任务介绍
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的状态和信息。

功能实现
这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
Quartz下载地址：http://www.quartz-scheduler.org/downloads
& h8 y1 s* X8 v( v6 }* H' F5 [
* V. K0 {3 Q" ?目前，最新版本为2.2.1，Maven配置如下：
) a% s1 e8 n; }' ]

1. <dependency>
   + M! C& \8 [' N7 t# ]( L' \
2.     <groupId>org.quartz-scheduler</groupId>
   
3.     <artifactId>quartz</artifactId>
   " n/ j! R" A" x% F
4.     <version>2.2.1</version>
   7 V5 X) N. I" \3 m
5.   </dependency>
   8 J9 d7 R+ O! g" p/ @6 j: Y% `
6.   <dependency>
   
7.     <groupId>org.quartz-scheduler</groupId>
   + t9 [3 n2 O5 Q9 S/ _: Y/ l
8.     <artifactId>quartz-jobs</artifactId>
   3 ^- D2 O" X9 B9 _( D: ^
9.     <version>2.2.1</version>
   ; p6 W7 ^# B/ _6 E9 Y" J6 r
10.   </dependency>

复制代码

! n% [( ]6 p* j3 {2 [4 C' A编写一个JobTest.java:

1. package quartz;
   
2. /**
   
3. * 任务测试 科帮网 http://www.52itstyle.top/
   . {' J7 t3 k3 M' C4 l7 E
4. * 创建者        张志朋
   
5. * 创建时间        2017年4月22日
   . z& |& o; B% N0 b+ E  F1 E
6. *
   7 x' ]* H$ _2 n: @& X( N! R+ V
7. */
   ' x5 l# V% P0 V- B; F' H
8. public class JobTest {
   
9.         public void work(){
   
10.                 System.out.println("任务开始执行");
    0 x% ]5 P1 w' d( |
11.         }
    
12. }
    

复制代码

编写applicationContext-job.xml：
5 u$ b* ^' ]; T

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <beans xmlns="http://www.springframework.org/schema/beans"
   / Z+ \1 W6 P' ~. h9 n, p
3.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
   ) }$ b( u7 |9 u% p& y
4.         xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
   
5.         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
   4 }" t; _! m/ I; D4 p
6.             http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
   ! Y  s9 Z, {/ m6 b
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">
   ) {0 A$ ]. ]8 |- O2 s
9.             
   6 U" {; L& P4 a: }; z# o9 \
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    2 E8 B6 P  G3 j9 Q5 D4 x
11.         <!-- 定义调用对象和调用对象的方法 -->
    
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    ; @( ^4 U" p1 [' m
13.             <!-- 调用的类 -->
    % {1 c6 |2 @4 w! O* V
14.             <property name="targetObject">
    
15.                 <ref bean="testJob"/>
    . e( R# b2 @- A$ d, c4 T3 P
16.             </property>
    & C# S# ]- @2 M2 J9 B
17.             <!-- 调用类中的方法 -->
    
18.             <property name="targetMethod">
    " x& u& }+ [- y8 g% B+ ]6 A
19.                 <value>work</value>
    ( q: f) l' l, E/ j/ o
20.             </property>
    
21.         </bean>  
    ! u: Y% O& Z5 x5 @+ M
22.         <!-- 调度触发器 -->
    
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    
24.             <property name="jobDetail">
    
25.                 <ref bean="testTask"/>
    + L" c) X8 E; B/ Z* S, ^  {8 w
26.             </property>
    
27.             <!-- cron表达式 -->
    
28.             <property name="cronExpression">
    + J  V0 x4 s( \. z' G
29.                            <value>0/5 * * * * ?</value>
    ! ^6 n% }+ H5 f
30.             </property>
    
31.         </bean>
    # \, K. N- x( ~6 u; }/ w& t
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    ( k* \7 M4 m; B" [+ b. `% [
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    7 e  @" @2 \5 E3 ?7 h# v$ c, x/ k
34.             <property name="triggers">
    , c/ A8 N: ~: G) ]1 @  Z; \. d
35.                 <list>
    ' P" _" w$ A- p3 Q2 x( j
36.                     <ref bean="jibDoTime"/>
    
37.                 </list>
    9 Q3 E- U2 F. w( M. Z$ t' T
38.             </property>
    2 }( v' p5 n4 N0 E( s2 U) G% \
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    
41.       </bean>
    
42.       <!-- 配置任务并发执行线程池 -->
    
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
      ]1 f  ~3 B% I5 w/ y
44.                 <property name="corePoolSize" value="3" />
    4 b& F$ N+ E6 x: z
45.                 <property name="maxPoolSize" value="5" />
    ( }6 O! O8 L8 m
46.                 <property name="queueCapacity" value="10" />
    
47.           </bean>
    2 J$ w+ l9 F: n7 a+ I- E  M+ o
48. </beans>

复制代码

: R) w. l$ F+ p! [4 \' M
2 i; @6 w4 S7 v9 Cweb.xml 启动配置：
9 h: t1 ^  z- e

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">
   - ?! W5 c- [+ l3 s, Z/ }
3.         <display-name>spring_quartz</display-name>
   * I1 }) ]5 q& _: M( f8 }  {: g+ I* {
4.         <context-param>
   
5.             <param-name>contextConfigLocation</param-name>
   
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   0 B7 ^- g* d6 d% m9 Y4 d
7.     </context-param>
   5 P! b0 |. |$ r+ K1 y
8.      <!-- 监听器 -->
   
9.          <listener>
   : b* Z2 G* C. ^& D4 B$ N7 A4 a1 d9 g  ]
10.                 <listener-class>
    " H" E3 ~3 Y9 u1 k6 d- S
11.                                 org.springframework.web.context.ContextLoaderListener
    
12.                         </listener-class>
    
13.          </listener>
    
14.         <welcome-file-list>
    
15.                 <welcome-file>index.html</welcome-file>
    : `" \' }& X& c
16.         </welcome-file-list>
    
17. </web-app>
    & k2 u, m( F& I

复制代码

5 q0 H1 g% H6 _* v: W  C0 h
: }- d0 U$ Q  a7 Y7 N6 L4 T运行截图：


, d4 Z2 H; A. H# }* b& Q% d0 B
Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

xjs

学习学习
7 l* Y, ]& M. E0 ^