Spring Boot 实现定时任务动态管理

在Spring Boot中，可以使用@Scheduled注解来创建定时任务，但这种方式不支持动态管理定时任务。要实现定时任务的动态管理，你可以使用ScheduledTaskRegistrar来注册和注销定时任务。

以下是一个简单的例子，展示如何在Spring Boot中动态添加和移除定时任务：

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.CronTrigger;
 
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
 
@Configuration
@EnableScheduling
public class DynamicScheduleConfig implements SchedulingConfigurer {
 
    private final ConcurrentMap<String, Runnable> schedules = new ConcurrentHashMap<>();
 
    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(Executors.newScheduledThreadPool(5));
        schedules.forEach(taskRegistrar::schedule);
    }
 
    public void addTask(String taskId, Runnable task, String cronExpression) {
        schedules.put(taskId, task);
        triggerTask(taskId, cronExpression);
    }
 
    public void removeTask(String taskId) {
        Runnable task = schedules.remove(taskId);
        if (task != null) {
            // 停止任务的执行
        }
    }
 
    public void triggerTask(String taskId, String cronExpression) {
        ScheduledTaskRegistrar registrar = new ScheduledTaskRegistrar();
        Runnable task = schedules.get(taskId);
        if (task != null) {
            CronTrigger trigger = new CronTrigger(cronExpression);
            registrar.addTriggerTask(task, trigger);
        }
        // 重新配置ScheduledTaskRegistrar以应用更改
    }
}

在这个例子中，我们使用了ConcurrentHashMap来存储定时任务，并且提供了添加、移除和触发定时任务的方法。configureTasks方法会在应用启动时加载所有任务，而addTask方法可以动态添加新的任务，removeTask方法可以移除任务，triggerTask方法可以改变任务的触发规则。

请注意，这个例子没有完全实现停止已经执行的任务的逻辑，实际应用中你需要管理正在执行的任务并相应地停止它们。同时，这个例子使用了Executors.newScheduledThreadPool来创建一个新的线程池，你可能需要根据实际情况来管理线程池的生命周期。