Spring Quartz任务案例源码实现

admin

写在开始
上一篇有讲到 springTask任务案例源码实现 :http://www.52itstyle.top/thread-40036-1-1.html
3 S/ ?( q$ @& O! `& x
此篇，见一下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的状态和信息。
; I$ G1 J. X! X9 l
8 K" X+ s' @, X功能实现
1 `3 Z1 X9 I, i8 ]这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
$ S+ [' ^. h- q- mQuartz下载地址：http://www.quartz-scheduler.org/downloads

3 y* }1 w- B0 V4 s9 t9 A: j目前，最新版本为2.2.1，Maven配置如下：

1. <dependency>
   
2.     <groupId>org.quartz-scheduler</groupId>
   1 \5 d$ w' n: e0 x, Z6 h4 \6 W
3.     <artifactId>quartz</artifactId>
   ' U* c' a3 Q( b6 j/ W. a( o+ }
4.     <version>2.2.1</version>
   . T5 S4 T4 k+ M1 g+ b3 l+ T
5.   </dependency>
   
6.   <dependency>
   
7.     <groupId>org.quartz-scheduler</groupId>
   
8.     <artifactId>quartz-jobs</artifactId>
   & k6 p  l. [  b' z4 a
9.     <version>2.2.1</version>
   0 `0 B) W- A% x) ^
10.   </dependency>

复制代码

1 ?3 `2 U4 F# M; x
$ k3 E; R& Q% b3 t; E$ A编写一个JobTest.java:
0 i- i5 t6 d$ ?( @* X) U

1. package quartz;
   
2. /**
   
3. * 任务测试 科帮网 http://www.52itstyle.top/
   : ~% ~' Z3 K  ~" o: K
4. * 创建者        张志朋
   
5. * 创建时间        2017年4月22日
   
6. *
   9 {' U' ~7 ]4 h: W9 @
7. */
   
8. public class JobTest {
   
9.         public void work(){
   
10.                 System.out.println("任务开始执行");
    ; x$ E; r' f' v% Q: s
11.         }
    
12. }
    

复制代码

编写applicationContext-job.xml：

1. <?xml version="1.0" encoding="UTF-8"?>
   1 |4 ?& `) [) _7 z; ]
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"
   
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
   0 H+ |8 _4 x- J& r# d' E
7.             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
   & J( p# I9 B" s
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">
   
9.             
   
10.              <bean id="testJob" class="quartz.JobTest"></bean>     
    7 l  M$ u+ \* m! n1 u# W
11.         <!-- 定义调用对象和调用对象的方法 -->
    
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    ! b  B  h1 Y9 l: o) F( b2 O6 S
13.             <!-- 调用的类 -->
    + N0 A- X, V4 U$ S1 B4 o
14.             <property name="targetObject">
    
15.                 <ref bean="testJob"/>
    
16.             </property>
    
17.             <!-- 调用类中的方法 -->
    
18.             <property name="targetMethod">
    
19.                 <value>work</value>
    . f8 u, o$ l& Y% D9 I* J
20.             </property>
    2 h, J+ j$ L, U- z- c! u
21.         </bean>  
    
22.         <!-- 调度触发器 -->
    
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    " a9 `1 F+ w" F5 U
24.             <property name="jobDetail">
    * I) Z  p' [  D6 R$ h
25.                 <ref bean="testTask"/>
    
26.             </property>
    
27.             <!-- cron表达式 -->
    6 M3 y; z8 w! U
28.             <property name="cronExpression">
    . n: N, l! d. q( D7 j4 u0 O
29.                            <value>0/5 * * * * ?</value>
    
30.             </property>
    
31.         </bean>
    % A* @0 R' O: t0 }* P) \% G
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
      `, Y5 j- ^# _1 T6 E0 ^
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
    
34.             <property name="triggers">
    & s0 q+ y# `; X& s; X6 ~
35.                 <list>
    
36.                     <ref bean="jibDoTime"/>
    
37.                 </list>
    7 ]$ K  e/ G/ u; J
38.             </property>
    0 _; u4 G& B7 p, s: {6 z/ i
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    4 L1 N% [  ~: J$ }+ G0 `
41.       </bean>
    
42.       <!-- 配置任务并发执行线程池 -->
    
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    * D9 V. B3 J% ^- ]  Y! u7 H
44.                 <property name="corePoolSize" value="3" />
    7 m  K% N, t/ O9 O$ }" `2 u4 f) _
45.                 <property name="maxPoolSize" value="5" />
    
46.                 <property name="queueCapacity" value="10" />
    
47.           </bean>
    
48. </beans>

复制代码

web.xml 启动配置：
0 f9 l5 N  p: z: A  z

1. <?xml version="1.0" encoding="UTF-8"?>
   ( K$ m% H2 A# O, P
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">
   8 ~% [+ X; Y# Q% V. k& E+ ~$ Q
3.         <display-name>spring_quartz</display-name>
   # y4 q$ L& y/ F6 Q' V: F
4.         <context-param>
   5 \' B$ P6 {# G2 @1 D  Y6 m
5.             <param-name>contextConfigLocation</param-name>
   
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   
7.     </context-param>
   ) B! V: q8 f$ d9 g% a  i
8.      <!-- 监听器 -->
   / Z: K  c. H* G5 `. K) E; V
9.          <listener>
   ! k" t4 ~& _& V- n2 G
10.                 <listener-class>
    6 }1 y$ u, S$ x/ m3 M: e
11.                                 org.springframework.web.context.ContextLoaderListener
    
12.                         </listener-class>
    # i# e, n8 Z  I- [# E
13.          </listener>
    
14.         <welcome-file-list>
    
15.                 <welcome-file>index.html</welcome-file>
    . T; r/ M" V/ ^3 G0 ^  T2 d& y
16.         </welcome-file-list>
    
17. </web-app>
    6 Y+ e' J% V% X4 d' Z- u7 M

复制代码

- q1 Y+ {% }0 L& z& F2 p' Q
5 d( M, c  r  Q+ e9 A3 ~/ g运行截图：


2 f. {9 r% x% b& M: O3 C
Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

+ Y2 e% v# {7 f; b) u! X