Spring提供了@Scheduled注解用于定時(shí)任務(wù)。

一、@Scheduled的基本使用

啟用調(diào)度支持：@EnableScheduling

可以將@Scheduled注釋與觸發(fā)器元數(shù)據(jù)一起添加到方法中。例如，以下方法每隔5秒調(diào)用一次，并具有固定的延遲，這意味著周期是從前面每次調(diào)用的完成時(shí)間開(kāi)始計(jì)算的

@Scheduled(fixedDelay=5000)public void doSomething() {// something that should execute periodically}

如果需要固定速率執(zhí)行，可以更改批注中指定的屬性名。以下方法每5秒調(diào)用一次（在每次調(diào)用的連續(xù)開(kāi)始時(shí)間之間計(jì)算）

@Scheduled(fixedRate=5000)public void doSomething() {// something that should execute periodically}

對(duì)于固定延遲和固定速率任務(wù)，可以通過(guò)指示在首次執(zhí)行方法之前要等待的毫秒數(shù)來(lái)指定初始延遲

@Scheduled(initialDelay=1000, fixedRate=5000)public void doSomething() {// something that should execute periodically}

如果簡(jiǎn)單的周期性調(diào)度不夠表達(dá)，可以提供cron表達(dá)式。例如，以下命令僅在工作日?qǐng)?zhí)行：

@Scheduled(cron='*/5 * * * * MON-FRI')public void doSomething() {// something that should execute on weekdays only}

實(shí)現(xiàn)SchedulingConfigurer接口，重寫(xiě)configureTasks方法：

@Schedule注解的一個(gè)缺點(diǎn)就是其定時(shí)時(shí)間不能動(dòng)態(tài)更改，它適用于具有固定任務(wù)周期的任務(wù)，若要修改任務(wù)執(zhí)行周期，只能走“停服務(wù)→修改任務(wù)執(zhí)行周期→重啟服務(wù)”這條路。而基于 SchedulingConfigurer 接口方式可以做到。SchedulingConfigurer 接口可以實(shí)現(xiàn)在@Configuration等注解類上。

ScheduledTaskRegistrar類包括以下幾個(gè)重要方法：

void addTriggerTask(Runnable task, Trigger trigger) void addTriggerTask(TriggerTask task)void addCronTask(Runnable task, String expression)void addCronTask(CronTask task)void addFixedRateTask(Runnable task, long interval)void addFixedRateTask(IntervalTask task)void addFixedDelayTask(Runnable task, long delay)void addFixedDelayTask(IntervalTask task)

具體實(shí)現(xiàn)參考如下：

@Componentpublic class TestTask implements SchedulingConfigurer { @Override public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { taskRegistrar.addTriggerTask(new Runnable() { @Override public void run() {// 定時(shí)任務(wù)要執(zhí)行的內(nèi)容System.out.println('【開(kāi)始執(zhí)行定時(shí)任務(wù)。。。】'); } }, new Trigger() { @Override public Date nextExecutionTime(TriggerContext triggerContext) {// 定時(shí)任務(wù)觸發(fā)，可修改定時(shí)任務(wù)的執(zhí)行周期String cron = '0 0/5 * * * ?'; //可以將表達(dá)式配置在數(shù)據(jù)庫(kù)中CronTrigger trigger = new CronTrigger(cron);Date nextExecDate = trigger.nextExecutionTime(triggerContext);return nextExecDate; } }); }}

提示：如果在數(shù)據(jù)庫(kù)修改時(shí)格式出現(xiàn)錯(cuò)誤，則定時(shí)任務(wù)會(huì)停止，即使重新修改正確；此時(shí)只能重新啟動(dòng)項(xiàng)目才能恢復(fù)。

二、使用@Scheduled注意事項(xiàng)

spring的注解@Scheduled 需要寫(xiě)在實(shí)現(xiàn)方法上； 定時(shí)器的任務(wù)方法不能有返回值（如果有返回值，spring初始化的時(shí)候會(huì)告訴你有個(gè)錯(cuò)誤、需要設(shè)定一個(gè)proxytargetclass的某個(gè)值為true），不能指向任何的參數(shù)； 如果該方法需要與應(yīng)用程序上下文的其他對(duì)象進(jìn)行交互，通常是通過(guò)依賴注入來(lái)實(shí)現(xiàn)； 實(shí)現(xiàn)類上要有組件的注解@Component。

三、使用@Scheduled常見(jiàn)問(wèn)題

單線程任務(wù)丟失，轉(zhuǎn)為異步線程池

默認(rèn)的 ConcurrentTaskScheduler 計(jì)劃執(zhí)行器采用Executors.newSingleThreadScheduledExecutor() 實(shí)現(xiàn)單線程的執(zhí)行器。因此，對(duì)同一個(gè)調(diào)度任務(wù)的執(zhí)行總是同一個(gè)線程。如果任務(wù)的執(zhí)行時(shí)間超過(guò)該任務(wù)的下一次執(zhí)行時(shí)間，則會(huì)出現(xiàn)任務(wù)丟失，跳過(guò)該段時(shí)間的任務(wù)。上述問(wèn)題有以下解決辦法：

采用異步的方式執(zhí)行調(diào)度任務(wù)，配置 Spring 的 @EnableAsync，在執(zhí)行定時(shí)任務(wù)的方法上標(biāo)注 @Async配置任務(wù)執(zhí)行池，線程池大小 n 的數(shù)量為 單個(gè)任務(wù)執(zhí)行所需時(shí)間 / 任務(wù)執(zhí)行的間隔時(shí)間。如下：

//每30秒執(zhí)行一次@Async('taskExecutor')@Scheduled(fixedRate = 1000 * 3)public void reportCurrentTime(){ System.out.println ('線程' + Thread.currentThread().getName() + '開(kāi)始執(zhí)行定時(shí)任務(wù)===&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&7&&&====》' + new SimpleDateFormat('yyyy-MM-dd HH:mm:ss').format(new Date())); long start = System.currentTimeMillis();}

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持好吧啦網(wǎng)。