前言
讓客戶滿意是我們工作的目標(biāo)，不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶，將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價值的長期合作伙伴，公司提供的服務(wù)項目有：域名申請、網(wǎng)頁空間、營銷軟件、網(wǎng)站建設(shè)、煙臺網(wǎng)站維護、網(wǎng)站推廣。
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
org.quartz-scheduler quartz 2.2.3
在 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) {
// 定時任務(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 params = new HashMap<>();
try {
User user = userService.selectOne(params);
System.out.println(user);
} catch (DataNotFoundException e) {
e.printStackTrace();
}
}
} 寫到這里，其實還沒有實現(xiàn)動態(tài)更改 cron 表達(dá)式。
接下來我們可以通過 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í)或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對創(chuàng)新互聯(lián)的支持。
