日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

springboot定时任务

發布時間:2023/12/10 编程问答 30 豆豆
生活随笔 收集整理的這篇文章主要介紹了 springboot定时任务 小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

使用SpringBoot創建定時任務非常簡單,目前主要有以下三種創建方式:

一、基于注解(@Scheduled)
二、基于接口(SchedulingConfigurer) 前者相信大家都很熟悉,但是實際使用中我們往往想從數據庫中讀取指定時間來動態執行定時任務,這時候基于接口的定時任務就派上用場了。
三、基于注解設定多線程定時任務
一、靜態:基于注解
基于注解@Scheduled默認為單線程,開啟多個任務時,任務的執行時機會受上一個任務執行時間的影響。
1、創建定時器
使用SpringBoot基于注解來創建定時任務非常簡單,只需幾行代碼便可完成。 代碼如下:

@Component @Configuration //1.主要用于標記配置類,兼備Component的效果。 @EnableScheduling // 2.開啟定時任務 public class SaticScheduleTask {//3.添加定時任務@Scheduled(cron = "0/5 * * * * ?")//或直接指定時間間隔,例如:5秒//@Scheduled(fixedRate=5000)private void configureTasks() {System.err.println("執行靜態定時任務時間: " + LocalDateTime.now());} }

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,隨便打開查詢窗口,然后執行腳本內容,如下:

DROP DATABASE IF EXISTS `socks`; CREATE DATABASE `socks`; USE `SOCKS`; DROP TABLE IF EXISTS `cron`; CREATE TABLE `cron` (`cron_id` varchar(30) NOT NULL PRIMARY KEY,`cron` varchar(30) NOT NULL ); INSERT INTO `cron` VALUES ('1', '0/5 * * * * ?');


然后在項目中的application.yml 添加數據源:

spring:datasource:url: jdbc:mysql://localhost:3306/socksusername: rootpassword: 123456

3、創建定時器
數據庫準備好數據之后,我們編寫定時任務,注意這里添加的是TriggerTask,目的是循環讀取我們在數據庫設置好的執行周期,以及執行相關定時任務的內容。
具體代碼如下:

@Component @Configuration //1.主要用于標記配置類,兼備Component的效果。 @EnableScheduling // 2.開啟定時任務 public class DynamicScheduleTask implements SchedulingConfigurer {@Mapperpublic interface CronMapper {@Select("select cron from cron limit 1")public String getCron();}@Autowired //注入mapper@SuppressWarnings("all")CronMapper cronMapper;/*** 執行定時任務.*/@Overridepublic void configureTasks(ScheduledTaskRegistrar taskRegistrar) {taskRegistrar.addTriggerTask(//1.添加任務內容(Runnable)() -> System.out.println("執行動態定時任務: " + LocalDateTime.now().toLocalTime()),//2.設置執行周期(Trigger)triggerContext -> {//2.1 從數據庫獲取執行周期String cron = cronMapper.getCron();//2.2 合法性校驗.if (StringUtils.isEmpty(cron)) {// Omitted Code ..}//2.3 返回執行周期(Date)return new CronTrigger(cron).nextExecutionTime(triggerContext);});}}

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定时任务的全部內容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯,歡迎將生活随笔推薦給好友。