在Spring框架下配置Quartz集群的詳細步驟(MySQL數據源)
更新時間：2025年01月23日 09:16:47 作者：牛肉胡辣湯
Quartz 是一個功能強大的調度庫,可以在 Java 應用中用于執(zhí)行定時任務,本文將介紹如何在 Spring 框架下配置 Quartz 集群,并使用 MySQL 作為數據源來存儲調度信息,文中有詳細的代碼供大家參考,需要的朋友可以參考下
簡介
Quartz 是一個功能強大的調度庫，可以在 Java 應用中用于執(zhí)行定時任務。在單機環(huán)境中，Quartz 的配置和使用相對簡單，但在分布式系統中，為了確保任務的唯一性和高可用性，通常需要將 Quartz 配置為集群模式。本文將介紹如何在 Spring 框架下配置 Quartz 集群，并使用 MySQL 作為數據源來存儲調度信息。
環(huán)境準備
- Java 版本: 1.8 或更高
- Spring Boot 版本: 2.3.x
- Quartz 版本: 2.3.x
- 數據庫: MySQL 5.7 或更高
步驟一：添加依賴
首先，在 ??pom.xml?? 文件中添加 Spring Boot 和 Quartz 的依賴：
<dependencies>
<!-- Spring Boot Starter -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!-- Quartz Scheduler -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
<!-- MySQL Connector -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<!-- Spring Boot Starter Data JPA -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
</dependencies>步驟二：配置數據庫
在 ??application.properties?? 中配置數據庫連接：
spring.datasource.url=jdbc:mysql://localhost:3306/quartz?useSSL=false&serverTimezone=UTC spring.datasource.username=root spring.datasource.password=root spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver spring.jpa.hibernate.ddl-auto=update spring.jpa.show-sql=true
步驟三：創(chuàng)建 Quartz 表
Quartz 需要一些特定的表來存儲調度信息?？梢允褂?Quartz 提供的 SQL 腳本來創(chuàng)建這些表。對于 MySQL，可以使用 ??tables_mysql_innodb.sql?? 腳本。
將腳本中的 SQL 語句執(zhí)行到 MySQL 數據庫中：
-- 示例：創(chuàng)建 Quartz 表 CREATE TABLE QRTZ_JOB_DETAILS( SCHED_NAME VARCHAR(120) NOT NULL, JOB_NAME VARCHAR(200) NOT NULL, JOB_GROUP VARCHAR(200) NOT NULL, DESCRIPTION VARCHAR(250) NULL, JOB_CLASS_NAME VARCHAR(250) NOT NULL, IS_DURABLE VARCHAR(1) NOT NULL, IS_NONCONCURRENT VARCHAR(1) NOT NULL, IS_UPDATE_DATA VARCHAR(1) NOT NULL, REQUESTS_RECOVERY VARCHAR(1) NOT NULL, JOB_DATA BLOB NULL, PRIMARY KEY (SCHED_NAME,JOB_NAME,JOB_GROUP) ) ENGINE=InnoDB; -- 其他表創(chuàng)建語句...
步驟四：配置 Quartz 集群
在 ??application.properties?? 中配置 Quartz 以啟用集群模式：
# Quartz 配置 spring.quartz.job-store-type=jdbc spring.quartz.jdbc.initialize-schema=always spring.quartz.properties.org.quartz.scheduler.instanceName=ClusteredScheduler spring.quartz.properties.org.quartz.scheduler.instanceId=AUTO spring.quartz.properties.org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX spring.quartz.properties.org.quartz.jobStore.isClustered=true spring.quartz.properties.org.quartz.jobStore.clusterCheckinInterval=20000 spring.quartz.properties.org.quartz.jobStore.misfireThreshold=60000 spring.quartz.properties.org.quartz.jobStore.tablePrefix=QRTZ_
步驟五：創(chuàng)建任務
定義一個簡單的 Quartz 任務類：
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class SimpleJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
System.out.println("SimpleJob is running...");
}
}步驟六：配置任務調度
在 Spring 配置類中配置任務調度：
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.JobDetailFactoryBean;
import org.springframework.scheduling.quartz.SimpleTriggerFactoryBean;
@Configuration
public class QuartzConfig {
@Bean
public JobDetailFactoryBean jobDetail() {
JobDetailFactoryBean factoryBean = new JobDetailFactoryBean();
factoryBean.setJobClass(SimpleJob.class);
factoryBean.setDurability(true);
return factoryBean;
}
@Bean
public SimpleTriggerFactoryBean trigger(JobDetail jobDetail) {
SimpleTriggerFactoryBean factoryBean = new SimpleTriggerFactoryBean();
factoryBean.setJobDetail(jobDetail);
factoryBean.setRepeatInterval(10000); // 每10秒執(zhí)行一次
factoryBean.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
factoryBean.setStartDelay(0L);
factoryBean.setMisfireInstruction(SimpleTrigger.MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_REMAINING_COUNT);
return factoryBean;
}
}步驟七：啟動應用
啟動 Spring Boot 應用程序，Quartz 將自動在集群模式下運行，并且所有節(jié)點都會共享相同的調度信息。
Spring Quartz 是一個非常流行的調度框架，用于在Java應用程序中執(zhí)行定時任務。當使用Quartz與Spring框架結合時，可以通過配置MySQL作為數據源來實現集群化部署，從而確保高可用性和負載均衡。
下面是一個簡單的示例，展示如何在Spring Boot項目中配置和使用Spring Quartz集群（使用MySQL作為數據源）：
1. 添加依賴
首先，在??pom.xml??文件中添加Spring Boot、Quartz和MySQL的依賴：
<dependencies>
<!-- Spring Boot Starter -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!-- Spring Boot Starter Web -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Quartz Scheduler -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
<!-- MySQL Connector -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- HikariCP Connection Pool -->
<dependency>
<groupId>com.zaxxer</groupId>
<artifactId>HikariCP</artifactId>
</dependency>
</dependencies>2. 配置MySQL數據源
在??application.properties??或??application.yml??中配置MySQL數據源和Quartz的相關屬性：
# 數據源配置 spring.datasource.url=jdbc:mysql://localhost:3306/quartz_db?useSSL=false&serverTimezone=UTC spring.datasource.username=root spring.datasource.password=password spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver # HikariCP連接池配置 spring.datasource.hikari.pool-name=HikariCP spring.datasource.hikari.maximum-pool-size=10 # Quartz配置 spring.quartz.job-store-type=jdbc spring.quartz.properties.org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX spring.quartz.properties.org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate spring.quartz.properties.org.quartz.jobStore.tablePrefix=QRTZ_ spring.quartz.properties.org.quartz.jobStore.isClustered=true spring.quartz.properties.org.quartz.jobStore.clusterCheckinInterval=20000 spring.quartz.properties.org.quartz.scheduler.instanceName=ClusteredScheduler spring.quartz.properties.org.quartz.scheduler.instanceId=AUTO
3. 創(chuàng)建Quartz Job
創(chuàng)建一個簡單的Quartz Job類，該類實現了??Job??接口：
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class MyJob implements Job {
private static final Logger logger = LoggerFactory.getLogger(MyJob.class);
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
logger.info("Executing job at: " + new java.util.Date());
}
}4. 配置Quartz Job和Trigger
在Spring Boot的配置類中定義Quartz Job和Trigger：
import org.quartz.JobDetail;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.JobDetailFactoryBean;
import org.springframework.scheduling.quartz.SimpleTriggerFactoryBean;
@Configuration
public class QuartzConfig {
@Bean
public JobDetailFactoryBean jobDetail() {
JobDetailFactoryBean factoryBean = new JobDetailFactoryBean();
factoryBean.setJobClass(MyJob.class);
factoryBean.setDurability(true);
return factoryBean;
}
@Bean
public SimpleTriggerFactoryBean trigger(JobDetail jobDetail) {
SimpleTriggerFactoryBean factoryBean = new SimpleTriggerFactoryBean();
factoryBean.setJobDetail(jobDetail);
factoryBean.setRepeatInterval(10000); // 每10秒執(zhí)行一次
factoryBean.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
factoryBean.setStartDelay(0);
factoryBean.setMisfireInstruction(SimpleScheduleBuilder.MISFIRE_INSTRUCTION_FIRE_NOW);
return factoryBean;
}
}5. 啟動Spring Boot應用
最后，創(chuàng)建一個Spring Boot啟動類：
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class QuartzClusterApplication {
public static void main(String[] args) {
SpringApplication.run(QuartzClusterApplication.class, args);
}
}6. 初始化Quartz表
確保在MySQL數據庫中創(chuàng)建Quartz所需的表。可以使用Quartz提供的SQL腳本，通常位于Quartz的發(fā)行包中，或者從Quartz的GitHub倉庫下載。
例如，使用以下命令創(chuàng)建表：
CREATE DATABASE quartz_db; USE quartz_db; -- 運行Quartz提供的SQL腳本 SOURCE path/to/tables_mysql_innodb.sql;
7. 測試
啟動多個實例（每個實例運行在不同的端口上），觀察日志輸出，確保任務在集群中的不同節(jié)點上交替執(zhí)行。
以上就是一個完整的Spring Boot + Quartz + MySQL集群配置示例。希望對你有所幫助！如果有任何問題或需要進一步的幫助，請隨時告訴我。在使用Spring與Quartz結合構建定時任務的集群環(huán)境中，MySQL通常被用作持久化存儲來確保任務的調度信息能夠在集群中的不同節(jié)點間共享。這樣可以避免同一個任務在多個節(jié)點上重復執(zhí)行，并且能夠保證即使某個節(jié)點宕機，其他節(jié)點也能接管未完成的任務。
以下是一個詳細的步驟和示例代碼，介紹如何在Spring Boot項目中配置和使用Quartz集群（MySQL數據源）：
1. 添加依賴
首先，在??pom.xml??文件中添加Spring Boot和Quartz的相關依賴：
<dependencies>
<!-- Spring Boot Starter -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!-- Quartz -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
<!-- MySQL Connector -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- Spring Boot Starter Data JPA -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
</dependencies>2. 配置Quartz
在??application.properties??或??application.yml??中配置Quartz連接到MySQL數據庫：
# MySQL 數據庫配置 spring.datasource.url=jdbc:mysql://localhost:3306/quartz?useSSL=false&serverTimezone=UTC spring.datasource.username=root spring.datasource.password=password spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver # Quartz 配置 spring.quartz.job-store-type=jdbc spring.quartz.jdbc.initialize-schema=always spring.quartz.properties.org.quartz.scheduler.instanceName=ClusteredScheduler spring.quartz.properties.org.quartz.scheduler.instanceId=AUTO spring.quartz.properties.org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX spring.quartz.properties.org.quartz.jobStore.isClustered=true spring.quartz.properties.org.quartz.jobStore.clusterCheckinInterval=20000 spring.quartz.properties.org.quartz.jobStore.misfireThreshold=60000 spring.quartz.properties.org.quartz.jobStore.tablePrefix=QRTZ_ spring.quartz.properties.org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool spring.quartz.properties.org.quartz.threadPool.threadCount=10
3. 創(chuàng)建定時任務
創(chuàng)建一個簡單的定時任務類：
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class MyJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
System.out.println("MyJob is running on node " + context.getScheduler().getSchedulerInstanceId());
}
}4. 配置Spring Boot啟動類
在Spring Boot的啟動類中配置Quartz Scheduler：
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;
@Component
public class QuartzInitializer implements CommandLineRunner {
@Autowired
private SchedulerFactory schedulerFactory;
@Override
public void run(String... args) throws Exception {
Scheduler scheduler = schedulerFactory.getScheduler();
scheduler.start();
}
@Bean
public SchedulerFactory schedulerFactory() {
return new StdSchedulerFactory();
}
}5. 定義Job和Trigger
使用Spring的??@Configuration??類來定義Job和Trigger：
import org.quartz.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class QuartzConfig {
@Bean
public JobDetail myJobDetail() {
return JobBuilder.newJob(MyJob.class)
.withIdentity("myJob", "group1")
.build();
}
@Bean
public Trigger myJobTrigger() {
SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(10)
.repeatForever();
return TriggerBuilder.newTrigger()
.forJob(myJobDetail())
.withIdentity("myJobTrigger", "group1")
.withSchedule(scheduleBuilder)
.build();
}
}6. 啟動應用
啟動Spring Boot應用后，Quartz會根據配置自動創(chuàng)建并調度任務。由于配置了集群模式，多個節(jié)點上的應用會共享相同的任務調度信息，確保任務不會重復執(zhí)行。
注意事項
- 數據庫表結構：確保MySQL數據庫中有Quartz所需的表結構?？梢酝ㄟ^設置?
?spring.quartz.jdbc.initialize-schema=always??來自動生成這些表。 - 集群配置：確保每個節(jié)點的?
?instanceId??是唯一的，可以通過設置??AUTO??來自動生成。 - 時間同步：確保集群中的所有節(jié)點的時間同步，以避免因時間不一致導致的任務調度問題。
通過以上步驟，你可以在Spring Boot項目中成功配置和使用Quartz集群（MySQL數據源）。
以上就是在Spring框架下配置Quartz集群的詳細步驟的詳細內容，更多關于Spring配置Quartz集群的資料請關注腳本之家其它相關文章！
相關文章
Spring Boot是Spring官方推出的一個快速構建獨立運行、生產級別Spring應用的框架,它的核心目標是簡化Spring應用的搭建與部署,本文給大家介紹Spring Boot啟動流程詳解,感興趣的朋友跟隨小編一起看看吧2026-02-02
建造者模式，是一種對象構建模式 它可以將復雜對象的建造過程抽象出來，使這個抽象過程的不同實現方法可以構造出不同表現的對象。本文將通過示例講解建造者模式，需要的可以參考一下2022-04-04
where標記的作用類似于動態(tài)sql中的set標記，本文主要介紹了mybatis where 標簽使用，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-03-03
這篇文章主要介紹了MyBatis傳入集合 list 數組 map參數的寫法的相關資料,非常不錯，具有參考借鑒價值，需要的朋友可以參考下2016-06-06
這篇文章主要為大家詳細介紹了java設計模式之單例模式，具有一定的參考價值，感興趣的小伙伴們可以參考一下2017-10-10
java8 stream 操作map根據key或者value排序的實現
這篇文章主要介紹了java8 stream 操作map根據key或者value排序的實現，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-09-09
這篇文章主要介紹了Java的List集合中泛型使用詳解,泛型類,如果沒有指定具體的數據類型,此時,操作類型是Object,泛型的類型參數只能是類類型,不能是基本數據類型,需要的朋友可以參考下2023-12-12
在Spring Boot中集成RabbitMQ詳細步驟(最新推薦)
本文將介紹如何在Spring Boot項目中集成RabbitMQ,實現生產者和消費者的基本配置,本文分步驟給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友參考下吧2023-12-12
圖形界面（簡稱GUI）是指采用圖形方式顯示的計算機操作用戶界面。與早期計算機使用的命令行界面相比，圖形界面對于用戶來說在視覺上更易于接受，本篇精講Java語言中關于圖形用戶界面的基本容器JFrame2022-02-02
深入解析Spring MVC中攔截器Interceptor的實現原理和應用場景
在 Spring 生態(tài)中,攔截器（Interceptor） 是實現上述橫切關注點（Cross-Cutting Concerns）的標準機制之一,它作為 Spring MVC 的核心組件,提供了對 Controller 層請求的精細化控制能力,下面小編就和大家深入介紹一下吧2025-12-12