JAVA項(xiàng)目中Spring如何正確的使用@Async?很多新手對(duì)此不是很清楚,為了幫助大家解決這個(gè)難題,下面小編將為大家詳細(xì)講解,有這方面需求的人可以來(lái)學(xué)習(xí)下,希望你能有所收獲。
讓客戶滿意是我們工作的目標(biāo),不斷超越客戶的期望值來(lái)自于我們對(duì)這個(gè)行業(yè)的熱愛(ài)。我們立志把好的技術(shù)通過(guò)有效、簡(jiǎn)單的方式提供給客戶,將通過(guò)不懈努力成為客戶在信息化領(lǐng)域值得信任、有價(jià)值的長(zhǎng)期合作伙伴,公司提供的服務(wù)項(xiàng)目有:域名申請(qǐng)、虛擬主機(jī)、營(yíng)銷軟件、網(wǎng)站建設(shè)、靈山網(wǎng)站維護(hù)、網(wǎng)站推廣。
JAVA 中Spring的@Async用法總結(jié)
引言: 在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ù)控制的目的。
看完上述內(nèi)容是否對(duì)您有幫助呢?如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章,請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道,感謝您對(duì)創(chuàng)新互聯(lián)的支持。
網(wǎng)頁(yè)題目:JAVA項(xiàng)目中Spring如何正確的使用@Async
分享URL:http://bm7419.com/article34/jcepse.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供ChatGPT、網(wǎng)站收錄、建站公司、網(wǎng)站導(dǎo)航、手機(jī)網(wǎng)站建設(shè)、靜態(tài)網(wǎng)站
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來(lái)源: 創(chuàng)新互聯(lián)