首頁  >  文章  >  Java  >  Spring中@Async用法詳解及簡單實例介紹

Spring中@Async用法詳解及簡單實例介紹

黄舟
黄舟原創
2017-03-07 10:12:131631瀏覽

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

Spring中@Async用法

引言: 在Java應用中,絕大多數情況下都是透過同步的方式來實現交互處理的;但是在處理與第三方系統交互的時候,容易造成響應遲緩的情況,之前大部分都是使用多執行緒來完成此類任務,其實,在spring 3.x之後,就已經內建了@Async來完美解決這個問題,本文將完成介紹@Async的用法。

1.  何為非同步呼叫?

    在解釋非同步呼叫之前,我們先來看同步呼叫的定義;同步是整個處理過程順序執行,當各個過程都執行完畢,並且回傳結果。 非同步呼叫則只是發送了呼叫的指令,呼叫者無需等待被呼叫的方法完全執行完畢;而是繼續執行下面的流程。

     例如, 在某個調用中,需要順序調用A, B, C三個過程方法;如他們都是同步調用,則需要將他們都順序執行完畢之後,方算作過程執行完畢; 如B為一個非同步的呼叫方法,則在執行完A之後,呼叫B,並不等待B完成,而是執行開始呼叫C,待C執行完畢之後,就表示這個過程執行完畢了。

2.  常規的非同步呼叫處理方式

    在Java中,一般在處理類似的場景之時,都是基於創建獨立的執行緒去完成對應的非同步呼叫邏輯,透過主執行緒和不同的執行緒之間的執行流程,從而在啟動獨立的執行緒之後,主執行緒繼續執行而不會產生停滯等待的情況。

3. @Async介紹

   在Spring中,基於@Async標註的方法,稱為非同步方法;這些方法將在執行的時候,將會在獨立的執行緒中被執行,呼叫者無需等待它的完成,即可繼續其他的操作。

     如何在Spring中啟用@Async

       以Java設定為基礎的啟用方式:

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

##   


##

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

##  啟用方式,設定如下:

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

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

4. 基於@Async無回值呼叫

    範例如下:

@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; 
}

#  使用的方式非常簡單,一個標註即可解決所有的問題。

5. 基於@Async回傳值的呼叫

#   範例如下:

public void testAsyncAnnotationForMethodsWithReturnType() 
  throws InterruptedException, ExecutionException { 
  System.out.println("Invoking an asynchronous method. " 
   + Thread.currentThread().getName()); 
  Future<String> future = asyncAnnotationExample.asyncMethodWithReturnType(); 
  
  while (true) { ///这里使用了循环判断,等待获取结果信息 
    if (future.isDone()) { //判断是否执行完毕 
      System.out.println("Result from asynchronous process - " + future.get()); 
      break; 
    } 
    System.out.println("Continue doing something else. "); 
    Thread.sleep(1000); 
  } 
}

#   以上範例可以發現,傳回的資料類型為Future類型,其為一個介面。具體的結果類型為AsyncResult,這個是需要注意的地方。

   呼叫傳回結果的非同步方法範例:

public class ExceptionHandlingAsyncTaskExecutor implements AsyncTaskExecutor { 
  private AsyncTaskExecutor executor; 
  public ExceptionHandlingAsyncTaskExecutor(AsyncTaskExecutor executor) { 
    this.executor = executor; 
   } 
   ////用独立的线程来包装,@Async其本质就是如此 
  public void execute(Runnable task) {    
   executor.execute(createWrappedRunnable(task)); 
  } 
  public void execute(Runnable task, long startTimeout) { 
    /用独立的线程来包装,@Async其本质就是如此 
    executor.execute(createWrappedRunnable(task), startTimeout);      
  }  
  public Future submit(Runnable task) { return executor.submit(createWrappedRunnable(task)); 
    //用独立的线程来包装,@Async其本质就是如此。 
  }  
  public Future submit(final Callable task) { 
   //用独立的线程来包装,@Async其本质就是如此。 
    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); 
  } 
}

  分析: 這些取得非同步方法的結果訊息,是透過不停的檢查Future的狀態來取得目前的非同步方法是否執行完畢來實現的。

6. 基於@Async呼叫中的異常處理機制

    在非同步方法中,如果出現異常,對於呼叫者caller而言,是無法感知的。如果確實需要進行異常處理,則按照以下方法來處理:

    1.  自訂實作AsyncTaskExecutor的任務執行器

         在這裡定義處理特定例外狀況的邏輯和方式。

    2.  設定由自訂的TaskExecutor取代內建的任務執行器

    範例步驟1,自訂的TaskExecutor

<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" />

 分析: 可以發現其是實現了AsyncTaskExecutor, 用獨立的線程來執行具體的每個方法操作。在createCallable和createWrapperRunnable中,定義了異常的處理方式和機制。

handle()就是未來我們需要關注的異常處理的地方。

      設定檔中的內容:

rrreee

  分析: 這裡的設定使用自訂的taskExecutor來取代缺省的TaskExecutor。

7. @Async調用中的事務處理機制

#    在@Async標註的方法,同時也適用了@Transactional進行了標註;在其呼叫資料庫操作之時,將無法產生事務管理的控制,原因就在於其是基於非同步處理的操作。

     那該如何為這些作業新增事務管理呢?可以將需要事務管理操作的方法放置到非同步方法內部,在內部被呼叫的方法上新增@Transactional.######    例如:  方法A,使用了@Async/@Transactional來標註,但是無法產生事務控制的目的。 ###

          方法B,並使用了@Async來標註,  B中呼叫了C、D,C/D分別使用@Transactional做了標註,則可實現事務控制的目的。

8. 總結

     透過上述的描述,應該對@Async所使用的方法和注意事項了。

 以上就是Spring中@Async用法詳解及簡單實例介紹的內容,更多相關內容請關注PHP中文網(www.php.cn)!


#
陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn