SpringBoot动态定时任务

SpringBoot提供了一个非常方便的方式来实现动态定时任务。具体实现步骤如下：

1. 首先需要在pom.xml文件中添加相关依赖：

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

2. 创建一个Job类，实现Quartz的Job接口，并在其中实现自己的业务逻辑。

public class MyJob implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // 业务逻辑代码
    }
}

3. 创建一个Trigger类，用于设置任务的触发器。

public class MyTrigger {
    /**
     * 创建一个cron表达式触发器
     * @param cronExpression cron表达式
     * @return 触发器对象
     */
    public static Trigger createCronTrigger(String cronExpression) {
        return TriggerBuilder.newTrigger().withSchedule(CronScheduleBuilder.cronSchedule(cronExpression)).build();
    }
}

4. 创建一个Scheduler类，用于管理定时任务的启停和修改。

@Component
public class MyScheduler {

    @Autowired
    private SchedulerFactory schedulerFactory;

    /**
     * 添加一个定时任务
     * @param jobName 任务名
     * @param jobGroupName 任务分组名
     * @param triggerName 触发器名
     * @param triggerGroupName 触发器分组名
     * @param jobClass 任务类
     * @param cronExpression cron表达式
     * @throws SchedulerException
     */
    public void addJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName,
                       Class<? extends Job> jobClass, String cronExpression) throws SchedulerException {
        Scheduler scheduler = schedulerFactory.getScheduler();
        JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build();
        Trigger trigger = MyTrigger.createCronTrigger(cronExpression);
        trigger = trigger.getTriggerBuilder().withIdentity(triggerName, triggerGroupName).build();
        scheduler.scheduleJob(jobDetail, trigger);
        if(!scheduler.isShutdown()) {
            scheduler.start();
        }
    }

    /**
     * 修改一个定时任务
     * @param jobName 任务名
     * @param jobGroupName 任务分组名
     * @param triggerName 触发器名
     * @param triggerGroupName 触发器分组名
     * @param cronExpression cron表达式
     * @throws SchedulerException
     */
    public void modifyJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName,
                          String cronExpression) throws SchedulerException {
        Scheduler scheduler = schedulerFactory.getScheduler();
        TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName);
        CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
        if(trigger == null) {
            return;
        }
        String oldCronExpression = trigger.getCronExpression();
        if(!oldCronExpression.equalsIgnoreCase(cronExpression)) {
            trigger = MyTrigger.createCronTrigger(cronExpression);
            trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).build();
            scheduler.rescheduleJob(triggerKey, trigger);
        }
    }

    /**
     * 删除一个定时任务
     * @param jobName 任务名
     * @param jobGroupName 任务分组名
     * @param triggerName 触发器名
     * @param triggerGroupName 触发器分组名
     * @throws SchedulerException
     */
    public void deleteJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName)
            throws SchedulerException {
        Scheduler scheduler = schedulerFactory.getScheduler();
        TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName);
        JobKey jobKey = JobKey.jobKey(jobName, jobGroupName);
        scheduler.pauseTrigger(triggerKey);
        scheduler.unscheduleJob(triggerKey);
        scheduler.deleteJob(jobKey);
    }
}

5. 在需要动态添加、修改、删除定时任务的地方，注入MyScheduler类，并调用其相应的方法即可。

@Autowired
private MyScheduler myScheduler;

// 添加一个定时任务
myScheduler.addJob("job1", "group1", "trigger1", "group1", MyJob.class, "0/5 * * * * ?");

// 修改一个定时任务
myScheduler.modifyJob("job1", "group1", "trigger1", "group1", "0/10 * * * * ?");

// 删除一个定时任务
myScheduler.deleteJob("job1", "group1", "trigger1", "group1");

以上就是SpringBoot动态定时任务的实现方式。