成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

SpringBoot定時任務及Cron表達式詳解

作者：珂jac
開發 后端
講解如何使用SpringBoot定時任務，并通過源碼說明如何使用多線程處理各定時任務。 詳細說明cron表達式用法。

SpringBoot定時任務及Cron表達式詳解

摘要: 講解如何使用SpringBoot定時任務，并通過源碼說明如何使用多線程處理各定時任務。 詳細說明cron表達式用法。

一、定時任務概述

后臺項目開發中經常會用到定時任務，現在實現定時任務都方式也是多種多樣。下面列舉幾種常見的定時任務實現方式：

1. Quartz：Quartz的使用相當廣泛，它是一個功能強大的調度器，當然使用起來也相對麻煩;

2. java.util包里的Timer，它也可以實現定時任務但是功能過于單一所有使用很少。

3. 就是我們今天要介紹的Spring自帶的定時任務Schedule，其實可以把它看作是一個簡化版的，輕量級的Quartz，使用起來也相對方便很多。

二、實現定時任務

1. 創建定時任務

  1. import org.slf4j.Logger; 
  2. import org.slf4j.LoggerFactory; 
  3. import org.springframework.scheduling.annotation.Scheduled; 
  4. import org.springframework.stereotype.Component; 
  5.  
  6. /** 
  7.  * Description: 構建執行定時任務 
  8.  * Designer: jack 
  9.  * Date: 2017/8/10 
  10.  * Version: 1.0.0 
  11.  */ 
  12. @Component 
  13. public class ScheduledTasks { 
  14.  
  15.     private Logger logger = LoggerFactory.getLogger(ScheduledTasks.class); 
  16.  
  17.     private int fixedDelayCount = 1; 
  18.     private int fixedRateCount = 1; 
  19.     private int initialDelayCount = 1; 
  20.     private int cronCount = 1; 
  21.  
  22.     @Scheduled(fixedDelay = 5000)        //fixedDelay = 5000表示當前方法執行完畢5000ms后，Spring scheduling會再次調用該方法 
  23.     public void testFixDelay() { 
  24.         logger.info("===fixedDelay: 第{}次執行方法", fixedDelayCount++); 
  25.     } 
  26.  
  27.     @Scheduled(fixedRate = 5000)        //fixedRate = 5000表示當前方法開始執行5000ms后，Spring scheduling會再次調用該方法 
  28.     public void testFixedRate() { 
  29.         logger.info("===fixedRate: 第{}次執行方法", fixedRateCount++); 
  30.     } 
  31.  
  32.     @Scheduled(initialDelay = 1000, fixedRate = 5000)   //initialDelay = 1000表示延遲1000ms執行***次任務 
  33.     public void testInitialDelay() { 
  34.         logger.info("===initialDelay: 第{}次執行方法", initialDelayCount++); 
  35.     } 
  36.  
  37.     @Scheduled(cron = "0 0/1 * * * ?")  //cron接受cron表達式，根據cron表達式確定定時規則 
  38.     public void testCron() { 
  39.         logger.info("===initialDelay: 第{}次執行方法", cronCount++); 
  40.     } 
  41.  
  42. }  

我們使用@Scheduled來創建定時任務 這個注解用來標注一個定時任務方法。通過看@Scheduled源碼可以看出它支持多種參數：

(1)cron：cron表達式，指定任務在特定時間執行;

(2)fixedDelay：表示上一次任務執行完成后多久再次執行，參數類型為long，單位ms;

(3)fixedDelayString：與fixedDelay含義一樣，只是參數類型變為String;

(4)fixedRate：表示按一定的頻率執行任務，參數類型為long，單位ms;

(5)fixedRateString: 與fixedRate的含義一樣，只是將參數類型變為String;

(6)initialDelay：表示延遲多久再***次執行任務，參數類型為long，單位ms;

(7)initialDelayString：與initialDelay的含義一樣，只是將參數類型變為String;

(8)zone：時區，默認為當前時區，一般沒有用到。

2.開啟定時任務

  1. import org.springframework.boot.SpringApplication; 
  2. import org.springframework.boot.autoconfigure.SpringBootApplication; 
  3. import org.springframework.scheduling.annotation.EnableScheduling; 
  4.  
  5. /** 
  6.  * Description: 啟動類 
  7.  * Designer: jack 
  8.  * Date: 2017/8/10 
  9.  * Version: 1.0.0 
  10.  */ 
  11. @SpringBootApplication 
  12. @EnableScheduling 
  13. public class Application { 
  14.     public static void main(String[] args) { 
  15.         SpringApplication.run(Application.class, args); 
  16.     } 
  17. }  

注意這里的 @EnableScheduling 注解，它的作用是發現注解@Scheduled的任務并由后臺執行。沒有它的話將無法執行定時任務。

引用官方文檔原文：

@EnableScheduling ensures that a background task executor is created. Without it, nothing gets scheduled.

3. 執行結果 (單線程)

到此我們就完成了一個簡單的定時任務模型，下面執行springBoot觀察執行結果。

  1. 2017-08-11 12:06:19.738  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===initialDelay: 第1次執行方法 
  2. 2017-08-11 12:06:23.739  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedRate: 第2次執行方法 
  3. 2017-08-11 12:06:23.739  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedDelay: 第2次執行方法 
  4. 2017-08-11 12:06:24.738  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===initialDelay: 第2次執行方法 
  5. 2017-08-11 12:06:28.739  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedRate: 第3次執行方法 
  6. 2017-08-11 12:06:28.740  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedDelay: 第3次執行方法 
  7. 2017-08-11 12:06:29.739  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===initialDelay: 第3次執行方法 
  8. 2017-08-11 12:06:33.735  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedRate: 第4次執行方法 
  9. 2017-08-11 12:06:33.741  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedDelay: 第4次執行方法 
  10. 2017-08-11 12:06:34.738  INFO 52252 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===initialDelay: 第4次執行方法  

從控制臺輸入的結果中我們可以看出所有的定時任務都是在同一個線程池用同一個線程來處理的，那么我們如何來并發的處理各定時任務呢，請繼續向下看。

4. 多線程處理定時任務

看到控制臺輸出的結果，所有的定時任務都是通過一個線程來處理的，我估計是在定時任務的配置中設定了一個SingleThreadScheduledExecutor，于是我看了源碼，從ScheduledAnnotationBeanPostProcessor類開始一路找下去。果然，在ScheduledTaskRegistrar(定時任務注冊類)中的ScheduleTasks中又這樣一段判斷：

  1. if (this.taskScheduler == null) { 
  2.             this.localExecutor = Executors.newSingleThreadScheduledExecutor(); 
  3.             this.taskScheduler = new ConcurrentTaskScheduler(this.localExecutor); 
  4.         }  

這就說明如果taskScheduler為空，那么就給定時任務做了一個單線程的線程池，正好在這個類中還有一個設置taskScheduler的方法：

  1. public void setScheduler(Object scheduler) { 
  2.         Assert.notNull(scheduler, "Scheduler object must not be null"); 
  3.         if (scheduler instanceof TaskScheduler) { 
  4.             this.taskScheduler = (TaskScheduler) scheduler; 
  5.         } 
  6.         else if (scheduler instanceof ScheduledExecutorService) { 
  7.             this.taskScheduler = new ConcurrentTaskScheduler(((ScheduledExecutorService) scheduler)); 
  8.         } 
  9.         else { 
  10.             throw new IllegalArgumentException("Unsupported scheduler type: " + scheduler.getClass()); 
  11.         } 
  12.     }  

這樣問題就很簡單了，我們只需用調用這個方法顯式的設置一個ScheduledExecutorService就可以達到并發的效果了。我們要做的僅僅是實現SchedulingConfigurer接口，重寫configureTasks方法就OK了;

  1. import org.springframework.context.annotation.Configuration; 
  2. import org.springframework.scheduling.annotation.SchedulingConfigurer; 
  3. import org.springframework.scheduling.config.ScheduledTaskRegistrar; 
  4.  
  5. import java.util.concurrent.Executors; 
  6.  
  7. /** 
  8.  * Description: 多線程執行定時任務 
  9.  * Designer: jack 
  10.  * Date: 2017/8/10 
  11.  * Version: 1.0.0 
  12.  */ 
  13. @Configuration 
  14. //所有的定時任務都放在一個線程池中，定時任務啟動時使用不同都線程。 
  15. public class ScheduleConfig implements SchedulingConfigurer { 
  16.     @Override 
  17.     public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { 
  18.         //設定一個長度10的定時任務線程池 
  19.         taskRegistrar.setScheduler(Executors.newScheduledThreadPool(10)); 
  20.     } 
  21. }  

注: 最開始我試圖在ScheduledAnnotationBeanPostProcessor類中做文章，因為里面也有一個類似的方法setScheduler()，但是***失敗了，不知道是否可以通過這個類實現定時任務的并發，如果有實現了的也請告訴大家一下方法。

5. 執行結果(并發)

  1. 2017-08-11 12:21:16.000  INFO 52284 --- [pool-1-thread-3] com.test.ScheduledTasks                  : ===initialDelay: 第1次執行方法 
  2. 2017-08-11 12:21:19.998  INFO 52284 --- [pool-1-thread-4] com.test.ScheduledTasks                  : ===fixedRate: 第2次執行方法 
  3. 2017-08-11 12:21:19.998  INFO 52284 --- [pool-1-thread-1] com.test.ScheduledTasks                  : ===fixedDelay: 第2次執行方法 
  4. 2017-08-11 12:21:20.999  INFO 52284 --- [pool-1-thread-4] com.test.ScheduledTasks                  : ===initialDelay: 第2次執行方法 
  5. 2017-08-11 12:21:25.000  INFO 52284 --- [pool-1-thread-2] com.test.ScheduledTasks                  : ===fixedRate: 第3次執行方法 
  6. 2017-08-11 12:21:25.000  INFO 52284 --- [pool-1-thread-6] com.test.ScheduledTasks                  : ===fixedDelay: 第3次執行方法 
  7. 2017-08-11 12:21:25.997  INFO 52284 --- [pool-1-thread-3] com.test.ScheduledTasks                  : ===initialDelay: 第3次執行方法 
  8. 2017-08-11 12:21:30.000  INFO 52284 --- [pool-1-thread-7] com.test.ScheduledTasks                  : ===fixedRate: 第4次執行方法 
  9. 2017-08-11 12:21:30.000  INFO 52284 --- [pool-1-thread-8] com.test.ScheduledTasks                  : ===fixedDelay: 第4次執行方法 
  10. 2017-08-11 12:21:31.000  INFO 52284 --- [pool-1-thread-7] com.test.ScheduledTasks                  : ===initialDelay: 第4次執行方法  

通過控制臺輸出的結果看出每個定時任務都是在通過不同的線程來處理了。

三、cron詳解

1. cron表達式定義

Cron表達式是一個字符串，是由空格隔開的6或7個域組成，每一個域對應一個含義(秒 分 時 每月第幾天 月 星期 年)其中年是可選字段。

但是，此處敲一下黑板，spring的schedule值支持6個域的表達式，也就是不能設定年，如果超過六個則會報錯。源碼如下：

  1. /** 
  2.      * Parse the given pattern expression. 
  3.      */ 
  4.     private void parse(String expression) throws IllegalArgumentException { 
  5.         String[] fields = StringUtils.tokenizeToStringArray(expression, " "); 
  6.         if (!areValidCronFields(fields)) { 
  7.             throw new IllegalArgumentException(String.format( 
  8.                     "Cron expression must consist of 6 fields (found %d in \"%s\")", fields.length, expression)); 
  9.         } 
  10.         setNumberHits(this.seconds, fields[0], 0, 60); 
  11.         setNumberHits(this.minutes, fields[1], 0, 60); 
  12.         setNumberHits(this.hours, fields[2], 0, 24); 
  13.         setDaysOfMonth(this.daysOfMonth, fields[3]); 
  14.         setMonths(this.months, fields[4]); 
  15.         setDays(this.daysOfWeek, replaceOrdinals(fields[5], "SUN,MON,TUE,WED,THU,FRI,SAT"), 8); 
  16.         if (this.daysOfWeek.get(7)) { 
  17.             // Sunday can be represented as 0 or 7 
  18.             this.daysOfWeek.set(0); 
  19.             this.daysOfWeek.clear(7); 
  20.         } 
  21.     } 
  22.  
  23.     private static boolean areValidCronFields(String[] fields) { 
  24.         return (fields != null && fields.length == 6); 
  25.     }  

2. 每個域可出現的字符類型和各字符的含義

(1)各域支持的字符類型

秒：可出現", - * /"四個字符，有效范圍為0-59的整數

分：可出現", - * /"四個字符，有效范圍為0-59的整數

時：可出現", - * /"四個字符，有效范圍為0-23的整數

每月第幾天：可出現", - * / ? L W C"八個字符，有效范圍為0-31的整數

月：可出現", - * /"四個字符，有效范圍為1-12的整數或JAN-DEc

星期：可出現", - * / ? L C #"四個字符，有效范圍為1-7的整數或SUN-SAT兩個范圍。1表示星期天，2表示星期一， 依次類推

(2)特殊字符含義

* : 表示匹配該域的任意值，比如在秒*, 就表示每秒都會觸發事件。;

? : 只能用在每月第幾天和星期兩個域。表示不指定值，當2個子表達式其中之一被指定了值以后，為了避免沖突，需要將另一個子表達式的值設為“?”;

- : 表示范圍，例如在分域使用5-20，表示從5分到20分鐘每分鐘觸發一次

/ : 表示起始時間開始觸發，然后每隔固定時間觸發一次，例如在分域使用5/20,則意味著5分，25分，45分，分別觸發一次.

, : 表示列出枚舉值。例如：在分域使用5,20，則意味著在5和20分時觸發一次。

L : 表示***，只能出現在星期和每月第幾天域，如果在星期域使用1L,意味著在***的一個星期日觸發。

W : 表示有效工作日(周一到周五),只能出現在每月第幾日域，系統將在離指定日期的最近的有效工作日觸發事件。注意一點，W的最近尋找不會跨過月份

LW : 這兩個字符可以連用，表示在某個月***一個工作日，即***一個星期五。

# : 用于確定每個月第幾個星期幾，只能出現在每月第幾天域。例如在1#3，表示某月的第三個星期日。

(3)表達式例子

引用spring官方注釋：

* <p>Example patterns:

* <ul>

* <li>"0 0 * * * *" = the top of every hour of every day.</li>

* <li>"*/10 * * * * *" = every ten seconds.</li>

* <li>"0 0 8-10 * * *" = 8, 9 and 10 o'clock of every day.</li>

* <li>"0 0/30 8-10 * * *" = 8:00, 8:30, 9:00, 9:30 and 10 o'clock every day.</li>

* <li>"0 0 9-17 * * MON-FRI" = on the hour nine-to-five weekdays</li>

* <li>"0 0 0 25 12 ?" = every Christmas Day at midnight</li>

"0 0 * * * *" 表示每小時0分0秒執行一次

" */10 * * * * *" 表示每10秒執行一次

"0 0 8-10 * * *" 表示每天8，9，10點執行

"0 0/30 8-10 * * *" 表示每天8點到10點，每半小時執行

"0 0 9-17 * * MON-FRI" 表示每周一至周五，9點到17點的0分0秒執行

"0 0 0 25 12 ?" 表示每年圣誕節(12月25日)0時0分0秒執行 

責任編輯：龐桂玉 來源： 珂jack的博客
JavaSpringBoot定時任務
相關推薦

2024-05-13 09:49:30

.NETQuartz庫Cron表達式

2025-04-21 02:20:00

2024-02-29 07:28:44

Cron表達式解析庫

2010-01-07 13:38:41

Linux定時任務

2022-08-15 15:43:29

Linuxcron

2024-02-02 12:41:33

表達式語法Cron

2024-06-03 00:00:01

表達式PythonJava

2020-12-21 07:31:23

實現單機JDK

2024-12-27 08:24:55

2025-04-27 08:01:25

2022-11-11 14:55:14

Linuxcron

2022-06-07 07:43:44

HealthchecCronPython

2024-03-13 14:40:35

SpringCron表達式

2009-08-27 09:13:28

LINQ查詢表達式

2009-08-07 15:41:39

C#正規表達式

2009-09-16 18:19:34

正則表達式組

2018-10-08 14:00:28

LinuxCron定時任務

2024-07-31 14:03:00

Spring定時任務管理

2009-09-16 16:22:04

正則表達式匹配

2009-09-16 17:29:30

正則表達式使用詳解
點贊
收藏

51CTO技術棧公眾號

主站蜘蛛池模板： 在线免费亚洲视频 | 国产一区不卡在线观看 | 国产精品久久久久无码av | 日韩影音 | 国产精品一区在线 | 91国内精精品久久久久久婷婷 | 一级片av| 成人免费看片 | 欧美福利一区 | 久久久www成人免费无遮挡大片 | 自拍偷拍亚洲一区 | 亚洲福利| 欧美乱码精品一区二区三区 | 日韩在线视频观看 | 中文字幕男人的天堂 | 久久成人人人人精品欧 | 国产精品久久久久久久免费大片 | 一级黄在线观看 | 欧美成人免费在线视频 | 天天操夜夜操 | 亚洲视频一区在线观看 | 久久久婷| 男女羞羞视频在线看 | 欧美日韩高清一区 | 国产成人精品一区二区三区网站观看 | 久久午夜视频 | 精品www | 国产91色在线 | 亚洲 | 国产精品视频一区二区三区四蜜臂 | 中文字幕一区二区三区四区五区 | 国产激情视频网址 | 久久一区二区三区四区五区 | 久久久精品一区二区三区 | 中文字幕亚洲精品在线观看 | 91精品国产91久久久久久吃药 | 国产一区二区三区色淫影院 | 91精品久久久久久久久 | 久久网一区二区 | 一区二区三区欧美在线 | 亚洲欧美国产精品久久 | 日本精品一区二区三区在线观看视频 |