13-SpringBoot項目使用定時任務

1、常用定時器技術

• Timer：這是java自帶的java.util.Timer類，這個類允許你調度一個java.util.TimerTask任務。使用這種方式可以讓你的程序按照某一個頻度執行，但不能在指定時間運行。一般用的較少。
• ScheduledExecutorService：也jdk自帶的一個類；是基於線程池設計的定時任務類,每個調度任務都會分配到線程池中的一個線程去執行,也就是說,任務是並發執行,互不影響。
• Spring Task：Spring3.0以後自帶的task，可以將它看成一個輕量級的Quartz，而且使用起來比Quartz簡單許多。
• Quartz：這是一個功能比較強大的的調度器，可以讓你的程序在指定時間執行，也可以按照某一個頻度執行，配置起來稍顯複雜。

2、SpringBoot定時任務實現

在SpringBoot中使用定時任務，用到了兩個註解：

• @EnableScheduling 用來修飾類，表示啟動定時任務
• @Scheduled 具體定時任務

1）、創建任務類

@Component@EnableSchedulingpublic class TaskWork { }

2）、多種定時機制

• fixedRate：定義一個按一定頻率執行的定時任務
• fixedDelay：定義一個按一定頻率執行的定時任務，與上面不同的是，該屬性可以配合initialDelay， 定義該任務延遲執行時間。
• cron：通過表達式來配置任務執行時間

cron表達式：

一個cron表達式有至少6個（也可能7個）有空格分隔的時間元素。按順序依次為：

• 秒（0~59）
• 分鐘（0~59）
• 3 小時（0~23）
• 4 天（0~31）
• 5 月（0~11）
• 6 星期（1~7 1=SUN 或 SUN，MON，TUE，WED，THU，FRI，SAT）
• 年份（1970－2099）

其中每個元素可以是一個值(如6),一個連續區間(9-12),一個間隔時間(8-18/4)(/表示每隔4小時),一個列表(1,3,5),通配符。由於」月份中的日期」和」星期中的日期」這兩個元素互斥的,必須要對其中一個設置。

關於Cron表達式介紹

cronExpression定義時間規則，Cron表達式由6或7個空格分隔的時間欄位組成：秒 分鐘 小時 日期 月份 星期 年（可選）

欄位　　允許值　　允許的特殊字符 秒     　 0-59 　　　　, - * / 分     　 0-59　　　　 , - * / 小時      0-23 　　　　, - * / 日期      1-31 　　　　, - * ? / L W C 月份      1-12 　　　　, - * / 星期      1-7 　　　　  , - * ? / L C 3」 每月的第三個星期五上午10:15觸發

3）、實現定時任務

@Component@EnableSchedulingpublic class TaskWork { private int workCount = 0; /** * fixedRate 的單位是毫秒 */ @Scheduled(fixedRate = 1000) public void taskCounter() { workCount ++; System.out.println(&34; + workCount); } @Scheduled(cron = &34;) public void taskRun5() throws InterruptedException { Date dNow = new Date( ); SimpleDateFormat ft = new SimpleDateFormat(&34;); System.out.println(Thread.currentThread().getName()+&34;+ft.format(dNow)); }}

3、定時任務重入問題

當一個任務的處理超時時，由於每個任務是單線程的，所以對於定時任務而言，有可能會延遲下一個任務。

當出現這種情況，就需要使用多線程定時任務，可以是使用下面註解來實現：




• @EnableAsync
• @Async

具體代碼如下：

package com.shenmazong.bootdemotask.task;import lombok.extern.slf4j.Slf4j;import org.springframework.scheduling.annotation.Async;import org.springframework.scheduling.annotation.EnableAsync;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.Scheduled;import org.springframework.stereotype.Component;import java.util.Date;@Slf4j@Component@EnableScheduling // 1.開啟定時任務@EnableAsync // 2.開啟多線程public class WorkTask { /** * TODO 每秒鐘執行一次任務 */ @Async @Scheduled(fixedRate = 1000) public void fixRateTask() { String strDateTime = new Date().toString(); try { Thread.sleep(1000*30); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName()+&34;+strDateTime); } /** * TODO 每5秒執行一次任務 */ @Scheduled(cron = &34;) public void fixTimeTask() {// String strDateTime = new Date().toString();//// try {// Thread.sleep(1000*10);// } catch (InterruptedException e) {// e.printStackTrace();// }//// System.out.println(Thread.currentThread().getName()+&34;+strDateTime); }}