詳解SpringBoot 創(chuàng)建定時任務(配合數(shù)據(jù)庫動態(tài)執(zhí)行)
序言:創(chuàng)建定時任務非常簡單,主要有兩種創(chuàng)建方式:一、基于注解(@Scheduled) 二、基于接口(SchedulingConfigurer). 前者相信大家都很熟悉,但是實際使用中我們往往想從數(shù)據(jù)庫中讀取指定時間來動態(tài)執(zhí)行定時任務,這時候基于接口的定時任務就大派用場了。
一、靜態(tài)定時任務(基于注解)
基于注解來創(chuàng)建定時任務非常簡單,只需幾行代碼便可完成。
@Scheduled 除了支持靈活的參數(shù)表達式cron之外,還支持簡單的延時操作,例如 fixedDelay ,fixedRate 填寫相應的毫秒數(shù)即可。
@Configuration //1.主要用于標記配置類,兼?zhèn)銫omponent的效果。 @EnableScheduling // 2.開啟定時任務 public class SimpleScheduleConfig { //3.添加定時任務 @Scheduled(cron = "0/5 * * * * ?") private void configureTasks() { System.err.println("執(zhí)行定時任務1: " + LocalDateTime.now()); } }
Cron表達式參數(shù)分別表示:
秒(0~59) 例如0/5表示每5秒
分(0~59)
時(0~23)
月的某天(0~31) 需計算
月(0~11)
周幾( 可填1-7 或 SUN/MON/TUE/WED/THU/FRI/SAT)
啟動應用,可以看到控制臺的信息如下:
誠然,使用Scheduled 確實很方便,但缺點是當我們調(diào)整了執(zhí)行周期的時候,需要重啟應用才能生效,這多少有些不方便。為了達到實時生效的效果,可以使用接口來完成定時任務。
二、動態(tài)定時任務(基于接口)
為了演示效果,這里選用 Mysql數(shù)據(jù)庫 和 Mybatis 來查詢和調(diào)整定時任務的執(zhí)行周期,然后觀察定時任務的執(zhí)行情況。
1.引入依賴
<!--依賴管理 --> <dependencies> <dependency><!--添加Web依賴 --> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency><!--添加Mybatis依賴 --> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.1</version> </dependency> <dependency><!--添加MySql依賴 --> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> <dependency><!--添加Test依賴 --> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies>
2.添加數(shù)據(jù)庫記錄
在Navicat 連接本地數(shù)據(jù)庫,隨便打開查詢窗口,然后執(zhí)行腳本內(nèi)容,如下:
DROP DATABASE IF EXISTS `socks`; CREATE DATABASE `socks`; USE `SOCKS`; DROP TABLE IF EXISTS `cron`; CREATE TABLE `cron` ( `cron_id` varchar(30), `cron` varchar(30) ); INSERT INTO `cron` VALUES ('1', '0/5 * * * * ?');
然后在項目中的application.yml 添加數(shù)據(jù)源:
#application.yml 配置如下:
spring: datasource: url: jdbc:mysql://localhost:3306/socks?useSSL=false username: root password: root
3.創(chuàng)建定時器
數(shù)據(jù)庫準備好數(shù)據(jù)之后,我們編寫定時任務,注意這里添加的是TriggerTask,目的是循環(huán)讀取我們在數(shù)據(jù)庫設置好的執(zhí)行周期,以及執(zhí)行相關定時任務的內(nèi)容。具體代碼如下:
@Configuration @EnableScheduling public class CompleteScheduleConfig implements SchedulingConfigurer { @Mapper public interface CronMapper { @Select("select cron from cron limit 1") String getCron(); } @Autowired @SuppressWarnings("all") CronMapper cronMapper; /** * 執(zhí)行定時任務. */ @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.addTriggerTask( //1.添加任務內(nèi)容(Runnable) () -> System.out.println("執(zhí)行定時任務2: " + LocalDateTime.now().toLocalTime()), //2.設置執(zhí)行周期(Trigger) triggerContext -> { //2.1 從數(shù)據(jù)庫獲取執(zhí)行周期 String cron = cronMapper.getCron(); //2.2 合法性校驗. if (StringUtils.isEmpty(cron)) { // Omitted Code .. } //2.3 返回執(zhí)行周期(Date) return new CronTrigger(cron).nextExecutionTime(triggerContext); } ); } }
4. 動態(tài)修改執(zhí)行周期
啟動應用后,查看控制臺,打印時間是我們預期的每5秒一次:
這時候打開Navicat ,將執(zhí)行周期修改為每1秒執(zhí)行一次,然后觀察控制臺打印效果:
可以清楚看到執(zhí)行周期已經(jīng)改變,并且不需要我們重啟應用,十分方便。
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關文章
解決Mybatis返回update后影響的行數(shù)問題
這篇文章主要介紹了解決Mybatis返回update后影響的行數(shù)問題,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-11-11關于@ApiModel和@ApiModelProperty的使用
這篇文章主要介紹了關于@ApiModel和@ApiModelProperty的使用方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2023-11-11Java獲取HttpServletRequest的三種方法詳解
這篇文章主要介紹了Java獲取HttpServletRequest的三種方法詳解,是一個接口,全限定名稱為Jakarta.Serclet.http.HttpServletRequest2023-11-11
HttpServletRequest接口是Servlet規(guī)范的一員,需要的朋友可以參考下Java使用Request獲取請求參數(shù)的通用方式詳解
這篇文章主要給大家介紹了關于Java使用Request獲取請求參數(shù)的通用方式,在Java后端開發(fā)中第一步就是獲取前端傳過來的請求參數(shù),文中通過代碼介紹的非常詳細,需要的朋友可以參考下2024-01-01