Spring Quartz任务案例源码实现

admin

写在开始
+ J3 _# x- W# U' X; G6 X上一篇有讲到 springTask任务案例源码实现 :http://www.52itstyle.top/thread-40036-1-1.html
. d% `. I$ i) P8 C+ u! U/ ]- z
此篇，见一下spring整合Quartz实现更强大的定时任务。
9 @  U* j0 p9 E; c+ Z
任务介绍
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的状态和信息。

% K4 K  t, W2 l7 X! Y) |功能实现
6 C1 i, {( X$ G. T0 C, r6 s% t这里，我们主要讲一下如何通过spring-4.0.6配置Quartz-2.2.1实现内存任务。
Quartz下载地址：http://www.quartz-scheduler.org/downloads

4 c$ S: D( x) Z& p2 N/ v% W5 H目前，最新版本为2.2.1，Maven配置如下：
% \, E! z* i  ?. h7 K5 h( Y; O

1. <dependency>
   
2.     <groupId>org.quartz-scheduler</groupId>
   
3.     <artifactId>quartz</artifactId>
   
4.     <version>2.2.1</version>
   , d1 o+ t& \+ X( V2 E7 I- f' D
5.   </dependency>
   4 @8 [. B1 C$ N9 W& y' L
6.   <dependency>
   , w" U* v0 L$ P4 A- v# ^
7.     <groupId>org.quartz-scheduler</groupId>
   ' A( p( N7 I: X7 O" W
8.     <artifactId>quartz-jobs</artifactId>
   . d5 m9 h' R/ z- M8 F# h
9.     <version>2.2.1</version>
   
10.   </dependency>

复制代码

1 ?8 G0 F  W! I# S( e/ \9 I编写一个JobTest.java:
& n7 z. {& z1 H9 C; O) |4 \2 V

1. package quartz;
   $ W9 N3 C3 U1 G
2. /**
   0 O# R  {  m/ t! w  V
3. * 任务测试 科帮网 http://www.52itstyle.top/
   , @( a+ [: v5 f4 G1 {( r$ Y& _
4. * 创建者        张志朋
   9 w" M! i# g2 l; z; K
5. * 创建时间        2017年4月22日
   
6. *
     @+ l3 F" Q* R- _, j
7. */
   ; [& I" D& ]; O7 r6 r3 g
8. public class JobTest {
   ) v. D" Y+ F+ i) F) ~
9.         public void work(){
   
10.                 System.out.println("任务开始执行");
    8 {& V, e! l" G6 w, i
11.         }
    + d* L5 L" F" d7 K2 W- |# w
12. }
    

复制代码

编写applicationContext-job.xml：
* u4 q9 E' Z4 W" ~; M. I

1. <?xml version="1.0" encoding="UTF-8"?>
   
2. <beans xmlns="http://www.springframework.org/schema/beans"
   & d4 f3 ], ?, l% U
3.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
   $ c# `9 _: m: M% [
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 B6 h1 V, d( @0 a/ L
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
   + g& |1 u* q, N
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>     
      b; s$ }1 A9 W- t
11.         <!-- 定义调用对象和调用对象的方法 -->
    
12.         <bean id="testTask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
    
13.             <!-- 调用的类 -->
    
14.             <property name="targetObject">
    , s/ ?6 T9 o9 Q
15.                 <ref bean="testJob"/>
    2 ]+ r* \9 J7 N& X1 p
16.             </property>
    
17.             <!-- 调用类中的方法 -->
    
18.             <property name="targetMethod">
    
19.                 <value>work</value>
    
20.             </property>
    
21.         </bean>  
    
22.         <!-- 调度触发器 -->
    2 F  V  ~+ L. q3 z' @0 G$ @
23.         <bean id="jibDoTime" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    ; q3 N- [6 p+ x- {
24.             <property name="jobDetail">
    . k. B! ?# y7 j" V( D
25.                 <ref bean="testTask"/>
    ( x) i( j  Y1 @( p
26.             </property>
    $ s/ ~6 S+ E- M+ u7 i  u
27.             <!-- cron表达式 -->
    
28.             <property name="cronExpression">
    
29.                            <value>0/5 * * * * ?</value>
    
30.             </property>
    
31.         </bean>
    8 H% q/ ?' p% Z% ~# u6 @7 T
32.         <!-- 调度工厂  如果将lazy-init='false'那么容器启动就会执行调度程序 -->
    * |8 \1 z: {9 s8 J0 [$ k
33.         <bean id="startQuertz"  factory-bean="executor" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
      Z3 S9 z1 n; R+ S/ s
34.             <property name="triggers">
    
35.                 <list>
    
36.                     <ref bean="jibDoTime"/>
    # }) U$ S1 b# G# J
37.                 </list>
    
38.             </property>
    % X2 c# o# y1 U: L7 |' P, y
39.             <!--必须的设置 QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->
    
40.             <property name="startupDelay" value="5" />
    7 `' e* ], m' \9 b" h6 t% [
41.       </bean>
    
42.       <!-- 配置任务并发执行线程池 -->
    
43.           <bean id="executor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    
44.                 <property name="corePoolSize" value="3" />
    
45.                 <property name="maxPoolSize" value="5" />
    
46.                 <property name="queueCapacity" value="10" />
    
47.           </bean>
    
48. </beans>

复制代码

6 F) }  ~: [, H3 y
. Z2 `4 u: V9 s$ Z( {) qweb.xml 启动配置：
1 @" x3 h; w" o- e+ L3 g

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">
   $ `3 C9 Z% E1 R$ x
3.         <display-name>spring_quartz</display-name>
   
4.         <context-param>
   
5.             <param-name>contextConfigLocation</param-name>
   # Z. G# j8 j4 q1 D2 j
6.             <param-value>classpath:applicationContext-job.xml</param-value>
   
7.     </context-param>
   2 m) S+ n" e* k0 F. ~" e7 f
8.      <!-- 监听器 -->
   7 i( y, N% @  W2 i( [
9.          <listener>
   
10.                 <listener-class>
    0 R) p7 ?2 r) \+ H) L
11.                                 org.springframework.web.context.ContextLoaderListener
    , y) B5 g6 A6 @
12.                         </listener-class>
    4 v: a+ |% J" k7 {* Y6 R
13.          </listener>
    # P1 f+ y7 b5 @7 f5 H+ }, V9 h5 ^( g- o
14.         <welcome-file-list>
    ( M5 I# ^6 V' P( k! ?& ?
15.                 <welcome-file>index.html</welcome-file>
    5 l: V% U0 p5 F7 o0 W
16.         </welcome-file-list>
    5 Y7 p  I' h+ `' ^
17. </web-app>
    

复制代码

0 s2 e' a( B3 x$ ^1 v1 M5 }
( O6 [7 ~# W1 X/ Y3 _+ J5 {运行截图：
* L$ c3 T0 w2 X. G4 o, `/ T4 i

1 e0 _: u7 j8 E8 q$ F! F
6 k  f9 {0 q5 V  g. | Spring Quartz任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

2017-4-23 19:18 上传

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

1 Z( e0 G$ f- b* S& W

xjs

学习学习