知識庫 / Spring RSS 訂閱

@Bean
public SimpleTriggerFactoryBean trigger(JobDetail job) {
    SimpleTriggerFactoryBean trigger = new SimpleTriggerFactoryBean();
    trigger.setJobDetail(job);
    trigger.setRepeatInterval(3600000);
    trigger.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
    return trigger;
}

4. 配置 JobStoreJobStore 提供 Job 和 Trigger 的存儲機制。它還負責維護與作業調度器相關的所有數據。API 支持內存存儲和持久化存儲。

4.1. 內存式 JobStore

對於我們的示例，我們將使用內存式 RAMJobStore，它提供極快的性能以及通過 quartz.properties 簡單的配置：

org.quartz.jobStore.class=org.quartz.simpl.RAMJobStore

使用 RAMJobStore 的明顯缺點是它具有易變性。所有調度信息在關機之間都會丟失。如果需要在關機後保留作業定義和調度，則可以使用持久的 JDBCJobStore。

要在 Spring 中啓用內存 JobStore，我們將設置以下屬性在我們的 application.properties 中：

spring.quartz.job-store-type=memory

4.2. JDBC JobStore

有兩類 JDBCJobStore：JobStoreTX 和 JobStoreCMT。它們都執行相同的功能，即在數據庫中存儲調度信息。

它們之間的區別在於如何管理用於提交數據的事務。 JobStoreCMT 類型需要應用程序事務來存儲數據，而 JobStoreTX 類型則會啓動和管理自己的事務。

對於 JDBCJobStore，有幾個屬性需要設置。 至少，我們必須指定 JDBCJobStore 的類型、數據源和數據庫驅動程序類。 對於大多數數據庫，都有驅動程序類，但 StdJDBCDelegate 覆蓋了大多數情況。

org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.dataSource=quartzDataSource

設置 Spring 中的 JDBC JobStore 需要幾個步驟。首先，我們在 application.properties 中設置存儲類型：

spring.quartz.job-store-type=jdbc

然後我們需要啓用自動配置，併為 Quartz 調度器提供所需的數據庫連接。<em @QuartzDataSource</em> 註解負責配置和初始化 Quartz 數據庫，從而簡化了整個過程：

@Configuration
@EnableAutoConfiguration
public class SpringQrtzScheduler {

    @Bean
    @QuartzDataSource
    public DataSource quartzDataSource() {
        return DataSourceBuilder.create().build();
    }
}

5. 調度器 (Scheduler)

調度器 (Scheduler) 接口是與作業調度器進行交互的主要 API。

可以通過調度器 (Scheduler) 工廠實例化調度器 (Scheduler)。 創建後，我們可以使用它註冊作業 (Job) 和觸發器 (Trigger)。 初始時，調度器 (Scheduler) 處於“待機”模式，必須調用其 start 方法 以啓動執行作業 (Job) 的線程。

@Bean
public Scheduler scheduler(Trigger trigger, JobDetail job, SchedulerFactoryBean factory) 
  throws SchedulerException {
    Scheduler scheduler = factory.getScheduler();
    scheduler.scheduleJob(job, trigger);
    scheduler.start();
    return scheduler;
}

@Bean
public SchedulerFactoryBean scheduler(Trigger trigger, JobDetail job, DataSource quartzDataSource) {
    SchedulerFactoryBean schedulerFactory = new SchedulerFactoryBean();
    schedulerFactory.setConfigLocation(new ClassPathResource("quartz.properties"));

    schedulerFactory.setJobFactory(springBeanJobFactory());
    schedulerFactory.setJobDetails(job);
    schedulerFactory.setTriggers(trigger);
    schedulerFactory.setDataSource(quartzDataSource);
    return schedulerFactory;
}

@Bean
public SpringBeanJobFactory springBeanJobFactory() {
    AutoWiringSpringBeanJobFactory jobFactory = new AutoWiringSpringBeanJobFactory();
    jobFactory.setApplicationContext(applicationContext);
    return jobFactory;
}

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

management.endpoints.web.exposure.include=quartz
management.endpoint.quartz.enabled=true

POST /actuator/quartz/jobs/{jobGroup}/{jobName}

curl -X POST "http://localhost:8080/actuator/quartz/jobs/DEFAULT/Qrtz_Job_Detail" \
     -H "Content-Type: application/json" \
     -d '{"state":"running"}'

{
    "group" : "DEFAULT",
    "name" : "Qrtz_Job_Detail",
    "className" : "org.baeldung.springquartz.basics.scheduler.SampleJob",
    "triggerTime" : "2025-05-31T10:36:36.474563900Z"
}