Spring Boot實(shí)現(xiàn)動(dòng)態(tài)更新任務(wù)的方法
前言
SpringBoot 實(shí)現(xiàn)動(dòng)態(tài) Job，可以通過 API 動(dòng)態(tài)變更 cron。
原生的 Job 實(shí)現(xiàn)起來很簡單，只要用注解 @Scheduled(cron=xxxxxx) 來實(shí)現(xiàn)就可以了，但是要實(shí)現(xiàn)動(dòng)態(tài)更改 cron ，就需要做點(diǎn)其他的了。
實(shí)現(xiàn)方法
在 pom.xml 中添加 quartz-scheduler
<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.2.3</version> </dependency>
在 application.yml 中增加 cron ，默認(rèn)一秒鐘執(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) {
// 定時(shí)任務(wù)觸發(fā)，可修改定時(shí)任務(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 注解
這樣，運(yùn)行 Application.java 就會(huì)每隔一秒執(zhí)行 Job 了。
如果要實(shí)現(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();
}
}
}
寫到這里，其實(shí)還沒有實(shí)現(xiàn)動(dòng)態(tài)更改 cron 表達(dá)式。
接下來我們可以通過 api 來動(dòng)態(tài)更改。
在我們的 Controller 中，增加一個(gè)方法
@PostMapping(value = "/cron")
public String changeDynamicCron(String cron) {
userDynamicJob.setCron(cron);
return "Success";
}
這樣，通過調(diào)用 localhost:8080/corn?corn=0/10 * * * * ?
就可以實(shí)現(xiàn)每 10 秒執(zhí)行一次了。
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家學(xué)習(xí)或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。
相關(guān)文章
這篇文章主要介紹了Java8 CompletableFuture詳解,CompletableFuture extends Future提供了方法，一元操作符和促進(jìn)異步性以及事件驅(qū)動(dòng)編程模型,需要的朋友可以參考下2014-06-06
下面小編就為大家?guī)硪黄贘ava中的數(shù)值和集合詳解。小編覺得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-07-07
這篇文章主要介紹了Java打包及上傳到私服務(wù)的方法,本文給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友參考下吧2024-01-01
這篇文章主要介紹了Java如何讀取XML文件 具體實(shí)現(xiàn)，有需要的朋友可以參考一下2013-12-12
這篇文章主要介紹了Spring?Security自定義失敗處理器問題,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-08-08
Java通過SSLEngine與NIO實(shí)現(xiàn)HTTPS訪問的操作方法
這篇文章主要介紹了Java通過SSLEngine與NIO實(shí)現(xiàn)HTTPS訪問,需要在Connect操作、Connected操作、Read和Write操作中加入SSL相關(guān)的處理即可，需要的朋友可以參考下2021-08-08
Elasticsearch Join字段類型簡單快速上手教程
這篇文章主要為大家介紹了Elasticsearch Join字段類型簡單快速上手教程詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-09-09
MyBatisPlus 主鍵策略的實(shí)現(xiàn)(4種)
MyBatis Plus 集成了多種主鍵策略,幫助用戶快速生成主鍵,本文主要介紹了MyBatisPlus主鍵策略的實(shí)現(xiàn),具有一定的參考價(jià)值,感興趣的可以了解一下2023-10-10
本文主要介紹了Springboot中的@Order如何使用，文中通過示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-02-02
在Java中,Stream（流）是一種用于操作集合（Collection）、數(shù)組等數(shù)據(jù)源的API,Stream的主要作用是進(jìn)行數(shù)據(jù)的轉(zhuǎn)換、篩選、聚合等操作,可以極大地簡化對數(shù)據(jù)的處理,本文給大家介紹Java中stream是什么？有什么作用？如何使用？感興趣的朋友一起看看吧2023-10-10