SpringBoot3整合Quartz實(shí)現(xiàn)定時(shí)任務(wù)的示例
1. 什么是 Quartz Scheduler？
Quartz 是 Java 平臺(tái)下的一個(gè)強(qiáng)大、靈活的調(diào)度庫(kù)，它支持復(fù)雜的任務(wù)調(diào)度，包括：
- 簡(jiǎn)單的任務(wù)：按固定頻率或延遲執(zhí)行任務(wù)。
- 基于 Cron 表達(dá)式的任務(wù)：支持類似于 Linux Cron 的表達(dá)式，用于定義復(fù)雜的定時(shí)任務(wù)。
- 持久化任務(wù)：支持將任務(wù)數(shù)據(jù)持久化存儲(chǔ)，以便在應(yīng)用程序重啟后可以恢復(fù)任務(wù)狀態(tài)。
2. Spring Boot 3 集成 Quartz Scheduler 的優(yōu)勢(shì)
- 無(wú)縫集成：通過(guò) Spring Boot 3 的自動(dòng)配置特性，無(wú)需編寫復(fù)雜的配置即可使用 Quartz。
- 靈活管理：支持任務(wù)的動(dòng)態(tài)添加、暫停、恢復(fù)和刪除。
- 擴(kuò)展性：可以輕松擴(kuò)展任務(wù)調(diào)度系統(tǒng)，便于業(yè)務(wù)邏輯的復(fù)雜應(yīng)用。
3. Spring Boot 3 集成 Quartz 的步驟
3.1 創(chuàng)建 Spring Boot 項(xiàng)目
可以使用 Spring Initializr 創(chuàng)建項(xiàng)目，選擇以下依賴：
- Spring Web
- Quartz Scheduler
3.2 添加 Quartz 依賴
如果使用的是手動(dòng)創(chuàng)建的項(xiàng)目，可以在 pom.xml 中添加 Quartz 的依賴：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
3.3 配置 Quartz 屬性
在 application.yml 或 application.properties 文件中配置 Quartz 的基本屬性，例如任務(wù)存儲(chǔ)和調(diào)度方式。
以下是 application.yml 配置示例：
spring:
application:
name: spring-boot3-19-quartz
quartz:
job-store-type: memory # 儲(chǔ)類型為內(nèi)存存儲(chǔ)
properties:
org:
quartz:
threadPool:
threadCount: 5 # 配置線程池線程數(shù)為 5
jobStore:
misfireThreshold: 60000 # 設(shè)置作業(yè)存儲(chǔ)的錯(cuò)過(guò)觸發(fā)閾值為 60000 毫秒（1分鐘）
這里使用了內(nèi)存存儲(chǔ)方式（job-store-type: memory），也可以根據(jù)需要配置數(shù)據(jù)庫(kù)存儲(chǔ)任務(wù)信息。
3.4 創(chuàng)建一個(gè) Quartz 任務(wù)類
創(chuàng)建一個(gè)簡(jiǎn)單的 Quartz 任務(wù)類，需要實(shí)現(xiàn) Job 接口，并重寫 execute 方法：
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
@Component
public class SampleJob implements Job {
private static final Logger logger = LoggerFactory.getLogger(SampleJob.class);
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
logger.info("Executing Sample Job at: " + context.getFireTime());
}
}
3.5 配置任務(wù)調(diào)度器
在 Spring Boot 3 中，可以通過(guò) @Configuration 創(chuàng)建 Quartz 的調(diào)度器，并配置定時(shí)任務(wù)的觸發(fā)器（Trigger）和任務(wù)詳情（JobDetail）。
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
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")
.storeDurably()
.build();
}
@Bean
public Trigger sampleJobTrigger() {
SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()
.withIntervalInSeconds(10) // 每 10 秒執(zhí)行一次
.repeatForever();
return TriggerBuilder.newTrigger()
.forJob(sampleJobDetail())
.withIdentity("sampleJobTrigger")
.withSchedule(scheduleBuilder)
.build();
}
}
sampleJobDetail方法定義了任務(wù)的基本信息，包括任務(wù)類和名稱。sampleJobTrigger方法定義了觸發(fā)器的調(diào)度策略，這里設(shè)置為每 10 秒執(zhí)行一次。
3.6 使用 Cron 表達(dá)式配置任務(wù)
除了簡(jiǎn)單的時(shí)間間隔，還可以通過(guò) Cron 表達(dá)式實(shí)現(xiàn)更靈活的調(diào)度。以下示例展示如何使用 Cron 表達(dá)式配置任務(wù)觸發(fā)器。
import org.quartz.CronScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
@Bean
public Trigger cronJobTrigger() {
return TriggerBuilder.newTrigger()
.forJob(sampleJobDetail())
.withIdentity("cronJobTrigger")
.withSchedule(CronScheduleBuilder.cronSchedule("0 0/1 * 1/1 * ? *")) // 每分鐘執(zhí)行一次
.build();
}
在這個(gè)例子中，Cron 表達(dá)式 "0 0/1 * 1/1 * ? *" 表示每分鐘執(zhí)行一次任務(wù)。
4. 運(yùn)行應(yīng)用并查看日志
配置完成后，啟動(dòng) Spring Boot 應(yīng)用。Quartz Scheduler 會(huì)按照配置執(zhí)行 SampleJob 任務(wù)。您可以在控制臺(tái)中看到日志輸出，類似如下：
2024-11-13T21:07:39.910+08:00 INFO 11984 --- [spring-boot3-18-quartz] [eduler_Worker-4] c.coderjia.boot318quartz.job.SampleJob : Executing Sample Job at: Wed Nov 13 21:07:39 CST 2024
每 10 秒執(zhí)行一次效果：
每分鐘執(zhí)行一次效果：
5. 動(dòng)態(tài)管理 Quartz 任務(wù)
可以在代碼中動(dòng)態(tài)地添加、暫停、恢復(fù)和刪除任務(wù)。例如，以下是動(dòng)態(tài)添加任務(wù)的示例：
package com.coderjia.boot318quartz;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.Trigger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* @author CoderJia
* @create 2024/11/13 下午 09:25
* @Description
**/
@Service
public class QuartzService {
private final Scheduler scheduler;
@Autowired
public QuartzService(Scheduler scheduler) {
this.scheduler = scheduler;
}
public void scheduleJob(JobDetail jobDetail, Trigger trigger) {
try {
scheduler.scheduleJob(jobDetail, trigger);
} catch (Exception e) {
e.printStackTrace();
}
}
public void pauseJob(String jobName, String jobGroup) {
try {
JobKey jobKey = new JobKey(jobName, jobGroup);
scheduler.pauseJob(jobKey);
System.out.println("Job paused: " + jobKey);
} catch (SchedulerException e) {
e.printStackTrace();
}
}
public void resumeJob(String jobName, String jobGroup) {
try {
JobKey jobKey = new JobKey(jobName, jobGroup);
scheduler.resumeJob(jobKey);
System.out.println("Job resumed: " + jobKey);
} catch (SchedulerException e) {
e.printStackTrace();
}
}
public void deleteJob(String jobName, String jobGroup) {
try {
JobKey jobKey = new JobKey(jobName, jobGroup);
boolean deleted = scheduler.deleteJob(jobKey);
if (deleted) {
System.out.println("Job deleted: " + jobKey);
} else {
System.out.println("Job not found: " + jobKey);
}
} catch (SchedulerException e) {
e.printStackTrace();
}
}
}
調(diào)用 scheduleJob 方法可以動(dòng)態(tài)地添加新的任務(wù)。類似地，使用 scheduler.pauseJob() 和 scheduler.deleteJob() 可以暫?；騽h除任務(wù)。
6. 總結(jié)
通過(guò)將 Quartz 與 Spring Boot 3 結(jié)合，我們可以實(shí)現(xiàn)強(qiáng)大而靈活的定時(shí)任務(wù)調(diào)度系統(tǒng)。本文介紹了 Quartz 的基本配置和使用方法，包括如何配置任務(wù)、觸發(fā)器，以及使用 Cron 表達(dá)式實(shí)現(xiàn)復(fù)雜的調(diào)度策略。
以上就是SpringBoot3整合Quartz實(shí)現(xiàn)定時(shí)任務(wù)的示例的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot3 Quartz定時(shí)任務(wù)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！
相關(guān)文章
mybatis-plus開啟sql打印的三種方式總結(jié)
這篇文章主要給大家介紹了mybatisplus開啟sql打印的三種方式,文章通過(guò)代碼示例介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的參考價(jià)值,需要的朋友可以參考下2023-11-11
如何使用Java調(diào)用Linux系統(tǒng)命令
這篇文章主要介紹了如何使用Java調(diào)用Linux系統(tǒng)命令，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-11-11
這篇文章主要介紹了Java中WeakHashMap的弱鍵回收機(jī)制,WeakHashMap繼承AbstractMap,實(shí)現(xiàn)了Map接口,和HashMap一樣,WeakHashMap也是一個(gè)散列表,它存儲(chǔ)的內(nèi)容也是鍵值對(duì)(key-value)映射,而且鍵和值都可以是null,需要的朋友可以參考下2023-09-09
這篇文章主要介紹了Eclipse IDE可支持Java 14編程，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-04-04
JavaFX程序初次運(yùn)行創(chuàng)建數(shù)據(jù)庫(kù)并執(zhí)行建表SQL詳解
這篇文章主要介紹了JavaFX程序初次運(yùn)行創(chuàng)建數(shù)據(jù)庫(kù)并執(zhí)行建表SQL詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-08-08
基于Java8 Stream API實(shí)現(xiàn)數(shù)據(jù)抽取收集
這篇文章主要介紹了基于Java8 Stream API實(shí)現(xiàn)數(shù)據(jù)抽取收集,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-03-03
Flink實(shí)戰(zhàn)之實(shí)現(xiàn)流式數(shù)據(jù)去重
流式數(shù)據(jù)是一種源源不斷產(chǎn)生的數(shù)據(jù),本文探索了一種流式大數(shù)據(jù)的實(shí)時(shí)去重方法,不一定適用于所有場(chǎng)景,不過(guò)或許可以給面對(duì)相似問(wèn)題的你一點(diǎn)點(diǎn)啟發(fā),2025-03-03
這篇文章主要介紹了解決eclipse上傳svn忽略target文件夾的坑，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-01-01
redis 使用lettuce 啟動(dòng)內(nèi)存泄漏錯(cuò)誤的解決方案
這篇文章主要介紹了redis 使用lettuce 啟動(dòng)內(nèi)存泄漏錯(cuò)誤的解決方案，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2021-04-04
這篇文章主要介紹了java獲取文件大小的幾種方法，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-10-10