Springquartz的配置方式详解

@Component
public class MyTask {
    @Scheduled(cron = "0 * * * * ?") // 每分钟执行
    public void doSomething() {
        System.out.println("执行定时任务...");
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:task="http://www.springframework.org/schema/task"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
                           http://www.springframework.org/schema/beans/spring-beans.xsd
                           http://www.springframework.org/schema/task
                           http://www.springframework.org/schema/task/spring-task.xsd">
    <task:annotation-driven />
    <bean id="myTask" class="com.example.MyTask" />
    <bean id="quartzScheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="jobDetails">
            <list>
                <ref bean="myTask" />
            </list>
        </property>
        <property name="triggers">
            <list>
                <bean class="org.quartz.SimpleTriggerBean">
                    <property name="jobDetail" ref="myTask" />
                    <property name="startDelay" value="1000" />
                    <property name="repeatInterval" value="60000" />
                </bean>
            </list>
        </property>
    </bean>
</beans>

@Configuration
public class QuartzConfig {
    @Bean
    public Scheduler scheduler() {
        SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
        // 设置 JobDetail
        JobDetail job = JobBuilder.newJob(MyTask.class)
                .withIdentity("myTask", "group1")
                .build();
        schedulerFactoryBean.setJobDetails(Arrays.asList(job));
        // 设置 Trigger
        Trigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("myTaskTrigger", "group1")
                .startNow()
                .withSchedule(CronScheduleBuilder.cronSchedule("0 * * * * ?"))
                .build();
        schedulerFactoryBean.setTriggers(Arrays.asList(trigger在实际的Java应用中，Spring Quartz通常与Spring框架一起使用，以实现定时任务的调度和管理。以下是一个简单的Spring Quartz配置示例，展示了如何在Spring应用中配置Quartz调度器。
首先，你需要在你的Spring应用中添加Quartz的依赖。如果你使用的是Maven，可以在pom.xml中添加以下依赖：
```xml
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-context</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jdbc</artifactId>
</dependency>
<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz</artifactId>
    <version>2.3.2</version><!-- 或者你正在使用的版本 -->
</dependency>

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class QuartzConfig {
    @Bean
    public SchedulerFactoryBean schedulerFactoryBean() throws SchedulerException {
        SchedulerFactoryBean factoryBean = new SchedulerFactoryBean();
        // 设置Quartz数据源，这里假设使用的是JDBC数据源
        factoryBean.setDataSource(yourDataSource);
        // 设置Quartz的表前缀，如果需要自定义表名
        factoryBean.setTablePrefix("QRTZ_");
        // 设置Quartz的调度器实现类
        factoryBean.setSchedulerClass("org.quartz.impl.StdSchedulerFactory");
        // 设置Quartz的线程池
        factoryBean.setThreadPoolSize(10);
        // 设置Quartz的作业和触发器工厂类
        factoryBean.setJobFactory(jobFactory());
        // 设置Quartz的触发器
        factoryBean.setTriggers(trigger());
        // 设置Quartz的调度器启动
        factoryBean.setStartupDelay(1000); // 设置调度器启动延迟
        factoryBean.setAutoStartup(true); // 设置调度器自动启动
        return factoryBean;
    }
    @Bean
    public JobFactory jobFactory() {
        // 返回一个JobFactory的实例，用于创建Job实例
        return new SimpleJobFactory();
    }
    @Bean
    public JobDetail jobDetail() {
        // 创建一个JobDetail对象，用于定义Job的执行信息
        return new JobDetail("yourJobName", SimpleJob.class);
    }
    @Bean
    public Trigger trigger() {
        // 创建一个Trigger对象，用于定义触发Job执行的条件
        SimpleTrigger trigger = new SimpleTrigger("yourTriggerName", jobDetail());
        trigger.setStartDelay(1000); // 设置触发器启动延迟
        trigger.setRepeatInterval(1000); // 设置触发器重复间隔
        trigger.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY); // 设置触发器无限次重复
        return trigger;
    }
}

import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
public class QuartzSchedulerFactoryBean extends SchedulerFactoryBean {
    public QuartzSchedulerFactoryBean() {
        super();
        // 设置Quartz的工厂类，用于创建Quartz的Scheduler实例
        setSchedulerFactoryClass(StdSchedulerFactory.class);
    }
    // 重写父类的getScheduler方法，以处理可能出现的SchedulerException
    @Override
    public Scheduler getScheduler() throws SchedulerException {
        Scheduler scheduler = super.getScheduler();
        if (scheduler == null) {
            throw new SchedulerException("Unable to obtain Quartz Scheduler");
        }
        return scheduler;
    }
}

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class MyQuartzJob implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // 在这里编写你的定时任务逻辑
        System.out.println("Quartz job executed!");
    }
}

import org.quartz.CronScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
public class MyQuartzTrigger {
    public static Trigger getCronTrigger(String cronExpression) {
        // 使用CronScheduleBuilder来构建CronTrigger
        return TriggerBuilder.newTrigger()
                .withSchedule(CronScheduleBuilder.cronSchedule(cronExpression))
                .build();
    }
}

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:task="http://www.springframework.org/schema/task"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
                           http://www.springframework.org/schema/beans/spring-beans.xsd
                           http://www.springframework.org/schema/context
                           http://www.springframework.org/schema/context/spring-context.xsd
                           http://www.springframework.org/schema/task
                           http://www.springframework.org/schema/task/spring-task.xsd">