我的日常

登录/注册
您现在的位置:论坛 新手区 新手教程 > SpringTask任务案例源码实现
总共48086条微博

动态微博

查看: 2178|回复: 0

SpringTask任务案例源码实现

[复制链接]
admin    

1244

主题

544

听众

1万

金钱

管理员

  • TA的每日心情

    2021-2-2 11:21
  • 签到天数: 36 天

    [LV.5]常住居民I

    管理员

    跳转到指定楼层
    楼主
    发表于 2017-04-22 14:46:31 |只看该作者 |倒序浏览
    写在开始
    ' n( w) E% q6 k一般来说,无论是生活中或者项目中都会用到定时任务。比如我自己来说,每天晚上写一篇博客,当然这个任务的时间点可能不是那么准时。更多的例子,比如我们项目中数据的统计,文件或者数据库的定时备份等等。
    ' c+ V/ }0 {1 \1 }& ?& \, L- Z举个特别常见的例子,比如一些大型网站,首页的一些数据展示。有时候并不是实时展示的,可能是十分钟或者更久更新一次,来呈现给用户。9 O+ i, d6 C( W

    3 K2 x2 x: H' f8 u1 S% Z任务介绍9 D9 O4 U8 P) b4 h+ g3 ~
    就目前自己接触的定时人来来说,这里简单的聊下一下三种:  ~! p" N" V  I# O
    3 D# U5 t) R2 U# x7 {1 `% V
    1)java自带的java.util.Timer类,这个类允许你调度一个java.util.TimerTask任务。使用这种方式可以让你的程序按照某一个频度执行,但不能在指定时间运行。) ~' C" L  z2 j4 I$ [1 J/ g  N

      ]- {- t8 Q* U2 ~8 j! [& B: }2)开源调度框架Quartz,这是一个功能丰富比较强大的的调度器,可以实现内存和实例化数据库的任务(基于配置文件的内存实现和数据库实现)
    ) m- k" Z- `# v2 K0 r) @$ I3 I% S' q6 J* L) D
    3)spring3以后自带的task任务管理,可以将它看成一个轻量级的Quartz,相对来说使用起来更加方便。
      u" b4 O  ?4 _- n- ^, {; [! y: a7 @: g: @# r' h! S4 u
    使用案例7 l) A7 @8 V5 e2 Q
    关于1,2任务这里不做介绍,后面会为大家详细介绍,这里主要介绍一下springTask的使用方法。5 _9 ?4 K, G! `9 b) E

    9 j+ c) u  H2 f5 j0 n5 t1 ?( T这里使用的spring4.0.6版本,是支持springTask的 ,需要依赖spring-context-4.0.6.RELEASE.jar和spring-context-support-4.0.6.RELEASE.jar等等,后面会有源码提供。4 o: f( B# @$ t0 ?
    3 q8 P1 p. v' b, D( B: `$ y" R5 l
    springTask提供了基于xml配置和注解的两种实现方式。
    - Z! h3 c+ J/ s( W9 D  L2 z! ^1 F9 P
    基于注解的实现TestJob.java:: }: Z9 j5 \+ V: {5 x
    1. package task;
      9 k5 L7 V3 @* d: N# @- _- Y7 V
    2.   ?7 ?0 E6 y" j( J$ R$ J: W: [
    3. import org.springframework.scheduling.annotation.Scheduled;
      - L5 ^, b5 W4 O
    4. import org.springframework.stereotype.Component;
      1 B9 q( b' L9 i9 J
    5. /**
      & M. G' K+ a: i* w  W# O& X
    6. * 任务测试 科帮网 http://www.52itstyle.top/1 d! _* |% G1 S1 P. U' V) u2 B
    7. * 创建者        张志朋
      & F" Z; R& ]; R9 C
    8. * 创建时间        2017年4月22日# z" @5 ?. M2 i! G. t3 t2 C7 k
    9. *
      * V" r; x, H2 J9 v- F! C
    10. */
      5 F, o; I: l; I* M* U. C0 D9 V
    11. @Component("TestJob")  
      # Q" x& s' Y. u. z" x3 _+ d( F8 j" P
    12. public class TestJob {) D9 B5 F" c, t6 h5 Z
    13.         @Scheduled(cron = "0/5 * * * * ?")//每隔1秒隔行一次 5 n- ~# M0 g1 K! P( ?
    14.     public void test1()
      $ }% g/ A8 }" P# q) _; a
    15.     {
      / }$ d$ d2 E1 i# w) N: v. W
    16.         System.out.println("job1 开始执行");
      / x! o$ {) K$ W4 f! \, v: R
    17.     } 0 D- `) H7 X# v5 K2 |
    18.         @Scheduled(cron = "0/5 * * * * ?")//每隔1秒隔行一次 1 \. f0 y% R* ]6 L& ^1 p+ r
    19.     public void test2()
      , U7 \! K& w* j! G
    20.     {
      - X, Y0 @) [/ G' J/ F, f) @
    21.         System.out.println("job2 开始执行");; k1 K0 }% \/ ^- @$ t
    22.     }
      " v! ~7 \7 I7 b& A* c
    23. }7 u' `* b# X& B+ Y  Q! m0 N5 C
    复制代码
    , k6 r9 {% ~5 B  a: K7 h& f

    6 V+ v4 {! B" I9 i; K9 z! b) T基于注解的实现spring-context.xml:9 I( ~) ~! u* }3 Y" d
    1. <?xml version="1.0" encoding="UTF-8"?>( r) B/ T2 T' Z  v2 Q  {
    2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      4 l0 y# H2 |0 z- T, S$ \! W" h
    3.         xmlns:context="http://www.springframework.org/schema/context" xmlns:jdbc="http://www.springframework.org/schema/jdbc"  , q, E9 P2 U$ _* o
    4.         xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
      9 h8 _, j6 j  h
    5.     xmlns:util="http://www.springframework.org/schema/util" xmlns:task="http://www.springframework.org/schema/task" xsi:schemaLocation="2 Y  _; \3 P' K1 X" }* o) x/ F
    6.                 http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
      $ q( J0 ]1 N' T$ \; Y$ ?/ M  E  A
    7.                 http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd
      6 I" E+ I( T% S7 |' u0 a5 V7 [
    8.                 http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-4.0.xsd8 X3 J4 j6 a5 f+ E* e
    9.                 http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.0.xsd0 t/ h% }2 B' F. E7 f7 m
    10.                 http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
      % W5 z5 f/ X& z7 G( E: ~
    11.                 http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd
      " p0 l! m' D( m; _+ b0 J) M& G5 r
    12.                 http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd">! f) l' F" d# ~7 S# e
    13. , ]4 F1 p# A! B4 z0 X9 {
    14.         <description>Spring Configuration</description>
      . y' s8 R* R5 d  Y( p
    15.         # _& r& H2 C0 @7 l) _
    16.         <context:component-scan base-package="task"/> - q) t0 P' C9 N1 m0 Q: Z
    17.         ! z% R' ]- }- l. O9 d
    18.         <!-- 配置任务线性池 -->
      6 H6 c3 ]% k8 C6 P4 s  @1 C
    19.     <task:executor  id="executor" pool-size="10" /> 3 m1 ?' Z' c) i. T: T
    20.     <task:scheduler id="scheduler" pool-size="10"/>
      " z$ r9 d' m  r" d: E
    21.     <task:annotation-driven scheduler="scheduler" executor="executor" proxy-target-class="true"/>$ ~) `* c' L3 {, H
    22. </beans>
    复制代码
    + L+ i; M+ W; \

    0 i) t8 L) G* R% a, S! m: T6 J  x( D7 H; J
    基于配置的实现TestJob.java:
    4 y( ?" u, j6 E3 ?
    1. package task;% e# o7 i6 [3 ^6 {7 x
    2. ) X2 M3 p" a: E7 G; l/ d3 |
    3. import org.springframework.stereotype.Component;
      # e0 a; g$ H4 a- Z- r6 j# _+ Q
    4. /**0 m) C, X/ e, F6 L& x9 ?
    5. * 任务测试 科帮网 http://www.52itstyle.top/- X7 `+ ~4 G8 P! \* {# y7 \! n5 d4 W! ^
    6. * 创建者        张志朋
      0 [( ^0 f! h/ ~6 R* C! R% I6 k# t
    7. * 创建时间        2017年4月22日
      5 r# X' Z* v" E$ C  _
    8. *
      * r9 r- U+ r3 G
    9. */" T3 L# ^8 m) q% e1 ?
    10. @Component("TestJob")  % A" k) g- \' @. x3 x# L1 R0 |) E
    11. public class TestJob {
      ( K7 i4 p) C( c: r, C0 [
    12.     public void test1()
      " z7 R- S, Y$ }# E+ G! m& ?
    13.     {! y8 d4 V& F: b; p$ k
    14.         System.out.println("job1 开始执行");
      % n# v! @" d) L# X9 x) ^
    15.     } ' _/ ^  Z. Q$ Q7 N  [+ g; a* J1 M
    16.     public void test2()
      ) a& p. R7 P7 U7 Z4 x; O
    17.     {3 A9 F0 T( h% R
    18.         System.out.println("job2 开始执行");
      - h$ q0 M! n# e7 f6 s4 f
    19.     }
      ( o0 x# u/ x# ^. U& C- i* Y
    20. }
      & s+ C- m$ b# B$ }+ H
    复制代码
    基于配置的实现spring-context.xml:
    , w' a( w# E- Z" A, |& p% Y
    1. <?xml version="1.0" encoding="UTF-8"?>
      9 h$ F* Q4 }& W: \1 h' F1 [9 }
    2. <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      ( K. u0 u8 ^. C4 l9 P7 Z+ V3 N- R' ~- t
    3.         xmlns:context="http://www.springframework.org/schema/context" xmlns:jdbc="http://www.springframework.org/schema/jdbc"  , }, U5 y$ @4 s! C! J
    4.         xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
      9 N: b( _8 R: h8 \) [1 I# p
    5.     xmlns:util="http://www.springframework.org/schema/util" xmlns:task="http://www.springframework.org/schema/task" xsi:schemaLocation="
      8 I. {2 E( g# \* _4 A' Z0 }; k2 m
    6.                 http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
      3 V, }3 w* K# W4 F+ {* y
    7.                 http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd2 o: t) d! Y1 p1 k
    8.                 http://www.springframework.org/schema/jdbc http://www.springframework.org/schema/jdbc/spring-jdbc-4.0.xsd& A1 G" E' Y; J7 d  B
    9.                 http://www.springframework.org/schema/jee http://www.springframework.org/schema/jee/spring-jee-4.0.xsd
      ! U2 |; p$ {$ f8 B
    10.                 http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd9 U$ J  u( J. c9 t% d/ [- U2 E
    11.                 http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd  D; {6 f5 K  B: ~4 V; _( W
    12.                 http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd">. k" g" k1 q0 r1 ], S: _7 b
    13. ( q# F# ~# c3 k1 x5 p
    14.         <description>Spring Configuration</description>* v1 f8 {7 G( s( [. k
    15.         / d" R' h7 W  D! A4 |% Z" U+ Y
    16.         <context:component-scan base-package="task"/>
      ! I( E8 Y6 W- u7 x4 N
    17.           O, G. r+ }! M2 S
    18.         <!-- 配置任务线性池 -->
      ; J6 Z3 ]  p1 L8 C+ w
    19.     <task:executor  id="executor" pool-size="10" />
      ! W8 r, K; f. ?" O8 T# h
    20.     <task:scheduler id="scheduler" pool-size="10"/>( E' A2 @# {1 K: r; D
    21.     <task:annotation-driven scheduler="scheduler" executor="executor" proxy-target-class="true"/>! i1 A$ F1 W! d% M4 a9 q' Q* u" W
    22.     <!-- 配置文件实现 如果使用配置文件实现 把注释解开即可然后 删除掉代码的注解-->. V$ h! H0 A0 q! ^/ H
    23.     <task:scheduled-tasks scheduler="scheduler">  
        G" M; F6 z1 m
    24.         <task:scheduled ref="TestJob" method="test1" cron="0/5 * * * * ?"/>  # C; B$ ^6 f4 L! M9 X
    25.         <task:scheduled ref="TestJob" method="test2" cron="0/6 * * * * ?"/>  
      / H6 ?: @5 a2 M* {: m/ D
    26.     </task:scheduled-tasks>
      " ]  h% T% m1 @( K/ s& p2 y1 D4 R" t% x
    27. </beans>
    复制代码

    9 H: Q  `# U, z8 F  a8 }: e6 R/ B
    . w2 E3 V5 f" z! k5 z( B( }6 M
    附:
    cronExpression的配置说明
    字段   允许值   允许的特殊字符
    秒    0-59    , - * /
    分    0-59    , - * /
    小时    0-23    , - * /
    日期    1-31    , - * ? / L W C
    月份    1-12 或者 JAN-DEC    , - * /
    星期    1-7 或者 SUN-SAT    , - * ? / L C #
    年(可选)    留空, 1970-2099    , - * /
    - 区间  
    * 通配符  
    ? 你不想设置那个字段
    下面只例出几个式子

    . ~0 S7 @8 ^' c! g& _
    CRON表达式    含义
    "0 0 12 * * ?"    每天中午十二点触发
    "0 15 10 ? * *"    每天早上10:15触发
    "0 15 10 * * ?"    每天早上10:15触发
    "0 15 10 * * ? *"    每天早上10:15触发
    "0 15 10 * * ? 2005"    2005年的每天早上10:15触发
    "0 * 14 * * ?"    每天从下午2点开始到2点59分每分钟一次触发
    "0 0/5 14 * * ?"    每天从下午2点开始到2:55分结束每5分钟一次触发
    "0 0/5 14,18 * * ?"    每天的下午2点至2:55和6点至6点55分两个时间段内每5分钟一次触发
    "0 0-5 14 * * ?"    每天14:00至14:05每分钟一次触发
    "0 10,44 14 ? 3 WED"    三月的每周三的14:10和14:44触发
    "0 15 10 ? * MON-FRI"    每个周一、周二、周三、周四、周五的10:15触发
    SpringTask任务案例源码实现.txt (31 Bytes, 下载次数: 0, 售价: 1 IT币)

    * }5 \, Y: M# u! @8 D

    科帮网 1、本主题所有言论和图片纯属会员个人意见,与本社区立场无关
    2、本站所有主题由该帖子作者发表,该帖子作者与科帮网享有帖子相关版权
    3、其他单位或个人使用、转载或引用本文时必须同时征得该帖子作者和科帮网的同意
    4、帖子作者须承担一切因本文发表而直接或间接导致的民事或刑事法律责任
    5、本帖部分内容转载自其它媒体,但并不代表本站赞同其观点和对其真实性负责
    6、如本帖侵犯到任何版权问题,请立即告知本站,本站将及时予与删除并致以最深的歉意
    7、科帮网管理员和版主有权不事先通知发贴者而删除本文


    JAVA爱好者①群:JAVA爱好者① JAVA爱好者②群:JAVA爱好者② JAVA爱好者③ : JAVA爱好者③

    快速回复
    您需要登录后才可以回帖 登录 | 立即注册

       

    关闭

    站长推荐上一条 /1 下一条

    发布主题 快速回复 返回列表 联系我们 官方QQ群 科帮网手机客户端
    快速回复 返回顶部 返回列表