springboot quartz 数据库

### Spring Boot 中集成 Quartz 实现基于数据库的任务调度 要在 Spring Boot 中集成 Quartz 并实现基于数据库的任务调度，可以按照以下方式完成： #### 1. 添加依赖 在 `pom.xml` 文件中引入必要的依赖项。以下是 Maven 的配置示例[^3]： ```xml <dependencies> <!-- Spring Boot Starter Quartz --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-quartz</artifactId> </dependency> <!-- MySQL Driver (如果使用MySQL作为数据库) --> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> </dependencies> ``` #### 2. 创建数据库表结构 为了持久化任务信息到数据库中，需要创建 Quartz 提供的标准 SQL 表结构。可以通过执行官方提供的脚本文件来初始化这些表格。对于 MySQL 数据库，可以下载并运行 `tables_mysql.sql` 脚本来生成所需的表结构[^1]。 #### 3. 配置 Quartz 属性 编辑 `application.properties` 或者 `application.yml` 来设置 Quartz 使用 JDBC-JobStore 和连接池的相关参数。例如，在 `application.properties` 中添加如下内容: ```properties # 定义实例名 org.quartz.scheduler.instanceName=MyClusteredScheduler # 设置线程池大小 org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool org.quartz.threadPool.threadCount=10 # 启用JDBC Job Store, 支持集群模式 org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate org.quartz.jobStore.tablePrefix=QRTZ_ # 开启集群支持 org.quartz.scheduler.instanceId=AUTO org.quartz.jobStore.isClustered=true org.quartz.jobStore.clusterCheckinInterval=20000 # 数据源配置 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 ``` #### 4. 编写任务类和触发器 定义一个简单的任务类继承自 `Job` 接口，并重写其方法逻辑。例如： ```java import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; public class SampleJob implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { System.out.println("Sample job is running..."); } } ``` 接着通过编程的方式或者 XML/JSON/YAML 等形式注册该任务及其对应的触发条件。这里展示一种常见的做法——利用 Java API 动态构建 Trigger 和 Schedule。 ```java import org.quartz.*; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class QuartzConfig { @Bean public JobDetail sampleJobDetail() { return JobBuilder.newJob(SampleJob.class) .withIdentity("sampleJob", "group1") .build(); } @Bean public Trigger sampleJobTrigger() { SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule() .withIntervalInSeconds(10).repeatForever(); return TriggerBuilder.newTrigger() .forJob(sampleJobDetail()) .withIdentity("sampleTrigger", "group1") .withSchedule(scheduleBuilder) .build(); } } ``` 以上代码片段展示了如何声明一个名为 `sampleJob` 的任务以及每十秒钟重复一次的触发机制。 --- ### 注意事项 当首次接触 Quartz 时，可以选择更简易的方式来测试环境搭建情况，比如采用内存存储而非立即切换至复杂的数据库方案[^2]。然而一旦进入生产阶段，则推荐启用高可用性的设计原则，即借助外部数据源保存状态记录以便于恢复失败节点上的未决工作项目。