SpringBoot定時調(diào)度之Timer與Quartz詳解
Java 中常用的定時調(diào)度框架有以下幾種:
- Timer:Java 標(biāo)準(zhǔn)庫中提供的一個定時調(diào)度工具,可以在指定的時間點或時間間隔內(nèi)執(zhí)行任務(wù)。Timer 的缺點是不支持并發(fā)執(zhí)行和錯誤處理機(jī)制較弱。
- ScheduledExecutorService:Java 標(biāo)準(zhǔn)庫中提供的另一個定時調(diào)度工具,也可以在指定的時間點或時間間隔內(nèi)執(zhí)行任務(wù)。與 Timer 相比,ScheduledExecutorService 支持并發(fā)執(zhí)行和錯誤處理機(jī)制較強。
- Spring Task:Spring 框架中提供的一個定時調(diào)度工具,可以用于執(zhí)行定時任務(wù)、異步任務(wù)等。Spring Task 支持多種時間表達(dá)式、動態(tài)調(diào)整和錯誤處理機(jī)制。
- Quartz:一個用于定時調(diào)度的開源框架,可以在指定的時間點或時間間隔內(nèi)自動執(zhí)行任務(wù)。Quartz 支持多種配置方式和調(diào)度策略,功能豐富、靈活性高、易于集成并且可靠性較高。
Timer
Timer 是 Java 標(biāo)準(zhǔn)庫中提供的一個定時調(diào)度工具,可以在指定的時間點或時間間隔內(nèi)執(zhí)行任務(wù)。Timer 提供了多種調(diào)度方式和執(zhí)行策略,可以用于管理簡單的定時任務(wù)。
Timer 使用 TimerTask 類來表示要執(zhí)行的任務(wù),TimerTask 是一個抽象類,需要繼承并實現(xiàn) run() 方法來定義具體的任務(wù)邏輯。Timer 還提供了多種調(diào)度方式,包括定時調(diào)度、周期性調(diào)度等。
以下是一個簡單的 Timer 示例:
import java.util.Timer;
import java.util.TimerTask;
public class MyTask extends TimerTask {
public void run() {
System.out.println("定時任務(wù)執(zhí)行了!");
}
public static void main(String[] args) {
Timer timer = new Timer();
MyTask task = new MyTask();
timer.schedule(task, 5000); // 5秒后執(zhí)行任務(wù)
}
}在上述代碼中,我們定義了一個名為 MyTask 的 TimerTask 類,并在其中實現(xiàn)了 run() 方法來定義具體的任務(wù)邏輯。然后,在 main() 方法中創(chuàng)建了一個 Timer 實例,并使用 schedule() 方法來指定任務(wù)的執(zhí)行時間和執(zhí)行方式。
需要注意的是,Timer 的缺點是不支持并發(fā)執(zhí)行和錯誤處理機(jī)制較弱。如果需要實現(xiàn)復(fù)雜的定時任務(wù),可以考慮使用其它的定時調(diào)度框架,例如 Quartz、ScheduledExecutorService 等。
ScheduledExecutorService
ScheduledExecutorService 基于 Executor 框架,使用 ThreadPoolExecutor 來實現(xiàn)任務(wù)的執(zhí)行和管理。
好的,下面是一個使用 ScheduledExecutorService 實現(xiàn)每天凌晨1點執(zhí)行任務(wù)的示例:
import java.time.LocalTime;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class MyTask implements Runnable {
public void run() {
System.out.println("定時任務(wù)執(zhí)行了!當(dāng)前時間:" + LocalTime.now());
}
public static void main(String[] args) {
ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
MyTask task = new MyTask();
long initialDelay = calculateInitialDelay();
executor.scheduleAtFixedRate(task, initialDelay, 24, TimeUnit.HOURS); // 每天凌晨1點執(zhí)行任務(wù)
}
private static long calculateInitialDelay() {
LocalTime now = LocalTime.now();
LocalTime target = LocalTime.of(1, 0, 0); // 目標(biāo)執(zhí)行時間為每天凌晨1點
if (now.isBefore(target)) {
return Duration.between(now, target).toMillis();
} else {
return Duration.between(now, target.plusDays(1)).toMillis();
}
}
}在上述代碼中,我們定義了一個名為 MyTask 的 Runnable 類,并在其中實現(xiàn)了 run() 方法來定義具體的任務(wù)邏輯。然后,在 main() 方法中創(chuàng)建了一個 ScheduledExecutorService 實例,并使用 scheduleAtFixedRate() 方法來指定任務(wù)的執(zhí)行時間和執(zhí)行方式。
為了實現(xiàn)每天凌晨1點執(zhí)行任務(wù),我們先定義了一個 calculateInitialDelay() 方法來計算任務(wù)的初始延遲時間。該方法會根據(jù)當(dāng)前時間和目標(biāo)執(zhí)行時間計算出初始延遲時間,如果當(dāng)前時間早于目標(biāo)執(zhí)行時間,則將初始延遲時間設(shè)置為兩者時間差,否則將初始延遲時間設(shè)置為兩者時間差加上一天的時間差。
最后,我們使用 scheduleAtFixedRate() 方法來指定任務(wù)的執(zhí)行時間和執(zhí)行周期,其中 initialDelay 參數(shù)為初始延遲時間,period 參數(shù)為執(zhí)行周期,這里是每24小時執(zhí)行一次。
需要注意的是,為了獲取當(dāng)前時間和計算時間差,我們使用了 Java 8 中的 LocalDate、LocalTime 和 Duration 類。如果使用的是 Java 7 或更早的版本,可以使用 Date、Calendar 等類來代替。
Spring Task
Spring Task(也稱為 Spring Scheduler)是 Spring 框架中提供的定時任務(wù)框架,可以在指定的時間點或時間間隔內(nèi)執(zhí)行任務(wù)。Spring Task 封裝了 Java 標(biāo)準(zhǔn)庫中的 Timer 和ScheduledExecutorService,提供了更加簡單和方便的定時任務(wù)管理方式。
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@Component
public class MyTask {
@Scheduled(cron = "0 0 1 * * ?") // 每天凌晨1點執(zhí)行任務(wù)
public void execute() {
System.out.println("定時任務(wù)執(zhí)行了!當(dāng)前時間:" + new Date());
}
}在上述代碼中,我們定義了一個名為 MyTask 的類,并在其中使用 @Scheduled 注解來指定任務(wù)的執(zhí)行時間和執(zhí)行方式。這里使用了 cron 表達(dá)式來指定每天凌晨1點執(zhí)行任務(wù)。
@Scheduled注解支持多種參數(shù)設(shè)置,例如:
- fixedRate:表示每隔多少毫秒執(zhí)行一次。
- fixedDelay:表示延遲多少毫秒后執(zhí)行。
- initialDelay:表示啟動延遲多少毫秒后執(zhí)行第一次。
- cron:使用Cron表達(dá)式來指定執(zhí)行時間,例如“0 0 12 * * ?”表示每天中午12點執(zhí)行。
需要注意的是,@Scheduled注解只能用于Spring容器中的Bean中,因此需要將使用該注解的類標(biāo)注為@Component或其他的Spring組件注解。
cron表達(dá)式
| 任務(wù)執(zhí)行時間 | cron 表達(dá)式 |
|---|---|
| 每分鐘執(zhí)行一次 | 0 * * * * ? |
| 每小時的第30分鐘執(zhí)行一次 | 0 30 * * * ? |
| 每天的凌晨1點執(zhí)行一次 | 0 0 1 * * ? |
| 每周的周日凌晨1點執(zhí)行一次 | 0 0 1 ? * SUN |
| 每月的1號凌晨1點執(zhí)行一次 | 0 0 1 1 * ? |
| 每年的1月1日凌晨1點執(zhí)行一次 | 0 0 1 1 1 ? |
| 每天上午10點和下午2點執(zhí)行一次 | 0 0 10,14 * * ? |
| 每天的上午10點到11點之間每隔30秒執(zhí)行一次 | 0/30 10-11 * * * ? |
| 每天的上午10點到11點之間每隔5分鐘的1、6、11、16、21、26、31、36、41、46、51、56秒執(zhí)行 | 1,6,11,16,21,26,31,36,41,46,51,56 10-11 * * * ? |
另外,如果想要快速生成 cron 表達(dá)式,可以使用在線 cron 表達(dá)式生成器,例如 cron.qqe2.com/ cron 表達(dá)式。
@EnableScheduling
使用@Scheduled需要@EnableScheduling 配合,默認(rèn) spring-boot-actuator 包會帶上@EnableScheduling 注解,從而給人一種默認(rèn)開啟定時任務(wù)的錯覺。移除對應(yīng)包之后,如果用戶沒有在自己項目中帶上 @EnableScheduling 注解,則定時任務(wù)不會生效。
Quartz
Quartz 使用 Job 和 Trigger 兩個核心概念來管理任務(wù)。Job 表示要執(zhí)行的任務(wù),Trigger 表示任務(wù)的觸發(fā)器,即任務(wù)執(zhí)行的時間條件。Quartz 還提供了多種調(diào)度器和監(jiān)聽器,可以實現(xiàn)更加復(fù)雜的任務(wù)調(diào)度和任務(wù)管理。
以下是一個簡單的 Quartz 示例:
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
public class MyJob implements Job {
public void execute(JobExecutionContext context) throws JobExecutionException {
System.out.println("定時任務(wù)執(zhí)行了!當(dāng)前時間:" + new Date());
}
public static void main(String[] args) throws SchedulerException {
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
JobDetail job = JobBuilder.newJob(MyJob.class).withIdentity("myJob", "group1").build();
Trigger trigger = TriggerBuilder.newTrigger().withIdentity("myTrigger", "group1")
.startAt(DateBuilder.todayAt(1, 0, 0)).withSchedule(SimpleScheduleBuilder.repeatHourlyForever())
.build();
scheduler.scheduleJob(job, trigger);
scheduler.start();
}
}在上述代碼中,我們定義了一個名為 MyJob 的 Job 類,并在其中實現(xiàn)了 execute() 方法來定義具體的任務(wù)邏輯。然后,在 main() 方法中創(chuàng)建了一個 Scheduler 實例,并使用 JobBuilder 和 TriggerBuilder 來定義任務(wù)和觸發(fā)器。這里我們使用 SimpleScheduleBuilder 來指定任務(wù)的執(zhí)行間隔,即每小時執(zhí)行一次。
Quartz 還支持多種觸發(fā)器類型和調(diào)度器類型,例如 CronTrigger、CalendarIntervalTrigger、JobStoreTX 等,可以根據(jù)具體的需求進(jìn)行選擇和配置。
以上就是SpringBoot定時調(diào)度之Timer與Quartz詳解的詳細(xì)內(nèi)容,更多關(guān)于SpringBoot定時的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
java基于jdbc實現(xiàn)簡單學(xué)生管理系統(tǒng)
本文主要主要介紹了java連接mysql數(shù)據(jù)庫的一個簡單學(xué)生系統(tǒng),通過jdbc連接數(shù)據(jù)庫。文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價值,感興趣的小伙伴們可以參考一下2021-10-10
Java集合中的CopyOnWriteArrayList使用詳解
這篇文章主要介紹了Java集合中的CopyOnWriteArrayList使用詳解,CopyOnWriteArrayList是ArrayList的線程安全版本,從他的名字可以推測,CopyOnWriteArrayList是在有寫操作的時候會copy一份數(shù)據(jù),然后寫完再設(shè)置成新的數(shù)據(jù),需要的朋友可以參考下2023-12-12
Spring實戰(zhàn)之使用Expression接口進(jìn)行表達(dá)式求值操作示例
這篇文章主要介紹了Spring實戰(zhàn)之使用Expression接口進(jìn)行表達(dá)式求值操作,結(jié)合實例形式分析了Spring操作Expression接口實現(xiàn)表達(dá)式運算的操作技巧與相關(guān)注意事項,需要的朋友可以參考下2019-12-12
在SpringBoot中無縫整合Dubbo的實現(xiàn)過程
微服務(wù)架構(gòu)已經(jīng)成為現(xiàn)代應(yīng)用開發(fā)的熱門趨勢,而Dubbo作為一款強大的分布式服務(wù)框架,與Spring?Boot的結(jié)合是構(gòu)建高性能微服務(wù)應(yīng)用的理想選擇,本文將詳細(xì)介紹如何在SpringBoot中無縫整合Dubbo,需要的朋友可以參考下2024-01-01
踩坑批量更新sql報錯,實際sql能夠正常執(zhí)行的問題
在項目工程遷移過程中,遇到了一個批量更新接口在新工程中報錯的問題,通過分析,排除了代碼錯誤的可能,最終發(fā)現(xiàn)是由于數(shù)據(jù)庫連接配置不當(dāng)導(dǎo)致的,在jdbc連接字符串中加入allowMultiQueries=true參數(shù)后,問題得以解決,這個參數(shù)的作用是允許SQL批量執(zhí)行2022-12-12
關(guān)于JSqlparser使用攻略(高效的SQL解析工具)
這篇文章主要介紹了關(guān)于JSqlparser使用攻略(高效的SQL解析工具),具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-11-11

