码迷，mamicode.com
首页 > 编程语言 > 详细

spring定时任务

时间：2017-10-29 13:48:58      阅读：198      评论：0      收藏：0      [点我收藏+]

标签：key   自动任务   uri   local   attr   location   span   ref   exe   

Spring内部有一个task是Spring自带的一个设定时间自动任务调度

task使用的时候很方便，但是他能做的东西不如quartz那么的多！

可以使用注解和配置两种方式，配置的方式如下 

引入Spring放在appcation.xml开头

 
  1. <beans xmlns="http://www.springframework.org/schema/beans"  
  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  3.     xmlns:aop="http://www.springframework.org/schema/aop"  
  4.     xmlns:context="http://www.springframework.org/schema/context"  
  5.     xmlns:task="http://www.springframework.org/schema/task"  
  6.     xsi:schemaLocation="  
  7.         http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd  
  8.         http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd  
  9.         http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd  
  10.         http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd"  
  11.     default-lazy-init="true">  


<!--  注册bean  -->

  1. <bean id="voiceFileClearJob" class="com.zjr.modules.boss.job.VoiceFileClearJob" />  
  2. <bean id="versionListenJob" class="com.zjr.modules.boss.job.VersionListenJob" />  
  3. <bean id="statJob" class="com.zjr.modules.opstat.job.StatJob" />  

<!--  开启任务调度  -->

  1. <task:scheduled-tasks>  
  2.     <task:scheduled ref="voiceFileClearJob" method="execute" initial-delay="5000" fixed-delay="3600000"/>  
  3.     <task:scheduled ref="versionListenJob" method="execute" initial-delay="5000" fixed-delay="5000"/>  
  4.     <task:scheduled ref="statJob" method="statLgj" cron="0 59 23 * * ?"/>  
  5.     <task:scheduled ref="statJob" method="statBadNameAndQQ" cron="23 28 20 * * ?"/>  
  6. </task:scheduled-tasks>   

第一个任务表示程序启动5s后调用voiceFileClearJob类中的execute方法，然后每隔一个小时再调用execute一次

第三个任务表示每天的23点59分调用statJob类中的statLgj方法

 

ref是工作类

method是工作类中要执行的方法

initial-delay是任务第一次被调用前的延时，单位毫秒

fixed-delay是上一个调用完成后再次调用的延时

fixed-rate是上一个调用开始后再次调用的延时（不用等待上一次调用完成）

cron是表达式，表示在什么时候进行任务调度。

 

以下为上述versionListenJob类的代码，实现的功能是监控某个文件夹，如果该文件夹里面的内容有任何改动，就重新生成一个txt文件，文件记录的是该文件夹所有文件的相关信息。 

  1. package com.zjr.modules.boss.job;  
  2.   
  3. import ...  
  4.   
  5. public class VersionListenJob {  
  6.   
  7.     Logger logger = LoggerFactory.getLogger(VersionListenJob.class);  
  8.   
  9.     private static final String GMBOSS_DIR = "/data/jweb_static/jweb_wb_mgmt_beta/gmboss/";  
  10.     private static final String GMBOSS_VERSION_TXT_FILE = "/data/jweb_static/jweb_wb_mgmt_beta/txt/version.txt";  
  11.     private static final String DOWNLOAD_URL = "http://beta.wbmgmt.youzijie.com/gmboss/";  
  12.   
  13.     private Map<String, String> versionInfoMap = new HashMap<>();  
  14.     private File dir = new File(GMBOSS_DIR);  
  15.     private File versionTxt = new File(GMBOSS_VERSION_TXT_FILE);  
  16.   
  17.     public VersionListenJob() {  
  18.         try {  
  19.             init();  
  20.         } catch (IOException e) {  
  21.             logger.error("error occurs during VersionListenJob", e);  
  22.         }  
  23.     }  
  24.   
  25.     private void init() throws IOException {  
  26.   
  27.         if (!versionTxt.exists())  
  28.             versionTxt.createNewFile();  
  29.   
  30.         for (String line : FileUtils.readLines(versionTxt)) {  
  31.             String[] array = StringUtils.split(line, "|");  
  32.             if (array.length == 5)  
  33.                 versionInfoMap.put(array[0], array[4]);  
  34.         }  
  35.     }  
  36.   
  37.     public void execute() throws IOException {  
  38.   
  39.         if (EnvironmentUtil.isLocal() || !dir.exists() || !dir.isDirectory()) {  
  40.             return;  
  41.         }  
  42.   
  43.         //是否有文件更新  
  44.         Boolean needUpdate = false;  
  45.         List<File> allFiles = getFiles(dir.getAbsolutePath());  
  46.   
  47.         for (File file : allFiles) {  
  48.             String filePath = file.getPath();  
  49.             long lastModifiedTime = file.lastModified();  
  50.             if (!StringUtils.equals(lastModifiedTime + "", versionInfoMap.get(filePath))) {  
  51.                 needUpdate = true;  
  52.                 break;  
  53.             }  
  54.         }  
  55.   
  56.         if (needUpdate) {  
  57.             List<String> list = new ArrayList<>();  
  58.             for (File file : allFiles) {  
  59.                 list.add(file.getAbsolutePath().replace(GMBOSS_DIR,"/") + "|"  
  60.                         + md5(file) + "|"  
  61.                         + file.getPath().replace(GMBOSS_DIR,DOWNLOAD_URL) + "|"  
  62.                         + file.length() + "|"  
  63.                         + file.lastModified());  
  64.             }  
  65.             FileUtils.writeLines(versionTxt,"UTF-8", list, IOUtils.LINE_SEPARATOR_WINDOWS,false);  
  66.             logger.info("VersionListenJob: Gmboss has been updated");  
  67.         }  
  68.     }  
  69.   
  70.     //递归获取目录下的所有文件列表  
  71.     public List<File> getFiles(String filePath) throws IOException {  
  72.   
  73.         List<File> allFiles = new ArrayList<>();  
  74.   
  75.         File root = new File(filePath);  
  76.         File files[] = root.listFiles();  
  77.         if (files != null && files.length != 0) {  
  78.             for (File file : files) {  
  79.                 if (file.isDirectory()) {  
  80.                     allFiles.addAll(getFiles(file.getAbsolutePath()));  
  81.                 } else {  
  82.                     allFiles.add(file);  
  83.                 }  
  84.             }  
  85.         }  
  86.         return allFiles;  
  87.     }  
  88.   
  89.     public String md5(File f) {  
  90.         MessageDigest md = null;  
  91.         try {  
  92.             md = MessageDigest.getInstance("MD5");  
  93.         } catch (NoSuchAlgorithmException ne) {  
  94.             ne.printStackTrace();  
  95.         }  
  96.         if (md == null)  
  97.             return null;  
  98.         FileInputStream fis = null;  
  99.         try {  
  100.             fis = new FileInputStream(f);  
  101.             byte[] buffer = new byte[8192];  
  102.             int length;  
  103.             while ((length = fis.read(buffer)) != -1) {  
  104.                 md.update(buffer, 0, length);  
  105.             }  
  106.             return new String(Hex.encodeHex(md.digest())).toUpperCase();  
  107.         } catch (Exception e) {  
  108.             logger.error("error occurs during md5 file", e);  
  109.             return null;  
  110.         } finally {  
  111.             try {  
  112.                 if (fis != null)  
  113.                     fis.close();  
  114.             } catch (IOException e) {  
  115.                 logger.error("error occurs during md5 file", e);  
  116.             }  
  117.         }  
  118.     }  
  119. }  

cron表达式：

一个cron表达式有至少6个（也可能7个）有空格分隔的时间元素。
按顺序依次为 
秒（0~59） 
分钟（0~59）
小时（0~23）
天（月）（0~31，但是你需要考虑你月的天数）
月（0~11）
天（星期）（1~7 1=SUN 或 SUN，MON，TUE，WED，THU，FRI，SAT）
年份（1970－2099）


其中每个元素可以是一个值(如6),一个连续区间(9-12),一个间隔时间(8-18/4)(/表示每隔4小时),一个列表(1,3,5),通配符。由于"月份中的日期"和"星期中的日期"这两个元素互斥的,必须要对其中一个设置?.

0 0 10,14,16 * * ? 每天上午10点，下午2点，4点
0 0/30 9-17 * * ?   朝九晚五工作时间内每半小时
0 0 12 ? * WED 表示每个星期三中午12点 
"0 0 12 * * ?" 每天中午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期间的每1分钟触发 
"0 0/5 14 * * ?" 在每天下午2点到下午2:55期间的每5分钟触发 
"0 0/5 14,18 * * ?" 在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发 
"0 0-5 14 * * ?" 在每天下午2点到下午2:05期间的每1分钟触发 
"0 10,44 14 ? 3 WED" 每年三月的星期三的下午2:10和2:44触发 
"0 15 10 ? * MON-FRI" 周一至周五的上午10:15触发 
"0 15 10 15 * ?" 每月15日上午10:15触发 
"0 15 10 L * ?" 每月最后一日的上午10:15触发 
"0 15 10 ? * 6L" 每月的最后一个星期五上午10:15触发 
"0 15 10 ? * 6L 2002-2005" 2002年至2005年的每月的最后一个星期五上午10:15触发 
"0 15 10 ? * 6#3" 每月的第三个星期五上午10:15触发

有些子表达式能包含一些范围或列表

例如：子表达式（天（星期） ）可以为 “MON-FRI”，“MON，WED，FRI”，“MON-WED,SAT”

“*”字符代表所有可能的值

因此，“*”在子表达式（月 ）里表示每个月的含义，“*”在子表达式（天（星期） ）表示星期的每一天
“/”字符用来指定数值的增量

例如：在子表达式（分钟）里的“0/15”表示从第0分钟开始，每15分钟

         在子表达式（分钟）里的“3/20”表示从第3分钟开始，每20分钟（它和“3，23，43”）的含义一样

“？”字符仅被用于天（月）和天（星期）两个子表达式，表示不指定值

当2个子表达式其中之一被指定了值以后，为了避免冲突，需要将另一个子表达式的值设为“？”

“L” 字符仅被用于天（月）和天（星期）两个子表达式，它是单词“last”的缩写


但是它在两个子表达式里的含义是不同的。


在天（月）子表达式中，“L”表示一个月的最后一天


在天（星期）自表达式中，“L”表示一个星期的最后一天，也就是SAT


如果在“L”前有具体的内容，它就具有其他的含义了


例如：“6L”表示这个月的倒数第６天，“ＦＲＩＬ”表示这个月的最一个星期五


注意：在使用“L”参数时，不要指定列表或范围，因为这会导致问题

 

字段 允许值 允许的特殊字符

秒 		  
0-59 		  
, - * / 

分 		  
0-59 		  
, - * / 

小时 		  
0-23 		  
, - * / 

日期 		  
1-31 		  
, - * ? / L W C 

月份 		  
1-12 或者 JAN-DEC 		  
, - * / 

星期 		  
1-7 或者 SUN-SAT 		  
, - * ? / L C # 

年（可选） 		  
留空, 1970-2099 		  
, - * / 

spring定时任务

标签：key   自动任务   uri   local   attr   location   span   ref   exe   

原文地址：http://www.cnblogs.com/nzhbk/p/7749700.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！