2. 程式人生 > >spring自動任務排程

spring自動任務排程

阿新 • • 發佈：2019-01-08

Spring內部有一個task是Spring自帶的一個設定時間自動任務排程

task使用的時候很方便，但是他能做的東西不如quartz那麼的多！

可以使用註解和配置兩種方式，配置的方式如下

引入Spring放在appcation.xml開頭

  1. <beansxmlns="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. <beanid="voiceFileClearJob"
    class="com.zjr.modules.boss.job.VoiceFileClearJob"/>
  2. <beanid="versionListenJob"class="com.zjr.modules.boss.job.VersionListenJob"/>
  3. <beanid="statJob"class="com.zjr.modules.opstat.job.StatJob"/>

<!--  開啟任務排程  -->

  1. <task:scheduled-tasks>
  2.     <task:scheduledref="voiceFileClearJob"method="execute"initial-delay="5000"fixed-delay="3600000"/>
  3.     <task:scheduledref="versionListenJob"method="execute"initial-delay="5000"fixed-delay="5000"/>
  4.     <task:scheduledref="statJob"method="statLgj"cron="0 59 23 * * ?"/>
  5.     <task:scheduledref="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. import ...  
  3. publicclass VersionListenJob {  
  4.     Logger logger = LoggerFactory.getLogger(VersionListenJob.class);  
  5.     privatestaticfinal String GMBOSS_DIR = "/data/jweb_static/jweb_wb_mgmt_beta/gmboss/";  
  6.     privatestaticfinal String GMBOSS_VERSION_TXT_FILE = "/data/jweb_static/jweb_wb_mgmt_beta/txt/version.txt";  
  7.     privatestaticfinal String DOWNLOAD_URL = "http://beta.wbmgmt.youzijie.com/gmboss/";  
  8.     private Map<String, String> versionInfoMap = new HashMap<>();  
  9.     private File dir = new File(GMBOSS_DIR);  
  10.     private File versionTxt = new File(GMBOSS_VERSION_TXT_FILE);  
  11.     public VersionListenJob() {  
  12.         try {  
  13.             init();  
  14.         } catch (IOException e) {  
  15.             logger.error("error occurs during VersionListenJob", e);  
  16.         }  
  17.     }  
  18.     privatevoid init() throws IOException {  
  19.         if (!versionTxt.exists())  
  20.             versionTxt.createNewFile();  
  21.         for (String line : FileUtils.readLines(versionTxt)) {  
  22.             String[] array = StringUtils.split(line, "|");  
  23.             if (array.length == 5)  
  24.                 versionInfoMap.put(array[0], array[4]);  
  25.         }  
  26.     }  
  27.     publicvoid execute() throws IOException {  
  28.         if (EnvironmentUtil.isLocal() || !dir.exists() || !dir.isDirectory()) {  
  29.             return;  
  30.         }  
  31.         //是否有檔案更新
  32.         Boolean needUpdate = false;  
  33.         List<File> allFiles = getFiles(dir.getAbsolutePath());  
  34.         for (File file : allFiles) {  
  35.             String filePath = file.getPath();  
  36.             long lastModifiedTime = file.lastModified();  
  37.             if (!StringUtils.equals(lastModifiedTime + "", versionInfoMap.get(filePath))) {  
  38.                 needUpdate = true;  
  39.                 break;  
  40.             }  
  41.         }  
  42.         if (needUpdate) {  
  43.             List<String> list = new ArrayList<>();  
  44.             for (File file : allFiles) {  
  45.                 list.add(file.getAbsolutePath().replace(GMBOSS_DIR,"/") + "|"
  46.                         + md5(file) + "|"
  47.                         + file.getPath().replace(GMBOSS_DIR,DOWNLOAD_URL) + "|"
  48.                         + file.length() + "|"
  49.                         + file.lastModified());  
  50.             }  
  51.             FileUtils.writeLines(versionTxt,"UTF-8", list, IOUtils.LINE_SEPARATOR_WINDOWS,false);  
  52.             logger.info("VersionListenJob: Gmboss has been updated");  
  53.         }  
  54.     }  
  55.     //遞迴獲取目錄下的所有檔案列表
  56.     public List<File> getFiles(String filePath) throws IOException {  
  57.         List<File> allFiles = new ArrayList<>();  
  58.         File root = new File(filePath);  
  59.         File files[] = root.listFiles();  
  60.         if (files != null && files.length != 0) {  
  61.             for (File file : files) {  
  62.                 if (file.isDirectory()) {  
  63.                     allFiles.addAll(getFiles(file.getAbsolutePath()));  
  64.                 } else {  
  65.                     allFiles.add(file);  
  66.                 }  
  67.             }  
  68.         }  
  69.         return allFiles;  
  70.     }  
  71.     public String md5(File f) {  
  72.         MessageDigest md = null;  
  73.         try {  
  74.             md = MessageDigest.getInstance("MD5");  
  75.         } catch (NoSuchAlgorithmException ne) {  
  76.             ne.printStackTrace();  
  77.         }  
  78.         if (md == null)  
  79.             returnnull;  
  80.         FileInputStream fis = null;  
  81.         try {  
  82.             fis = new FileInputStream(f);  
  83.             byte[] buffer = newbyte[8192];  
  84.             int length;  
  85.             while ((length = fis.read(buffer)) != -1) {  
  86.                 md.update(buffer, 0, length);  
  87.             }  
  88.             returnnew String(Hex.encodeHex(md.digest())).toUpperCase();  
  89.         } catch (Exception e) {  
  90.             logger.error("error occurs during md5 file", e);  
  91.             returnnull;  
  92.         } finally {  
  93.             try {  
  94.                 if (fis != null)  
  95.                     fis.close();  
  96.             } catch (IOException e) {  
  97.                 logger.error("error occurs during md5 file", e);  
  98.             }  
  99.         }  
  100.     }  
  101. }  
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自動任務排程

Spring內部有一個task是Spring自帶的一個設定時間自動任務排程 task使用的時候很方便，但是他能做的東西不如quartz那麼的多！ 可以使用註解和配置兩種方式，配置的方式如下 引入Spring放在appcation.xml開頭 <bean

spring定時任務排程quartz

1.maven依賴 <!-- 定時任務 --> <dependency> <groupId>quartz</groupId> <artifactId>quartz</artifactId> <v

Spring：任務排程之task:scheduler與task:executor配置的詳解

其實就是Spring定時器中配置檔案中一些配置資訊，由於筆者自己是頭一次使用，有些配置詳細不太明白，隨即研究了一番，於是想記錄一下，有需要的小夥伴可以參考，也方便日後自己查閱。 首先，建立一個僅僅包含定時器配置的Spring配置檔案：spring-timer.xml。以下均為配置資訊：1、在配置檔案

spring boot 任務排程

1.依賴檔案 檔名:pom.xml 檔案內容: <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0"      

spring task 任務排程 （定時任務）

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

轉:Spring中任務排程cronExpression配置說明

cronExpression配置說明 欄位 允許值 允許的特殊字元 秒 0-59 , - * / 分 0-59 , - * / 小時 0-23 , - * / 日期 1-31 , - * ? / L W C 月份

spring定時任務排程

本文將告訴你如何使用spring的任務排程。主要使用@Scheduled註解 需要會使用maven 第一步 pom.xml配置 <?xml version="1.0" encoding="UTF-8"?> <proje

Spring定時任務排程【含cron引數詳解】

spring內部有一個task是Spring自帶的一個設定時間自動任務排程task使用的時候很方便，但是他能做的東西不如quartz那麼的多！可以使用註解和配置兩種方式，配置的方式如下引入Spring放在appcation.xml開頭<beans xmlns="http

Quartz Job & Spring 動態任務排程

Quartz Job & Spring 在實際專案應用中經常會用到定時任務，可通過Quartz框架輕鬆完成。在Web專案中，如果用Spring框架管理Quartz，在Web容器啟動或關閉時自動啟動、關閉Quartz中的任務，非常方便。 傳統的Meth

自動任務排程 - Timer

一、概述： 最近維護一個老專案，裡面使用的是Timer的時間排程器，以前沒接觸過，對著程式碼鼓搗了半天，查閱了部分部落格，最後總結出自己的見解，新專案一般是不會用這種老掉牙的時間排程器了，但是維護老專案還是用的著的。就當筆記記錄一下了，自己寫的才是符合自己的思路走向的。有時間再補上Quartz排程器，這個才是

Spring整合quartz定時任務排程的cronExpression配置說明(轉載)

Spring整合quartz定時任務排程 "* * * * * *" 欄位   允許值   允許的特殊字元 秒   

Spring之——兩種任務排程Scheduled和Async

轉載請註明出處:http://blog.csdn.net/l1028386804/article/details/72494169 1、Spring排程的兩種方式 Spring提供了兩種後臺任務的方法,分別是:     排

Spring任務排程實戰之Quartz Simple Trigger

分享一下我老師大神的人工智慧教程！零基礎，通俗易懂！http://blog.csdn.net/jiangjunshow 也歡迎大家轉載本篇文章。分享知識，造福人民，實現我們中華民族偉大復興！        

Spring的定時任務（任務排程）兩種

Spring內部有一個task是Spring自帶的一個設定時間自動任務排程,提供了兩種方式進行配置，一種是註解的方式，而另外一種就是XML配置方式了。註解方式比較簡潔，XML配置方式相對而言有些繁瑣，但是應用場景的不同，兩者又各有優點，所以具體使用還是根據需求來劃分。因為任務排程這樣的需求，

Spring的業務層和Web層-----------任務排程

任務排程 　　quartz框架 　　quartz框架實現了Spring的任務排程，使用者可以隨意的定義觸發器排程時間表，並將觸發器和任務進行對映。quartz通過排程器、觸發器和任務實現任務排程。 　　Job：主要用來設計任務實現的邏輯，並且只有一個方法execute。 　　JobDetail：主要用

Spring的定時任務（任務排程）

一、XML配置方式 第1步、編寫類 /** * 定時計算 */ @Component("profitScheduler") public class ProfitScheduler { @Autowired private XXXService

Spring MVC自動任務配置

本文旨在整理個人工作總結，僅供參考 自動任務類QueryBankFromErp原始碼： import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Au

java計劃任務排程框架quartz結合spring實現排程的配置例項程式碼分享

                一：quartz簡介       OpenSymphony 的Quartz提供了一個比較完美的任務排程解決方案。       Quartz 是個開源的作業排程框架，定時排程器，為在 Java 應用程式中進行作業排程提供了簡單卻強大的機制。       Quartz中有兩個基本概

spring schedule + redisson實現分散式系統任務排程

Redisson是架設在Redis基礎上的一個Java駐記憶體資料網格（In-Memory Data Grid）。【Redis官方推薦】 適用場景 主要適用於以下幾種場景： 分散式應用，快取，分散式會話

spring任務執行器與任務排程器(TaskExecutor And TaskScheduler)

　　對於多執行緒及週期性排程相關的操作，spring框架提供了TaskExecutor和TaskScheduler介面為非同步執行和任務排程。並提供了相關實現類給開發者使用。(只記錄採用註解的使用形式，對於XML的使用形式不做筆記。)　　　　Spring官方對TaskExecutor的相關解釋:　　　　Spr