詳解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 確實很方便,但缺點是當我們調整了執(zhí)行周期的時候,需要重啟應用才能生效,這多少有些不方便。為了達到實時生效的效果,可以使用接口來完成定時任務。
二、動態(tài)定時任務(基于接口)
為了演示效果,這里選用 Mysql數(shù)據(jù)庫 和 Mybatis 來查詢和調整定時任務的執(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í)行腳本內容,如下:
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í)行相關定時任務的內容。具體代碼如下:
@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.添加任務內容(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í)行周期已經改變,并且不需要我們重啟應用,十分方便。
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關文章
利用synchronized實現(xiàn)線程同步的案例講解
這篇文章主要介紹了利用synchronized實現(xiàn)線程同步的案例講解,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2021-02-02
一文詳解為什么用ElasticSearch以及和傳統(tǒng)數(shù)據(jù)庫MySQL有什么區(qū)別
Elasticsearch和MySQL都是非常重要的數(shù)據(jù)庫管理系統(tǒng),它們在各種應用場景中都有著廣泛的應用,這篇文章主要介紹了為什么用ElasticSearch以及和傳統(tǒng)數(shù)據(jù)庫MySQL有什么區(qū)別的相關資料,需要的朋友可以參考下2025-07-07
Java spring boot 實現(xiàn)支付寶支付功能的示例代碼
這篇文章主要介紹了Java spring boot 實現(xiàn)支付寶支付功能,本文通過實例代碼圖文相結合給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-06-06
java hasNextInt判斷是否為數(shù)字的方法
今天小編就為大家分享一篇java hasNextInt判斷是否為數(shù)字的方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧2018-07-07

