springboot实现动态定定时任务

Spring Boot提供了一个内置的调度器——Spring Task，可以轻松地实现动态定时任务。下面是一个简单的示例：

1. 添加依赖

在`pom.xml`中添加以下依赖：

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

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

2. 创建定时任务类

创建一个继承`QuartzJobBean`的定时任务类，例如：

public class DemoTask extends QuartzJobBean {

    private static final Logger LOGGER = LoggerFactory.getLogger(DemoTask.class);

    @Override
    protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        LOGGER.info("DemoTask is running...");
    }
}

3. 配置定时任务

在`application.properties`中添加以下配置：

spring.quartz.job-store-type=jdbc
spring.datasource.url=jdbc:mysql://localhost:3306/springboot_demo?useUnicode=true&characterEncoding=utf8&useSSL=false&serverTimezone=GMT%2B8
spring.datasource.username=root
spring.datasource.password=root

demoTask.cron=0/5 * * * * ?

其中，`spring.quartz.job-store-type`指定任务存储方式为JDBC，`spring.datasource`指定数据库连接信息，`demoTask.cron`指定定时任务的cron表达式。

4. 创建定时任务管理类

创建一个定时任务管理类，用于添加、删除、修改定时任务，例如：

@Service
public class TaskService {

    @Autowired
    private Scheduler scheduler;

    /**
     * 添加定时任务
     *
     * @param taskName 任务名称
     * @param taskGroup 任务分组
     * @param cronExpression cron表达式
     * @throws Exception
     */
    public void addTask(String taskName, String taskGroup, String cronExpression) throws Exception {
        JobDetail jobDetail = JobBuilder.newJob(DemoTask.class).withIdentity(taskName, taskGroup).build();
        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
        CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(taskName, taskGroup).withSchedule(scheduleBuilder).build();
        scheduler.scheduleJob(jobDetail, cronTrigger);
    }

    /**
     * 删除定时任务
     *
     * @param taskName 任务名称
     * @param taskGroup 任务分组
     * @throws Exception
     */
    public void deleteTask(String taskName, String taskGroup) throws Exception {
        TriggerKey triggerKey = TriggerKey.triggerKey(taskName, taskGroup);
        scheduler.pauseTrigger(triggerKey);
        scheduler.unscheduleJob(triggerKey);
        JobKey jobKey = JobKey.jobKey(taskName, taskGroup);
        scheduler.deleteJob(jobKey);
    }

    /**
     * 修改定时任务
     *
     * @param taskName 任务名称
     * @param taskGroup 任务分组
     * @param cronExpression cron表达式
     * @throws Exception
     */
    public void modifyTask(String taskName, String taskGroup, String cronExpression) throws Exception {
        TriggerKey triggerKey = TriggerKey.triggerKey(taskName, taskGroup);
        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
        CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(taskName, taskGroup).withSchedule(scheduleBuilder).build();
        scheduler.rescheduleJob(triggerKey, cronTrigger);
    }
}

5. 测试定时任务

在Controller中注入`TaskService`，调用`addTask`方法添加定时任务，例如：

@RestController
public class DemoController {

    @Autowired
    private TaskService taskService;

    @GetMapping("/addTask")
    public String addTask() throws Exception {
        taskService.addTask("demoTask", "demoTaskGroup", "0/10 * * * * ?");
        return "success";
    }
}

访问`http://localhost:8080/addTask`，即可添加一个每隔10秒执行一次的定时任务。

以上就是一个简单的动态定时任务的实现，可以根据业务需求进行扩展。