JAVA 中Spring的@Async用法總結
JAVA 中Spring的@Async用法總結
引言： 在Java應用中，絕大多數(shù)情況下都是通過同步的方式來實現(xiàn)交互處理的；但是在處理與第三方系統(tǒng)交互的時候，容易造成響應遲緩的情況，之前大部分都是使用多線程來完成此類任務，其實，在spring 3.x之后，就已經內置了@Async來完美解決這個問題，本文將完成介紹@Async的用法。
1. 何為異步調用？
在解釋異步調用之前，我們先來看同步調用的定義；同步就是整個處理過程順序執(zhí)行，當各個過程都執(zhí)行完畢，并返回結果。 異步調用則是只是發(fā)送了調用的指令，調用者無需等待被調用的方法完全執(zhí)行完畢；而是繼續(xù)執(zhí)行下面的流程。
例如， 在某個調用中，需要順序調用 A, B, C三個過程方法；如他們都是同步調用，則需要將他們都順序執(zhí)行完畢之后，方算作過程執(zhí)行完畢； 如B為一個異步的調用方法，則在執(zhí)行完A之后，調用B，并不等待B完成，而是執(zhí)行開始調用C，待C執(zhí)行完畢之后，就意味著這個過程執(zhí)行完畢了。
2. 常規(guī)的異步調用處理方式
在Java中，一般在處理類似的場景之時，都是基于創(chuàng)建獨立的線程去完成相應的異步調用邏輯，通過主線程和不同的線程之間的執(zhí)行流程，從而在啟動獨立的線程之后，主線程繼續(xù)執(zhí)行而不會產生停滯等待的情況。
3. @Async介紹
在Spring中，基于@Async標注的方法，稱之為異步方法；這些方法將在執(zhí)行的時候，將會在獨立的線程中被執(zhí)行，調用者無需等待它的完成，即可繼續(xù)其他的操作。
如何在Spring中啟用@Async
基于Java配置的啟用方式：
@Configuration
@EnableAsync
public class SpringAsyncConfig { ... }
基于XML配置文件的啟用方式，配置如下：
<task:executor id="myexecutor" pool-size="5" /> <task:annotation-driven executor="myexecutor"/>
以上就是兩種定義的方式。
4. 基于@Async無返回值調用
示例如下：
@Async //標注使用
public void asyncMethodWithVoidReturnType() {
System.out.println("Execute method asynchronously. "
+ Thread.currentThread().getName());
}
使用的方式非常簡單，一個標注即可解決所有的問題。
5. 基于@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;
}
以上示例可以發(fā)現(xiàn)，返回的數(shù)據(jù)類型為Future類型，其為一個接口。具體的結果類型為AsyncResult,這個是需要注意的地方。
調用返回結果的異步方法示例：
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)判斷，等待獲取結果信息
if (future.isDone()) { //判斷是否執(zhí)行完畢
System.out.println("Result from asynchronous process - " + future.get());
break;
}
System.out.println("Continue doing something else. ");
Thread.sleep(1000);
}
}
分析： 這些獲取異步方法的結果信息，是通過不停的檢查Future的狀態(tài)來獲取當前的異步方法是否執(zhí)行完畢來實現(xiàn)的。
6. 基于@Async調用中的異常處理機制
在異步方法中，如果出現(xiàn)異常，對于調用者caller而言，是無法感知的。如果確實需要進行異常處理，則按照如下方法來進行處理：
1. 自定義實現(xiàn)AsyncTaskExecutor的任務執(zhí)行器
在這里定義處理具體異常的邏輯和方式。
2. 配置由自定義的TaskExecutor替代內置的任務執(zhí)行器
示例步驟1，自定義的TaskExecutor
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);
}
}
分析： 可以發(fā)現(xiàn)其是實現(xiàn)了AsyncTaskExecutor, 用獨立的線程來執(zhí)行具體的每個方法操作。在createCallable和createWrapperRunnable中，定義了異常的處理方式和機制。
handle()就是未來我們需要關注的異常處理的地方。
配置文件中的內容：
<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調用中的事務處理機制
在@Async標注的方法，同時也適用了@Transactional進行了標注；在其調用數(shù)據(jù)庫操作之時，將無法產生事務管理的控制，原因就在于其是基于異步處理的操作。
那該如何給這些操作添加事務管理呢？可以將需要事務管理操作的方法放置到異步方法內部，在內部被調用的方法上添加@Transactional.
例如： 方法A，使用了@Async/@Transactional來標注，但是無法產生事務控制的目的。
方法B，使用了@Async來標注， B中調用了C、D，C/D分別使用@Transactional做了標注，則可實現(xiàn)事務控制的目的。
8. 總結
通過以上的描述，應該對@Async使用的方法和注意事項了。
感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！
相關文章
SpringMVC中Model與Session的區(qū)別說明
這篇文章主要介紹了SpringMVC中Model與Session的區(qū)別說明，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-12-12
本篇文章主要介紹了IntelliJ IDEA 自定義方法注解模板，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-12-12
Java 的 java.time 包提供了強大的日期和時間處理功能,通過 DateTimeFormatter 可以輕松地在日期時間對象和字符串之間進行轉換,下面小編給大家詳細介紹一下Java中字符串轉時間與時間轉字符串的操作,需要的朋友可以參考下2025-04-04
ThreadLocal用來提供線程內部的局部變量，不同的線程之間不會相互干擾，這種變量在多線程環(huán)境下訪問時能保證各個線程的變量相對獨立于其他線程內的變量，在線程的生命周期內起作用，可以減少同一個線程內多個函數(shù)或組件之間一些公共變量傳遞的復雜度2022-08-08
這篇文章主要為大家詳細介紹了springboot+vue實現(xiàn)頁面下載文件，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2020-12-12
linux下idea、pycharm等輸入中文拼音時滿3個字母后無法繼續(xù)拼音輸入的問題
這篇文章主要介紹了linux下idea、pycharm等輸入中文拼音時滿3個字母后無法繼續(xù)拼音輸入的問題,本文通過圖文并茂的形式給大家分享解決方法，需要的朋友可以參考下2021-04-04
這篇文章主要介紹了JAVA流程控制語句的的相關資料，文中講解非常細致，代碼幫助大家更好的理解和學習，感興趣的朋友可以了解下2020-06-06
Spring 為Bean 的獲取提供了多種方式,通常包括4種方式,（也就是說在Spring中為Bean對象的創(chuàng)建準備了多種方案,目的是：更加靈活）,本文將通過代碼示例詳細的給大家介紹了一下這四種方式,需要的朋友可以參考下2024-04-04
java.lang.UnsupportedClassVersionError錯誤的解決辦法(附圖文)
這篇文章主要給大家介紹了關于java.lang.UnsupportedClassVersionError錯誤的解決辦法,"java.lang.UnsupportedClassVersionError"意味著您正在運行的Java版本與編譯該類時使用的Java版本不兼容,需要的朋友可以參考下2023-10-10
這篇文章主要為大家詳細介紹了JAVA每月運勢api調用代碼實例,具有一定的參考價值，感興趣的小伙伴們可以參考一下2016-09-09