Spring Boot實現(xiàn)動態(tài)更新任務(wù)的方法
前言
SpringBoot 實現(xiàn)動態(tài) Job，可以通過 API 動態(tài)變更 cron。
原生的 Job 實現(xiàn)起來很簡單，只要用注解 @Scheduled(cron=xxxxxx) 來實現(xiàn)就可以了，但是要實現(xiàn)動態(tài)更改 cron ，就需要做點其他的了。
實現(xiàn)方法
在 pom.xml 中添加 quartz-scheduler
<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.2.3</version> </dependency>
在 application.yml 中增加 cron ，默認一秒鐘執(zhí)行一次
cron: pattern: 0/1 * * * * ?
創(chuàng)建 DynamicScheduledTask.java
public class DynamicScheduledTask implements SchedulingConfigurer {
@Value("${cron.pattern}")
public String pattern;
public void setCron(String cron) {
this.pattern = cron;
}
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.addTriggerTask(new Runnable() {
@Override
public void run() {
doBiz();
}
}, new Trigger() {
@Override
public Date nextExecutionTime(TriggerContext triggerContext) {
// 定時任務(wù)觸發(fā)，可修改定時任務(wù)的執(zhí)行周期
CronTrigger trigger = new CronTrigger(pattern);
Date nextExecDate = trigger.nextExecutionTime(triggerContext);
return nextExecDate;
}
});
}
public void doBiz() {
// do your biz
System.out.println("do biz...");
}
}
在 Application.java 中增加 @EnableScheduling 注解
這樣，運行 Application.java 就會每隔一秒執(zhí)行 Job 了。
如果要實現(xiàn)特定的邏輯，可以繼承 DynamicScheduledTask.java，重寫 doBiz() 方法。
UserDynamicJob.java
@Component
public class UserDynamicJob extends DynamicScheduledTask {
@Autowired
IUserService userService;
@Override
public void doBiz() {
Map<String, Object> params = new HashMap<>();
try {
User user = userService.selectOne(params);
System.out.println(user);
} catch (DataNotFoundException e) {
e.printStackTrace();
}
}
}
寫到這里，其實還沒有實現(xiàn)動態(tài)更改 cron 表達式。
接下來我們可以通過 api 來動態(tài)更改。
在我們的 Controller 中，增加一個方法
@PostMapping(value = "/cron")
public String changeDynamicCron(String cron) {
userDynamicJob.setCron(cron);
return "Success";
}
這樣，通過調(diào)用 localhost:8080/corn?corn=0/10 * * * * ?
就可以實現(xiàn)每 10 秒執(zhí)行一次了。
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家學(xué)習(xí)或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。
相關(guān)文章
本文主要介紹了mybatisplus駝峰命名映射的問題解決，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-07-07
對于JAVA學(xué)習(xí)，或多或少都會遇到這樣的問題：編碼基本知識，java，系統(tǒng)軟件，url，工具軟件等2014-10-10
Java調(diào)用SSE流式接口并流式返回給前端實現(xiàn)打字輸出效果
在Web開發(fā)中,有時我們需要將文件以流的形式返回給前端,下面這篇文章主要給大家介紹了關(guān)于Java調(diào)用SSE流式接口并流式返回給前端實現(xiàn)打字輸出效果的相關(guān)資料,需要的朋友可以參考下2024-08-08
文章主要介紹了Spring和Nacos對`@RefreshScope`注解的處理方式,Spring在每次調(diào)用被`@RefreshScope`注解的bean的屬性時,會先從本地緩存獲取,如果緩存不存在則重新創(chuàng)建并獲取最新環(huán)境配置2024-12-12
將List集合中的map對象轉(zhuǎn)為List<對象>形式實例代碼
這篇文章主要介紹了將List集合中的map對象轉(zhuǎn)為List<對象>形式實例代碼，具有一定借鑒價值,需要的朋友可以參考下2018-01-01
這篇文章主要介紹了SpringBoot SSMP 整合案例分享，文章圍繞主題展開詳細的內(nèi)容介紹，具有一定的參考價值，需要的小伙伴可以參考一下2022-08-08
java項目idea構(gòu)建總是報內(nèi)存溢出怎么解決詳析
這篇文章主要介紹了java項目idea構(gòu)建總是報內(nèi)存溢出怎么解決的相關(guān)資料,方法包括增加IDEA內(nèi)存分配、調(diào)整項目編譯設(shè)置、配置Gradle構(gòu)建內(nèi)存、優(yōu)化項目結(jié)構(gòu)、清理不必要的依賴、使用命令行構(gòu)建、更新IDEA和JDK、清理IDEA緩存和禁用不必要的插件,需要的朋友可以參考下2025-03-03
Java中stream.map和stream.forEach的區(qū)別
本文主要介紹了Java中stream.map和stream.forEach的區(qū)別，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-08-08
Spring自定義注解實現(xiàn)數(shù)據(jù)脫敏