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

?

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

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

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

?

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

? ? 在Java中，一般在處理類似的場景之時，都是基于創(chuàng)建獨立的線程去完成相應的異步調(diào)用邏輯，通過主線程和不同的線程之間的執(zhí)行流程，從而在啟動獨立的線程之后，主線程繼續(xù)執(zhí)行而不會產(chǎn)生停滯等待的情況。或是使用TaskExecutor執(zhí)行異步線程，參看http://www.cnblogs.com/wihainan/p/6098970.html。

?

3. @Async介紹

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

? ?如何在Spring中啟用@Async。基于Java配置的啟用方式：

1 @Configuration 2 @EnableAsync 3 public class SpringAsyncConfig { ... }

?

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

使用的方式非常簡單，一個標注即可解決所有的問題：

1 @Async //標注使用 2 public void asyncMethodWithVoidReturnType() { 3 System.out.println("Execute method asynchronously. " 4 + Thread.currentThread().getName()); 5 }

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

1 @Async 2 public Future<String> asyncMethodWithReturnType() { 3 System.out.println("Execute method asynchronously - " + Thread.currentThread().getName()); 4 try { 5 Thread.sleep(5000); 6 return new AsyncResult<String>("hello world !!!!"); 7 } catch (InterruptedException e) { 8 // 9 } 10 11 return null; 12 }

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

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

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

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

?

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

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

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

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

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

? ? 示例步驟1，自定義的TaskExecutor

?

1 public class ExceptionHandlingAsyncTaskExecutor implements AsyncTaskExecutor { 2 private AsyncTaskExecutor executor; 3 public ExceptionHandlingAsyncTaskExecutor(AsyncTaskExecutor executor) { 4 this.executor = executor; 5 } 6 用獨立的線程來包裝，@Async其本質(zhì)就是如此 7 public void execute(Runnable task) { 8 executor.execute(createWrappedRunnable(task)); 9 } 10 public void execute(Runnable task, long startTimeout) { 11 /用獨立的線程來包裝，@Async其本質(zhì)就是如此 12 executor.execute(createWrappedRunnable(task), startTimeout); 13 } 14 public Future submit(Runnable task) { return executor.submit(createWrappedRunnable(task)); 15 //用獨立的線程來包裝，@Async其本質(zhì)就是如此。 16 } 17 public Future submit(final Callable task) { 18 //用獨立的線程來包裝，@Async其本質(zhì)就是如此。 19 return executor.submit(createCallable(task)); 20 } 21 22 private Callable createCallable(final Callable task) { 23 return new Callable() { 24 public T call() throws Exception { 25 try { 26 return task.call(); 27 } catch (Exception ex) { 28 handle(ex); 29 throw ex; 30 } 31 } 32 }; 33 } 34 35 private Runnable createWrappedRunnable(final Runnable task) { 36 return new Runnable() { 37 public void run() { 38 try { 39 task.run(); 40 } catch (Exception ex) { 41 handle(ex); 42 } 43 } 44 }; 45 } 46 private void handle(Exception ex) { 47 //具體的異常邏輯處理的地方 48 System.err.println("Error during @Async execution: " + ex); 49 } 50 }

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

?handle()就是未來我們需要關注的異常處理的地方。?配置文件中的內(nèi)容：

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

?

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

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

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

? ? 例如： ?方法A，使用了@Async/@Transactional來標注，但是無法產(chǎn)生事務控制的目的。

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

不積跬步無以至千里

轉(zhuǎn)載于:https://www.cnblogs.com/zhangwufei/p/10036401.html

總結(jié)

以上是生活随笔為你收集整理的Spring中@Async的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。