Java單機環(huán)境實現(xiàn)定時任務(wù)技術(shù)
前言
開發(fā)的系統(tǒng)中過程,會有如下的需求:
- 凌晨生成訂單統(tǒng)計報表
- 定時推送文章、發(fā)送郵件
- 每隔5分鐘動態(tài)抓取數(shù)據(jù)更新
- 每晚定時計算用戶當(dāng)日收益情況并推送給用戶
- .....
通常這些需求我們都是通過定時任務(wù)來實現(xiàn),列舉了java中一些常用的的定時任務(wù)框架。
定時任務(wù)框架
TimeTask
從我們開始學(xué)習(xí)java開始,最先實現(xiàn)定時任務(wù)的時候都是采用TimeTask, Timer內(nèi)部使用TaskQueue的類存放定時任務(wù),它是一個基于最小堆實現(xiàn)的優(yōu)先級隊列。TaskQueue會按照任務(wù)距離下一次執(zhí)行時間的大小將任務(wù)排序,保證在堆頂?shù)娜蝿?wù)最先執(zhí)行。
實例代碼:
public static void main(String[] args) { TimerTask task = new TimerTask() { public void run() { System.out.println("當(dāng)前時間: " + new Date() + "n" + "線程名稱: " + Thread.currentThread().getName()); } }; Timer timer = new Timer("Timer"); long delay = 5000L; timer.schedule(task, delay); System.out.println("當(dāng)前時間: " + new Date() + "n" + "線程名稱: " + Thread.currentThread().getName()); }
運行結(jié)果:
當(dāng)前時間: Wed Apr 06 22:05:04 CST 2022n線程名稱: main 當(dāng)前時間: Wed Apr 06 22:05:09 CST 2022n線程名稱: Timer 復(fù)制代碼
從結(jié)果可以看出,5秒后執(zhí)行了定時任務(wù)。
缺點:
- TimeTask執(zhí)行任務(wù)只能串行執(zhí)行,一旦一個任務(wù)執(zhí)行的時間比較長的話將會影響其他任務(wù)執(zhí)行
- 執(zhí)行任務(wù)過程如果發(fā)生異常,任務(wù)會直接停止。
隨著時間的推移,java的技術(shù)也在不斷的更新,針對TimeTask的不足,ScheduledExecutorService出現(xiàn)替代了TimeTask。
ScheduledExecutorService
ScheduledExecutorService是一個接口,有多個實現(xiàn)類,比較常用的是ScheduledThreadPoolExecutor。而ScheduledThreadPoolExecutor本身就是一個線程池,其內(nèi)部使用 DelayQueue 作為任務(wù)隊列,并且支持任務(wù)并發(fā)執(zhí)行。
實例代碼:
public static void main(String[] args) throws InterruptedException { ScheduledExecutorService executorService = Executors.newScheduledThreadPool(3); // 執(zhí)行任務(wù): 每 10秒執(zhí)行一次 executorService.scheduleAtFixedRate(() -> { System.out.println("執(zhí)行任務(wù):" + new Date()+",線程名稱: " + Thread.currentThread().getName()); }, 1, 10, TimeUnit.SECONDS); }
缺點:
- 盡量避免用Executors方式去創(chuàng)建線程池,因為jdk自帶線程池內(nèi)部使用的的隊列的比較大,很容易出現(xiàn)OOM。
- 定時任務(wù)是基于JVM單機內(nèi)存形式的,一旦重啟定時任務(wù)就消失了。
- 無法支持cron表達式實現(xiàn)豐富的定時任務(wù)。
Spring Task
學(xué)習(xí)了Spring之后,開始使用了Spring 自帶的Task。Spring Framework 自帶定時任務(wù),提供了 cron 表達式來實現(xiàn)豐富定時任務(wù)配置。
實例代碼:
@EnableScheduling @Component public class SpringTask { private Logger logger = LoggerFactory.getLogger(SpringTask.class); private static final SimpleDateFormat dateFormat = new SimpleDateFormat( "HH:mm:ss"); /** * fixedRate:固定速率執(zhí)行。每5秒執(zhí)行一次。 */ @Scheduled(fixedRate = 5000) public void invokeTaskWithFixedRate() { logger.info("Fixed Rate Task : Current Time is {}", dateFormat.format(new Date())); } /** * fixedDelay:固定延遲執(zhí)行。距離上一次調(diào)用成功后2秒才執(zhí)。 */ @Scheduled(fixedDelay = 2000) public void invokeTaskWithFixedDelay() { try { TimeUnit.SECONDS.sleep(3); logger.info("Fixed Delay Task : Current Time is {}", dateFormat.format(new Date())); } catch (InterruptedException e) { logger.error("invoke task error",e); } } /** * initialDelay:初始延遲。任務(wù)的第一次執(zhí)行將延遲5秒,然后將以5秒的固定間隔執(zhí)行。 */ @Scheduled(initialDelay = 5000, fixedRate = 5000) public void invokeTaskWithInitialDelay() { logger.info("Task with Initial Delay : Current Time is {}", dateFormat.format(new Date())); } /** * cron:使用Cron表達式,每隔5秒執(zhí)行一次 */ @Scheduled(cron = "0/5 * * * * ? ") public void invokeTaskWithCronExpression() { logger.info("Task Cron Expression: Current Time is {}", dateFormat.format(new Date())); } }
執(zhí)行結(jié)果:
2022-04-06 23:06:20.945 INFO 14604 --- [ scheduling-1] com.fw.task.SpringTask : Task Cron Expression: Current Time is 23:06:20
2022-04-06 23:06:22.557 INFO 14604 --- [ scheduling-1] com.fw.task.SpringTask : Task with Initial Delay : Current Time is 23:06:22
2022-04-06 23:06:22.557 INFO 14604 --- [ scheduling-1] com.fw.task.SpringTask : Fixed Rate Task : Current Time is 23:06:22
2022-04-06 23:06:25.955 INFO 14604 --- [ scheduling-1] com.fw.task.SpringTask : Fixed Delay Task : Current Time is 23:06:25
2022-04-06 23:06:25.955 INFO 14604 --- [ scheduling-1] com.fw.task.SpringTask : Task Cron Expression: Current Time is 23:06:25
2022-04-06 23:06:27.555 INFO 14604 --- [ scheduling-1] com.fw.task.SpringTask : Task with Initial Delay : Current Time is 23:06:27
2022-04-06 23:06:27.556 INFO 14604 --- [ scheduling-1] com.fw.task.SpringTask : Fixed Rate Task : Current Time is 23:06:27
@EnableScheduling需要開啟定時任務(wù),@Scheduled(cron = "0/5 * * * * ?")配置定時任務(wù)的規(guī)則。cron表達式支持豐富定時任務(wù)配置,不熟悉的的可以查看
優(yōu)點:
使用簡單方便,支持各種復(fù)雜的定時任務(wù)配置
缺點:
- 基于單機形式定時任務(wù),一旦重啟定時任務(wù)就消失了。
- 定時任務(wù)默認(rèn)是單線程執(zhí)行任務(wù),如果需要并行執(zhí)行需要開啟@EnableAsync。
- 沒有統(tǒng)一的圖形化任務(wù)調(diào)度的管理,無法控制定時任務(wù)
結(jié)語
任何技術(shù)的出現(xiàn)都有它的價值,技術(shù)沒有最好的,只有最合適的。我們要針對不同的需求選擇最合適的技術(shù),切莫過度架構(gòu)設(shè)計。本文講解了單機環(huán)境實現(xiàn)定時任務(wù)的技術(shù),
到此這篇關(guān)于Java單機環(huán)境實現(xiàn)定時任務(wù)技術(shù)的文章就介紹到這了,更多相關(guān)Java定時任務(wù)框架內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java 根據(jù)貸款年限對應(yīng)利率計算功能實現(xiàn)解析
這篇文章主要介紹了Java 根據(jù)貸款年限對應(yīng)利率計算功能實現(xiàn)解析,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-10-10SpringBoot實現(xiàn)動態(tài)定時任務(wù)
這篇文章主要為大家詳細介紹了SpringBoot實現(xiàn)動態(tài)定時任務(wù),文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2019-04-04java 使用JDBC構(gòu)建簡單的數(shù)據(jù)訪問層實例詳解
以下是如何使用JDBC構(gòu)建一個數(shù)據(jù)訪問層,包括數(shù)據(jù)轉(zhuǎn)換(將從數(shù)據(jù)庫中查詢的數(shù)據(jù)封裝到對應(yīng)的對象中……),數(shù)據(jù)庫的建立,以及如何連接到數(shù)據(jù)庫,需要的朋友可以參考下2016-11-11