Springboot quartz 动态

Spring Boot Quartz 是一个在 Spring Boot 应用程序中使用 Quartz 调度框架的库。它提供了一种简单的方式来配置和管理定时任务，允许您使用注释和配置文件轻松地定义定时任务。而动态的意思是可以在运行时动态地添加、修改或删除定时任务。

实现动态定时任务的关键是使用 Quartz 的 JobDetail 和 Trigger 接口。JobDetail 定义要执行的任务，Trigger 定义任务何时执行。在 Spring Boot Quartz 中，可以通过实现 Job 类来定义任务，通过配置文件或注释来定义 Trigger。

动态添加、修改或删除定时任务可以通过使用 SchedulerFactoryBean 和 CronTriggerFactoryBean 来实现。SchedulerFactoryBean 是 Quartz 的主要类，它负责创建和管理 Quartz Scheduler。CronTriggerFactoryBean 是一个工厂类，用于创建 CronTrigger 对象，可以在运行时动态地创建和修改 CronTrigger。

下面是一个简单的示例，演示如何使用 Spring Boot Quartz 实现动态定时任务：

1. 首先，需要在 pom.xml 文件中添加以下依赖：

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

2. 创建一个 Job 类：

@Component
public class MyJob implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        System.out.println("定时任务执行了");
    }
}

3. 创建一个 CronTrigger 对象：

@Bean
public CronTriggerFactoryBean myTrigger() {
    CronTriggerFactoryBean factoryBean = new CronTriggerFactoryBean();
    factoryBean.setJobDetail(myJobDetail().getObject());
    factoryBean.setCronExpression("0/5 * * * * ?");
    return factoryBean;
}

4. 创建一个 JobDetail 对象：

@Bean
public JobDetailFactoryBean myJobDetail() {
    JobDetailFactoryBean factoryBean = new JobDetailFactoryBean();
    factoryBean.setJobClass(MyJob.class);
    factoryBean.setDurability(true);
    return factoryBean;
}

5. 创建一个 SchedulerFactoryBean 对象：

@Bean
public SchedulerFactoryBean schedulerFactoryBean() {
    SchedulerFactoryBean factoryBean = new SchedulerFactoryBean();
    factoryBean.setTriggers(myTrigger().getObject());
    return factoryBean;
}

6. 最后，在需要添加、修改或删除任务的地方，可以使用以下代码：

@Autowired
private SchedulerFactoryBean schedulerFactoryBean;

public void addJob(String jobName, String groupName, String cronExpression) throws SchedulerException {
    JobDetail jobDetail = JobBuilder.newJob(MyJob.class).withIdentity(jobName, groupName).build();
    CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(jobName, groupName)
            .withSchedule(CronScheduleBuilder.cronSchedule(cronExpression)).build();
    Scheduler scheduler = schedulerFactoryBean.getScheduler();
    scheduler.scheduleJob(jobDetail, cronTrigger);
    scheduler.start();
}

public void modifyJob(String jobName, String groupName, String cronExpression) throws SchedulerException {
    TriggerKey triggerKey = new TriggerKey(jobName, groupName);
    CronTrigger cronTrigger = (CronTrigger) schedulerFactoryBean.getScheduler().getTrigger(triggerKey);
    cronTrigger = cronTrigger.getTriggerBuilder().withIdentity(triggerKey)
            .withSchedule(CronScheduleBuilder.cronSchedule(cronExpression)).build();
    schedulerFactoryBean.getScheduler().rescheduleJob(triggerKey, cronTrigger);
}

public void deleteJob(String jobName, String groupName) throws SchedulerException {
    JobKey jobKey = new JobKey(jobName, groupName);
    schedulerFactoryBean.getScheduler().deleteJob(jobKey);
}

以上代码演示了如何添加、修改和删除定时任务。通过调用相应的方法，可以在运行时动态地管理定时任务。