[[396421]]

大家好，我是冰河~~

最近有小伙伴出去面試，回來跟我說：冰河，我去XXX公司面試，面試官竟然問了我一個關(guān)于Spring中Scheduled和Async調(diào)度的問題，我竟然沒回答上來，你能不能寫一篇關(guān)于這個問題的文章呢?我：可以，安排上!于是便有了這篇文章。

好了，我們開始正文吧~~

Spring調(diào)度的兩種方式

Spring提供了兩種后臺任務(wù)的方法,分別是:

• 調(diào)度任務(wù)，@Schedule
• 異步任務(wù)，@Async

當(dāng)然，使用這兩個是有條件的，需要在spring應(yīng)用的上下文中聲明當(dāng)然，如果我們是基于java配置的，需要在配置類上加@EnableScheduling和@EnableAsync注解，例如，下面的代碼片段。

@EnableScheduling 
@EnableAsync 
public class WebAppConfig { 
   .... 
｝ 

除此之外，還是有第三方庫可以調(diào)用的，例如Quartz，文章最后我們再簡單提下Quartz。

@Schedule調(diào)度

先看下@Schedule怎么調(diào)用再說。

public final static long ONE_DAY = 24 * 60 * 60 * 1000; 
public final static long ONE_HOUR = 60 * 60 * 1000; 
  
@Scheduled(fixedRate = ONE_DAY) 
public void scheduledTask() { 
   System.out.println(" 我是一個每隔一天就會執(zhí)行一次的調(diào)度任務(wù)"); 
} 
  
@Scheduled(fixedDelay = ONE_HOURS) 
public void scheduleTask2() { 
    System.out.println(" 我是一個執(zhí)行完后，隔一小時就會執(zhí)行的任務(wù)"); 
} 
  
@Scheduled(initialDelay=1000, fixedRate=5000) 
public void doSomething() { 
    // something that should execute periodically 
} 
  
@Scheduled(cron = "0 0/1 * * * ? ") 
public void ScheduledTask3() { 
    System.out.println(" 我是一個每隔一分鐘就就會執(zhí)行的任務(wù)"); 
} 

需要注意的是：

• 關(guān)于@Scheduled注解，里面使用的是Cron表達式，同時我們看到了兩個不一樣的面孔fixedDelay& fixedRate，前者fixedDelay表示在指定間隔運行程序，例如這個程序在今晚九點運行程序，跑完這個方法后的一個小時，就會再執(zhí)行一次，而后者fixedDelay是指，這個函數(shù)每隔一段時間就會被調(diào)用(我們這里設(shè)置的是一天)，不管再次調(diào)度的時候，這個方法是在運行還是結(jié)束了。而前者就要求是函數(shù)運行結(jié)束后開始計時的，這就是兩者區(qū)別。
• 這個還有一個initialDelay的參數(shù)，是第一次調(diào)用前需要等待的時間，這里表示被調(diào)用后的，推遲一秒再執(zhí)行，這適合一些特殊的情況。
• 我們在serviceImpl類寫這些調(diào)度任務(wù)時候，也需要在ServiceInterface的接口口中寫多個接口，不然會拋出but not found in any interface(s) for bean JDK proxy.Either pull the method up to an interface or 的異常。

@Async調(diào)度

有時候我們會調(diào)用一些特殊的任務(wù)，任務(wù)會比較耗時，重要的是，我們不管他返回的后果。這時候我們就需要用這類的異步任務(wù)啦，調(diào)用后就讓它去跑，不堵塞主線程，我們繼續(xù)干別的。代碼像下面這樣:

public void AsyncTask(){ 
    @Async 
    public void doSomeHeavyBackgroundTask(int sleepTime) { 
        try { 
            Thread.sleep(sleepTime); 
        } catch (InterruptedException e) { 
            e.printStackTrace(); 
        } 
    } 
    @Async 
    public Future<String> doSomeHeavyBackgroundTask() { 
        try { 
            Thread.sleep(3000); 
        } catch (InterruptedException e) { 
            e.printStackTrace(); 
        } 
        return null; 
    } 
      
    public void printLog() { 
         System.out.println(" i print a log ,time=" + System.currentTimeMillis()); 
    } 
  
} 

我們寫個簡單的測試類來測試下

@RunWith(SpringJUnit4ClassRunner.class) 
@WebAppConfiguration 
@ContextConfiguration(classes = AsycnTaskConfig.class) //要聲明@EnableASync 
public class AsyncTaskTest { 
    @Autowired 
    AsyncTask asyncTask; 
    @Test 
    public void AsyncTaskTest() throws InterruptedException { 
        if (asyncTask != null) { 
            asyncTask.doSomeHeavyBackgroundTask(4000); 
            asyncTask.printLog(); 
            Thread.sleep(5000); 
        } 
    } 
} 

這感覺比我們手動開線程方便多了，不想異步的話直接把@Async去掉就可以了，另外如果想要返回結(jié)果，需要使用Future<>接口。如果想修改Spring Boot的默認線程池配置，可以實現(xiàn)AsyncConfigurer。

需要注意的是：

• 相對于@scheduled，這個可以有參數(shù)和返回個結(jié)果，因為這個是我們調(diào)用的，而調(diào)度的任務(wù)是spring調(diào)用的。
• 異步方法不能內(nèi)部調(diào)用，只能像上面那樣，外部調(diào)用，否則就會變成阻塞主線程的同步任務(wù)啦!這里，給大家展示一個活生生的大坑!例如下面的代碼案例。

public void AsyncTask(){ 
    public void fakeAsyncTaskTest(){ 
        doSomeHeavyBackgroundTask(4000); 
        printLog(); 
        //你會發(fā)現(xiàn)，當(dāng)你像這樣內(nèi)部調(diào)用的時候，居然是同步執(zhí)行的，不是異步的！！ 
    } 
      
    @Async 
    public void doSomeHeavyBackgroundTask(int sleepTime) { 
        try { 
            Thread.sleep(sleepTime); 
        } catch (InterruptedException e) { 
            e.printStackTrace(); 
        } 
    } 
      
    public void printLog() { 
        System.out.println(" i print a log "); 
    } 
} 

另外一點就是不要重復(fù)的掃描，這也會導(dǎo)致異步無效，具體的可以看這個stackoveflow的spring-async-not-working Issue。

關(guān)于異常處理，難免在這個異步執(zhí)行過程中有異常發(fā)生，對于這個問題，Spring提供的解決方案如下,實現(xiàn) AsyncUncaughtExceptionHandler接口。

public class MyAsyncUncaughtExceptionHandler implements AsyncUncaughtExceptionHandler { 
    @Override 
    public void handleUncaughtException(Throwable ex, Method method, Object... params) { 
        // handle exception 
    } 
} 

寫好我們的異常處理后，我們需要配置一下，告訴Spring，這個異常處理就是我們在運行異步任務(wù)時候，拋出錯誤時的異常終結(jié)者。

@Configuration 
@EnableAsync 
public class AsyncConfig implements AsyncConfigurer { 
    @Bean 
    public AsyncTask asyncBean() { 
        return new AsyncTask(); 
    } 
      
    @Override 
    public Executor getAsyncExecutor() { 
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); 
        executor.setCorePoolSize(7); 
        executor.setMaxPoolSize(42); 
        executor.setQueueCapacity(11); 
        executor.setThreadNamePrefix("MyExecutor-"); 
        executor.initialize(); 
        return executor; 
    } 
      
    @Override 
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() { 
         return new MyAsyncUncaughtExceptionHandler(); 
    } 
} 

簡單聊下Quartz登場

Spring中除了@Scheduled和@Async注解外，還有一個和Spring整合的第三方庫叫Quartz，看了下官網(wǎng)的使用簡介，也是挺逗的，現(xiàn)在都習(xí)慣用Maven，Gradle之類來關(guān)系這些依賴了，他還叫人下載，也是不知為何，詳情點擊->http://quartz-scheduler.org/documentation/quartz-2.2.x/quick-start

估計有可能是因為沒再維護了的原因吧，看了下，最新版2.2居然是Sep, 2013更新的…

Quartz居然是停更了，不過Quartz作為一個企業(yè)級應(yīng)用的任務(wù)調(diào)度框架，還是一個可以的候選項目，作為其他方案的兜底方案。

這里不鋪開講，有興趣的小伙伴們就去官網(wǎng)看下吧。整體用起來感覺是沒有Spring自己的后臺任務(wù)方便，不過也可以接受，只需要簡單的配置就可以使用了。

本文轉(zhuǎn)載自微信公眾號「冰河技術(shù)  」，可以通過以下二維碼關(guān)注。轉(zhuǎn)載本文請聯(lián)系冰河技術(shù) 公眾號。