生活随笔
收集整理的這篇文章主要介紹了
Spring中@Async用法总结
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
轉(zhuǎn)載自?https://blog.csdn.net/blueheart20/article/details/44648667
引言： 在Java應(yīng)用中，絕大多數(shù)情況下都是通過同步的方式來實(shí)現(xiàn)交互處理的；但是在處理與第三方系統(tǒng)交互的時(shí)候，容易造成響應(yīng)遲緩的情況，之前大部分都是使用多線程來完成此類任務(wù)，其實(shí)，在Spring 3.x之后，就已經(jīng)內(nèi)置了@Async來完美解決這個(gè)問題，本文將完成介紹@Async的用法。
1. ?何為異步調(diào)用？
? ? 在解釋異步調(diào)用之前，我們先來看同步調(diào)用的定義；同步就是整個(gè)處理過程順序執(zhí)行，當(dāng)各個(gè)過程都執(zhí)行完畢，并返回結(jié)果。 異步調(diào)用則是只是發(fā)送了調(diào)用的指令，調(diào)用者無需等待被調(diào)用的方法完全執(zhí)行完畢；而是繼續(xù)執(zhí)行下面的流程。
? ? ?例如， 在某個(gè)調(diào)用中，需要順序調(diào)用 A, B, C三個(gè)過程方法；如他們都是同步調(diào)用，則需要將他們都順序執(zhí)行完畢之后，方算作過程執(zhí)行完畢； 如B為一個(gè)異步的調(diào)用方法，則在執(zhí)行完A之后，調(diào)用B，并不等待B完成，而是執(zhí)行開始調(diào)用C，待C執(zhí)行完畢之后，就意味著這個(gè)過程執(zhí)行完畢了。
2. ?常規(guī)的異步調(diào)用處理方式
? ? 在Java中，一般在處理類似的場景之時(shí)，都是基于創(chuàng)建獨(dú)立的線程去完成相應(yīng)的異步調(diào)用邏輯，通過主線程和不同的線程之間的執(zhí)行流程，從而在啟動(dòng)獨(dú)立的線程之后，主線程繼續(xù)執(zhí)行而不會(huì)產(chǎn)生停滯等待的情況。
3. @Async介紹
? ?在Spring中，基于@Async標(biāo)注的方法，稱之為異步方法；這些方法將在執(zhí)行的時(shí)候，將會(huì)在獨(dú)立的線程中被執(zhí)行，調(diào)用者無需等待它的完成，即可繼續(xù)其他的操作。
? ? ?如何在Spring中啟用@Async
? ? ? ?基于Java配置的啟用方式：
[html]?view plaincopy
@Configuration??@EnableAsync??public?class?SpringAsyncConfig?{?...?}??
? ? ?基于XML配置文件的啟用方式，配置如下：
[html]?view plaincopy
<task:executor?id="myexecutor"?pool-size="5"??/>??<task:annotation-driven?executor="myexecutor"/>??
? ?以上就是兩種定義的方式。
4. 基于@Async無返回值調(diào)用
? ? 示例如下：
[html]?view plaincopy
@Async??//標(biāo)注使用??public?void?asyncMethodWithVoidReturnType()?{??????System.out.println("Execute?method?asynchronously.?"????????+?Thread.currentThread().getName());??}??
? 使用的方式非常簡單，一個(gè)標(biāo)注即可解決所有的問題。
5. 基于@Async返回值的調(diào)用
? ?示例如下：
[html]?view plaincopy
@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é)果的異步方法示例：
[html]?view plaincopy
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é)果信息，是通過不停的檢查Future的狀態(tài)來獲取當(dāng)前的異步方法是否執(zhí)行完畢來實(shí)現(xiàn)的。
6. 基于@Async調(diào)用中的異常處理機(jī)制
? ? 在異步方法中，如果出現(xiàn)異常，對(duì)于調(diào)用者caller而言，是無法感知的。如果確實(shí)需要進(jìn)行異常處理，則按照如下方法來進(jìn)行處理：
? ? 1. ?自定義實(shí)現(xiàn)AsyncTaskExecutor的任務(wù)執(zhí)行器
? ? ? ? ?在這里定義處理具體異常的邏輯和方式。
? ? 2. ?配置由自定義的TaskExecutor替代內(nèi)置的任務(wù)執(zhí)行器
? ? 示例步驟1，自定義的TaskExecutor
[html]?view plaincopy
public?class?ExceptionHandlingAsyncTaskExecutor?implements?AsyncTaskExecutor?{??????private?AsyncTaskExecutor?executor;??????public?ExceptionHandlingAsyncTaskExecutor(AsyncTaskExecutor?executor)?{??????????this.executor?=?executor;???????}????????用獨(dú)立的線程來包裝，@Async其本質(zhì)就是如此??????public?void?execute(Runnable?task)?{?????????????executor.execute(createWrappedRunnable(task));??????}??????public?void?execute(Runnable?task,?long?startTimeout)?{??????????/用獨(dú)立的線程來包裝，@Async其本質(zhì)就是如此?????????executor.execute(createWrappedRunnable(task),?startTimeout);???????????????}???????public?Future?submit(Runnable?task)?{?return?executor.submit(createWrappedRunnable(task));?????????//用獨(dú)立的線程來包裝，@Async其本質(zhì)就是如此。??????}???????public?Future?submit(final?Callable?task)?{????????//用獨(dú)立的線程來包裝，@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ú)立的線程來執(zhí)行具體的每個(gè)方法操作。在createCallable和createWrapperRunnable中，定義了異常的處理方式和機(jī)制。
handle()就是未來我們需要關(guān)注的異常處理的地方。
? ? ? 配置文件中的內(nèi)容：
[html]?view plaincopy
<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來替代缺省的TaskExecutor。
7. @Async調(diào)用中的事務(wù)處理機(jī)制
? ? 在@Async標(biāo)注的方法，同時(shí)也適用了@Transactional進(jìn)行了標(biāo)注；在其調(diào)用數(shù)據(jù)庫操作之時(shí)，將無法產(chǎn)生事務(wù)管理的控制，原因就在于其是基于異步處理的操作。
? ? ?那該如何給這些操作添加事務(wù)管理呢？可以將需要事務(wù)管理操作的方法放置到異步方法內(nèi)部，在內(nèi)部被調(diào)用的方法上添加@Transactional.
? ? 例如： ?方法A，使用了@Async/@Transactional來標(biāo)注，但是無法產(chǎn)生事務(wù)控制的目的。
? ? ? ? ? 方法B，使用了@Async來標(biāo)注， ?B中調(diào)用了C、D，C/D分別使用@Transactional做了標(biāo)注，則可實(shí)現(xiàn)事務(wù)控制的目的。
8. 總結(jié)
? ? ?通過以上的描述，應(yīng)該對(duì)@Async使用的方法和注意事項(xiàng)了。
總結(jié)
以上是生活随笔為你收集整理的Spring中@Async用法总结的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。
