快捷導(dǎo)航

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

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

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

前言

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

配置文件

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

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

定時任務(wù)核心類

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

            // 能定義大于等于間隔59秒
            // 使用不同的觸發(fā)器，為設(shè)置循環(huán)時間的關(guān)鍵，區(qū)別于CronTrigger觸發(fā)器，
            // 該觸發(fā)器可隨意設(shè)置循環(huán)間隔時間，單位為毫秒
            long seconds = timer * 1000;  // 毫秒轉(zhuǎn)秒
            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";
    }

}

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

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

您可能感興趣的文章: