快捷導(dǎo)航

Spring6.x對(duì)調(diào)度和異步執(zhí)行的注解支持示例詳解

更新時(shí)間：2023年11月24日 09:15:30 作者：JavaEdge

這篇文章主要為大家介紹了Spring6.x對(duì)調(diào)度和異步執(zhí)行的注解支持示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

1 啟用Scheduling注解

Spring為任務(wù)調(diào)度和異步方法執(zhí)行提供注解支持。

要啟用 @Scheduled 和 @Async ，在 @Configuration 類(lèi)（或者在啟動(dòng)類(lèi)）添加 @EnableScheduling 和 @EnableAsync，如下：

@Configuration
@EnableAsync
@EnableScheduling
public class AppConfig {

}

@SpringBootApplication(exclude = {
        DataSourceAutoConfiguration.class,
})
@EnableScheduling
public class RoadSyncApplication {

    public static void main(String[] args) {
        SpringApplication.run(RoadSyncApplication.class, args);
    }
}

你可以為你的應(yīng)用程序選擇相關(guān)的注解。例如,如果你只需要支持 @Scheduled,可以省略 @EnableAsync。對(duì)于更細(xì)粒度的控制,你還可以分別實(shí)現(xiàn) SchedulingConfigurer 接口和 AsyncConfigurer 接口。有關(guān)完整詳細(xì)信息,請(qǐng)參閱 SchedulingConfigurer 和 AsyncConfigurer javadoc。

默認(rèn)處理 @Async 注解的建議模式是 proxy，它僅允許通過(guò)代理攔截調(diào)用。使用這種方式無(wú)法攔截同一類(lèi)中的本地調(diào)用。對(duì)于更高級(jí)的攔截模式,請(qǐng)考慮切換到 aspectj 模式與編譯時(shí)織入或加載時(shí)織入結(jié)合使用。

2 @Scheduled 注解

可將 @Scheduled 注解以及觸發(fā)元數(shù)據(jù)添加到方法中。

2.1 fixedDelay

如下方法每5000ms執(zhí)行一次，采用固定延遲，即周期從每次先前調(diào)用的【完成時(shí)間】開(kāi)始測(cè)量。

@Scheduled(fixedDelay = 5000)  
public void doSomething() {
    // 定期運(yùn)行的內(nèi)容  
}

默認(rèn)，固定延遲、固定速率和初始延遲的值將使用ms作時(shí)間單位。如想用不同時(shí)間單位，如s或min，可在 @Scheduled 配置 timeUnit 屬性：

@Scheduled(fixedDelay = 5, timeUnit = TimeUnit.SECONDS)
public void doSomething() {
}

2.2 fixedRate

如需固定速率執(zhí)行，使用 fixedRate 屬性。下面的方法每五秒(從每次【調(diào)用的開(kāi)始時(shí)間】間隔測(cè)量)執(zhí)行一次：

@Scheduled(fixedRate = 5, timeUnit = TimeUnit.SECONDS)  
public void doSomething() {

}

固定延遲、固定速率的任務(wù)，可通過(guò)指示等待的時(shí)間量來(lái)指定初始延遲，然后再執(zhí)行方法的第一次調(diào)用：

@Scheduled(initialDelay=1000, fixedRate=5000)  
public void doSomething() {
    // 定期運(yùn)行的內(nèi)容
}

2.3 一次性任務(wù)

可只指定通過(guò)指示等待執(zhí)行方法的時(shí)間量的初始延遲：

@Scheduled(initialDelay=1000)
public void doSomething() {
    // 只運(yùn)行一次
}

若簡(jiǎn)單的定期計(jì)劃不夠表達(dá)力，可用 cron 表達(dá)式：

@Scheduled(cron="*/5 * * * * MON-FRI")  
public void doSomething() {
    // 僅在工作日運(yùn)行的內(nèi)容 
}

還可使用 zone 屬性指定解析 cron 表達(dá)式的時(shí)區(qū)。

要計(jì)劃的方法須有 void 返回值，且不接受任何參數(shù)。如果方法需要與應(yīng)用程序上下文中的其他對(duì)象交互,那么這些對(duì)象通常已經(jīng)通過(guò)依賴(lài)注入。

@Scheduled 是可重復(fù)注解。如在同一方法上找到幾個(gè) scheduled 聲明，每個(gè)聲明都將獨(dú)立處理，為每個(gè)聲明觸發(fā)單獨(dú)的觸發(fā)器。因此，這樣的共定位計(jì)劃可并行重疊并立即連續(xù)執(zhí)行多次。請(qǐng)確保你指定的 cron 表達(dá)式等不會(huì)意外重疊。

Spring Framework 4.3 開(kāi)始,支持任何范圍的 bean 上的 @Scheduled 方法。確保在運(yùn)行時(shí)不初始化同一 @Scheduled 注解類(lèi)的多個(gè)實(shí)例,除非你確實(shí)希望調(diào)度回調(diào)到每個(gè)這樣的實(shí)例。

確保不要在使用 @Scheduled 注解并作為常規(guī) Spring bean 注冊(cè)到容器中的 bean 類(lèi)上使用 @Configurable。否則,你將獲得雙重初始化(一次通過(guò)容器,一次通過(guò) @Configurable 方面),其結(jié)果是每個(gè) @Scheduled 方法被調(diào)用兩次。

FAQ

問(wèn)題

生產(chǎn)用@Scheduled注解寫(xiě)定時(shí)任務(wù)，5min執(zhí)行一次：

@Scheduled(cron = "0 0/5 * * * ?")
public void MyTimerJobSchedule() throws Exception {
  //省略具體業(yè)務(wù)邏輯
  System.out.println("五分鐘執(zhí)行一次");
}

過(guò)幾天，領(lǐng)導(dǎo)通知說(shuō)有問(wèn)題，一查日志，發(fā)現(xiàn)是定時(shí)任務(wù)問(wèn)題。本來(lái)應(yīng)該是5min跑一次，結(jié)果日志發(fā)現(xiàn)，每天0點(diǎn)-3點(diǎn)正常，3-10點(diǎn)沒(méi)執(zhí)行；一直到10-11點(diǎn)之間才繼續(xù)跑。

原因

發(fā)現(xiàn)可能是定時(shí)任務(wù)單線(xiàn)程模式導(dǎo)致任務(wù)阻塞。

繼續(xù)分析日志，發(fā)現(xiàn)該定時(shí)任務(wù)的線(xiàn)程號(hào)是[Scheduling-1]，除了執(zhí)行自身的任務(wù)，還打印了其它定時(shí)任務(wù)的輸出語(yǔ)句。

每天3點(diǎn)前，[Scheduling-1]線(xiàn)程在執(zhí)行本人寫(xiě)的5min一次的定時(shí)任務(wù)，3點(diǎn)后，[Scheduling-1]線(xiàn)程會(huì)執(zhí)行另一個(gè)比較耗時(shí)的定時(shí)任務(wù)，直到10點(diǎn)后，[Scheduling-1]線(xiàn)程才重新執(zhí)行5min一次的定時(shí)任務(wù)。

看來(lái)，確實(shí)是由于@Scheduled定時(shí)任務(wù)默認(rèn)使用單線(xiàn)程模式導(dǎo)致：一旦有一個(gè)定時(shí)任務(wù)比較耗時(shí)，就會(huì)影響到其它定時(shí)任務(wù)按時(shí)執(zhí)行。