springboot定时任务
使用SpringBoot創建定時任務非常簡單,目前主要有以下三種創建方式:
一、基于注解(@Scheduled)
二、基于接口(SchedulingConfigurer) 前者相信大家都很熟悉,但是實際使用中我們往往想從數據庫中讀取指定時間來動態執行定時任務,這時候基于接口的定時任務就派上用場了。
三、基于注解設定多線程定時任務
一、靜態:基于注解
基于注解@Scheduled默認為單線程,開啟多個任務時,任務的執行時機會受上一個任務執行時間的影響。
1、創建定時器
使用SpringBoot基于注解來創建定時任務非常簡單,只需幾行代碼便可完成。 代碼如下:
Cron表達式參數分別表示:
秒(0~59) 例如0/5表示每5秒
分(0~59)
時(0~23)
日(0~31)的某天,需計算
月(0~11)
周幾( 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT)
@Scheduled:除了支持靈活的參數表達式cron之外,還支持簡單的延時操作,例如 fixedDelay ,fixedRate 填寫相應的毫秒數即可。
2、啟動測試
啟動應用,可以看到控制臺打印出如下信息:
顯然,使用@Scheduled 注解很方便,但缺點是當我們調整了執行周期的時候,需要重啟應用才能生效,這多少有些不方便。為了達到實時生效的效果,可以使用接口來完成定時任務。
二、動態:基于接口
基于接口(SchedulingConfigurer)
1、導入依賴包:
<parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId><version>2.0.4.RELEASE</version></parent><dependencies><dependency><!--添加Web依賴 --><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><!--添加MySql依賴 --><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId></dependency><dependency><!--添加Mybatis依賴 配置mybatis的一些初始化的東西--><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>1.3.1</version></dependency><dependency><!-- 添加mybatis依賴 --><groupId>org.mybatis</groupId><artifactId>mybatis</artifactId><version>3.4.5</version><scope>compile</scope></dependency></dependencies>2、添加數據庫記錄:
開啟本地數據庫mysql,隨便打開查詢窗口,然后執行腳本內容,如下:
然后在項目中的application.yml 添加數據源:
3、創建定時器
數據庫準備好數據之后,我們編寫定時任務,注意這里添加的是TriggerTask,目的是循環讀取我們在數據庫設置好的執行周期,以及執行相關定時任務的內容。
具體代碼如下:
4、啟動測試
啟動應用后,查看控制臺,打印時間是我們預期的每10秒一次:
然后打開Navicat ,將執行周期修改為每6秒執行一次,如圖:
查看控制臺,發現執行周期已經改變,并且不需要我們重啟應用,十分方便。如圖:
注意: 如果在數據庫修改時格式出現錯誤,則定時任務會停止,即使重新修改正確;此時只能重新啟動項目才能恢復。
三、多線程定時任務
基于注解設定多線程定時任務
1、創建多線程定時任務
//@Component注解用于對那些比較中立的類進行注釋; //相對與在持久層、業務層和控制層分別采用 @Repository、@Service 和 @Controller 對分層中的類進行注釋 @Component @EnableScheduling // 1.開啟定時任務 @EnableAsync // 2.開啟多線程 public class MultithreadScheduleTask {@Async@Scheduled(fixedDelay = 1000) //間隔1秒public void first() throws InterruptedException {System.out.println("第一個定時任務開始 : " + LocalDateTime.now().toLocalTime() + "\r\n線程 : " + Thread.currentThread().getName());System.out.println();Thread.sleep(1000 * 10);}@Async@Scheduled(fixedDelay = 2000)public void second() {System.out.println("第二個定時任務開始 : " + LocalDateTime.now().toLocalTime() + "\r\n線程 : " + Thread.currentThread().getName());System.out.println();}}2、啟動測試
啟動應用后,查看控制臺:
從控制臺可以看出,第一個定時任務和第二個定時任務互不影響;
并且,由于開啟了多線程,第一個任務的執行時間也不受其本身執行時間的限制,所以需要注意可能會出現重復操作導致數據異常。
總結
以上是生活随笔為你收集整理的springboot定时任务的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Python代码整洁之道勘误
- 下一篇: [渝粤教育] 淄博职业学院 市场营销 参