溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

Spring Boot實(shí)現(xiàn)動(dòng)態(tài)更新任務(wù)的方法

發(fā)布時(shí)間：2020-09-10 05:46:39 來源：腳本之家 閱讀：395 作者：huanxi 欄目：編程語言

前言

SpringBoot 實(shí)現(xiàn)動(dòng)態(tài) Job，可以通過 API 動(dòng)態(tài)變更 cron。

原生的 Job 實(shí)現(xiàn)起來很簡(jiǎ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é)

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家學(xué)習(xí)或者工作能帶來一定的幫助，如果有疑問大家可以留言交流，謝謝大家對(duì)億速云的支持。

向AI問一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手