快捷導(dǎo)航

Spring中@Async用法詳解及簡(jiǎn)單實(shí)例

更新時(shí)間：2017年02月10日 14:20:06 投稿：lqh

這篇文章主要介紹了Spring中@Async用法詳解及簡(jiǎn)單實(shí)例的相關(guān)資料,需要的朋友可以參考下

Spring中@Async用法

引言：在Java應(yīng)用中，絕大多數(shù)情況下都是通過(guò)同步的方式來(lái)實(shí)現(xiàn)交互處理的；但是在處理與第三方系統(tǒng)交互的時(shí)候，容易造成響應(yīng)遲緩的情況，之前大部分都是使用多線程來(lái)完成此類任務(wù)，其實(shí)，在spring 3.x之后，就已經(jīng)內(nèi)置了@Async來(lái)完美解決這個(gè)問(wèn)題，本文將完成介紹@Async的用法。

1. 何為異步調(diào)用？

在解釋異步調(diào)用之前，我們先來(lái)看同步調(diào)用的定義；同步就是整個(gè)處理過(guò)程順序執(zhí)行，當(dāng)各個(gè)過(guò)程都執(zhí)行完畢，并返回結(jié)果。異步調(diào)用則是只是發(fā)送了調(diào)用的指令，調(diào)用者無(wú)需等待被調(diào)用的方法完全執(zhí)行完畢；而是繼續(xù)執(zhí)行下面的流程。

例如，在某個(gè)調(diào)用中，需要順序調(diào)用 A, B, C三個(gè)過(guò)程方法；如他們都是同步調(diào)用，則需要將他們都順序執(zhí)行完畢之后，方算作過(guò)程執(zhí)行完畢；如B為一個(gè)異步的調(diào)用方法，則在執(zhí)行完A之后，調(diào)用B，并不等待B完成，而是執(zhí)行開(kāi)始調(diào)用C，待C執(zhí)行完畢之后，就意味著這個(gè)過(guò)程執(zhí)行完畢了。

2. 常規(guī)的異步調(diào)用處理方式

在Java中，一般在處理類似的場(chǎng)景之時(shí)，都是基于創(chuàng)建獨(dú)立的線程去完成相應(yīng)的異步調(diào)用邏輯，通過(guò)主線程和不同的線程之間的執(zhí)行流程，從而在啟動(dòng)獨(dú)立的線程之后，主線程繼續(xù)執(zhí)行而不會(huì)產(chǎn)生停滯等待的情況。

3. @Async介紹

在Spring中，基于@Async標(biāo)注的方法，稱之為異步方法；這些方法將在執(zhí)行的時(shí)候，將會(huì)在獨(dú)立的線程中被執(zhí)行，調(diào)用者無(wú)需等待它的完成，即可繼續(xù)其他的操作。

如何在Spring中啟用@Async

基于Java配置的啟用方式：

@Configuration 
@EnableAsync 
public class SpringAsyncConfig { ... }

基于XML配置文件的啟用方式，配置如下：

<task:executor id="myexecutor" pool-size="5" /> 
<task:annotation-driven executor="myexecutor"/>

以上就是兩種定義的方式。

4. 基于@Async無(wú)返回值調(diào)用

示例如下：

@Async //標(biāo)注使用 
public void asyncMethodWithVoidReturnType() { 
  System.out.println("Execute method asynchronously. " 
   + Thread.currentThread().getName()); 
}

使用的方式非常簡(jiǎn)單，一個(gè)標(biāo)注即可解決所有的問(wèn)題。

5. 基于@Async返回值的調(diào)用

示例如下：

@Async 
public Future<String> asyncMethodWithReturnType() { 
  System.out.println("Execute method asynchronously - " 
   + Thread.currentThread().getName()); 
  try { 
    Thread.sleep(5000); 
    return new AsyncResult<String>("hello world !!!!"); 
  } catch (InterruptedException e) { 
    // 
  } 
  
  return null; 
}

以上示例可以發(fā)現(xiàn)，返回的數(shù)據(jù)類型為Future類型，其為一個(gè)接口。具體的結(jié)果類型為AsyncResult,這個(gè)是需要注意的地方。

調(diào)用返回結(jié)果的異步方法示例：

public void testAsyncAnnotationForMethodsWithReturnType() 
  throws InterruptedException, ExecutionException { 
  System.out.println("Invoking an asynchronous method. " 
   + Thread.currentThread().getName()); 
  Future<String> future = asyncAnnotationExample.asyncMethodWithReturnType(); 
  
  while (true) { ///這里使用了循環(huán)判斷，等待獲取結(jié)果信息 
    if (future.isDone()) { //判斷是否執(zhí)行完畢 
      System.out.println("Result from asynchronous process - " + future.get()); 
      break; 
    } 
    System.out.println("Continue doing something else. "); 
    Thread.sleep(1000); 
  } 
}

分析：這些獲取異步方法的結(jié)果信息，是通過(guò)不停的檢查Future的狀態(tài)來(lái)獲取當(dāng)前的異步方法是否執(zhí)行完畢來(lái)實(shí)現(xiàn)的。

6. 基于@Async調(diào)用中的異常處理機(jī)制

在異步方法中，如果出現(xiàn)異常，對(duì)于調(diào)用者caller而言，是無(wú)法感知的。如果確實(shí)需要進(jìn)行異常處理，則按照如下方法來(lái)進(jìn)行處理：

1. 自定義實(shí)現(xiàn)AsyncTaskExecutor的任務(wù)執(zhí)行器

在這里定義處理具體異常的邏輯和方式。

2. 配置由自定義的TaskExecutor替代內(nèi)置的任務(wù)執(zhí)行器

示例步驟1，自定義的TaskExecutor

public class ExceptionHandlingAsyncTaskExecutor implements AsyncTaskExecutor { 
  private AsyncTaskExecutor executor; 
  public ExceptionHandlingAsyncTaskExecutor(AsyncTaskExecutor executor) { 
    this.executor = executor; 
   } 
   ////用獨(dú)立的線程來(lái)包裝，@Async其本質(zhì)就是如此 
  public void execute(Runnable task) {    
   executor.execute(createWrappedRunnable(task)); 
  } 
  public void execute(Runnable task, long startTimeout) { 
    /用獨(dú)立的線程來(lái)包裝，@Async其本質(zhì)就是如此 
    executor.execute(createWrappedRunnable(task), startTimeout);      
  }  
  public Future submit(Runnable task) { return executor.submit(createWrappedRunnable(task)); 
    //用獨(dú)立的線程來(lái)包裝，@Async其本質(zhì)就是如此。 
  }  
  public Future submit(final Callable task) { 
   //用獨(dú)立的線程來(lái)包裝，@Async其本質(zhì)就是如此。 
    return executor.submit(createCallable(task));  
  }  
   
  private Callable createCallable(final Callable task) {  
    return new Callable() {  
      public T call() throws Exception {  
         try {  
           return task.call();  
         } catch (Exception ex) {  
           handle(ex);  
           throw ex;  
          }  
         }  
    };  
  } 
 
  private Runnable createWrappedRunnable(final Runnable task) {  
     return new Runnable() {  
       public void run() {  
         try { 
           task.run();  
         } catch (Exception ex) {  
           handle(ex);  
          }  
      } 
    };  
  }  
  private void handle(Exception ex) { 
   //具體的異常邏輯處理的地方 
   System.err.println("Error during @Async execution: " + ex); 
  } 
}

分析：可以發(fā)現(xiàn)其是實(shí)現(xiàn)了AsyncTaskExecutor, 用獨(dú)立的線程來(lái)執(zhí)行具體的每個(gè)方法操作。在createCallable和createWrapperRunnable中，定義了異常的處理方式和機(jī)制。

handle()就是未來(lái)我們需要關(guān)注的異常處理的地方。

配置文件中的內(nèi)容：

<task:annotation-driven executor="exceptionHandlingTaskExecutor" scheduler="defaultTaskScheduler" /> 
<bean id="exceptionHandlingTaskExecutor" class="nl.jborsje.blog.examples.ExceptionHandlingAsyncTaskExecutor"> 
  <constructor-arg ref="defaultTaskExecutor" /> 
</bean> 
<task:executor id="defaultTaskExecutor" pool-size="5" /> 
<task:scheduler id="defaultTaskScheduler" pool-size="1" />

分析：這里的配置使用自定義的taskExecutor來(lái)替代缺省的TaskExecutor。

7. @Async調(diào)用中的事務(wù)處理機(jī)制

在@Async標(biāo)注的方法，同時(shí)也適用了@Transactional進(jìn)行了標(biāo)注；在其調(diào)用數(shù)據(jù)庫(kù)操作之時(shí)，將無(wú)法產(chǎn)生事務(wù)管理的控制，原因就在于其是基于異步處理的操作。

那該如何給這些操作添加事務(wù)管理呢？可以將需要事務(wù)管理操作的方法放置到異步方法內(nèi)部，在內(nèi)部被調(diào)用的方法上添加@Transactional.

例如：方法A，使用了@Async/@Transactional來(lái)標(biāo)注，但是無(wú)法產(chǎn)生事務(wù)控制的目的。

方法B，使用了@Async來(lái)標(biāo)注， B中調(diào)用了C、D，C/D分別使用@Transactional做了標(biāo)注，則可實(shí)現(xiàn)事務(wù)控制的目的。

8. 總結(jié)

通過(guò)以上的描述，應(yīng)該對(duì)@Async使用的方法和注意事項(xiàng)了。

感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！

您可能感興趣的文章: