SpringBoot實現(xiàn)動態(tài)定時任務的示例代碼

更新時間：2022年10月25日 09:08:41 作者：野生java研究僧

在SpringBoot項目中簡單使用定時任務，不過由于要借助cron表達式且都提前定義好放在配置文件里，不能在項目運行中動態(tài)修改任務執(zhí)行時間，實在不太靈活?，F(xiàn)在我們就來實現(xiàn)可以動態(tài)修改cron表達式的定時任務,感興趣的可以了解一下

前言

之前在SpringBoot項目中簡單使用定時任務，不過由于要借助cron表達式且都提前定義好放在配置文件里，不能在項目運行中動態(tài)修改任務執(zhí)行時間，實在不太靈活?，F(xiàn)在我們就來實現(xiàn)可以動態(tài)修改cron表達式的定時任務。

配置文件

application-task.yml,其余的配置 application.yml 等就按照springBoot正常配置即可

task:
  cron: 0/10 * * * * ?
  timer: 10

定時任務核心類

import cn.hutool.core.date.DateUtil;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.PeriodicTrigger;

import java.util.Date;


@Data
@Slf4j
@Configuration
@EnableScheduling
@ConfigurationProperties(prefix = "task")
public class WorkScheduleTask  implements SchedulingConfigurer {

    private String cron;

    private Long timer;


    @Override

    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        // 動態(tài)使用cron表達式設置循環(huán)間隔
        taskRegistrar.addTriggerTask(() -> {
            String dateTime = DateUtil.formatDateTime(new Date());
            String threadName = Thread.currentThread().getName();
            log.info("定時任務開始[configureTasks] :{},線程:{}", dateTime, threadName);
        }, triggerContext -> {
            // 使用CronTrigger觸發(fā)器，可動態(tài)修改cron表達式來操作循環(huán)規(guī)則
            // 只能定義小于等于間隔59秒
//          CronTrigger cronTrigger = new CronTrigger(cron);
//          return cronTrigger.nextExecutionTime(triggerContext);

            // 能定義大于等于間隔59秒
            // 使用不同的觸發(fā)器，為設置循環(huán)時間的關鍵，區(qū)別于CronTrigger觸發(fā)器，
            // 該觸發(fā)器可隨意設置循環(huán)間隔時間，單位為毫秒
            long seconds = timer * 1000;  // 毫秒轉秒
            PeriodicTrigger periodicTrigger = new PeriodicTrigger(seconds);
            return periodicTrigger.nextExecutionTime(triggerContext);
        });
    }
}

提供修改cron表達式的controller

@Slf4j
@CrossOrigin
@RestController
@RequestMapping("/updateTask")
public class UpdateTaskController {

    @Resource
    private WorkScheduleTask workScheduleTask;

    @PostMapping("/updateCron")
    public String updateCron(String cron) {
        log.info("new cron :{}", cron);
        workScheduleTask.setCron(cron);
        return "ok";
    }

    @PostMapping("/updateTimer")
    public String updateTimer(Long timer) {
        log.info("new timer :{}", timer);
        workScheduleTask.setTimer(timer);
        return "ok";
    }

}

一開始定時任務的執(zhí)行時機和周期都是配置文件指定的，但是我們如果對于執(zhí)行的周期不滿意，我們可以調用接口進行修改定時任務，但是需要注意的是，這種外暴露的接最好做一下安全校驗，不是誰都可以調用，否則被別人掃描到這個接口，然后隨意修改，會影響我們正常的業(yè)務流程，嚴重可能會造成嚴重損失。

到此這篇關于SpringBoot實現(xiàn)動態(tài)定時任務的示例代碼的文章就介紹到這了,更多相關SpringBoot動態(tài)定時任務內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: