spring中@Async的用法
在Java應用中,絕大多數情況下都是通過同步的方式來實現互動處理的;但是在處理與第三方系統互動的時候,容易造成響應遲緩的情況,之前大部分都是使用多執行緒來完成此類任務,其實,在spring 3.x之後,就已經內建了@Async來完美解決這個問題,本文將完成介紹@Async的用法。
1. 何為非同步呼叫?
在解釋非同步呼叫之前,我們先來看同步呼叫的定義;同步就是整個處理過程順序執行,當各個過程都執行完畢,並返回結果。 非同步呼叫則是隻是傳送了呼叫的指令,呼叫者無需等待被呼叫的方法完全執行完畢;而是繼續執行下面的流程。
例如, 在某個呼叫中,需要順序呼叫 A, B, C三個過程方法;如他們都是同步呼叫,則需要將他們都順序執行完畢之後,方算作過程執行完畢; 如B為一個非同步的呼叫方法,則在執行完A之後,呼叫B,並不等待B完成,而是執行開始呼叫C,待C執行完畢之後,就意味著這個過程執行完畢了。
2. 常規的非同步呼叫處理方式
在Java中,一般在處理類似的場景之時,都是基於建立獨立的執行緒去完成相應的非同步呼叫邏輯,通過主執行緒和不同的執行緒之間的執行流程,從而在啟動獨立的執行緒之後,主執行緒繼續執行而不會產生停滯等待的情況。或是使用TaskExecutor執行非同步執行緒,參看http://www.cnblogs.com/wihainan/p/6098970.html。
3. @Async介紹
在Spring中,基於@Async標註的方法,稱之為非同步方法;這些方法將在執行的時候,將會在獨立的執行緒中被執行,呼叫者無需等待它的完成,即可繼續其他的操作。
如何在Spring中啟用@Async。基於Java配置的啟用方式:
@Configuration
@EnableAsync
public class SpringAsyncConfig { ... }
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;
}
以上示例可以發現,返回的資料型別為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) { ///這裡使用了迴圈判斷,等待獲取結果資訊
if (future.isDone()) { //判斷是否執行完畢
System.out.println("Result from asynchronous process - " + future.get());
break;
}
System.out.println("Continue doing something else. ");
Thread.sleep(1000);
}
}
這些獲取非同步方法的結果資訊,是通過不停的檢查Future的狀態來獲取當前的非同步方法是否執行完畢來實現的。
6. 基於@Async呼叫中的異常處理機制
在非同步方法中,如果出現異常,對於呼叫者caller而言,是無法感知的。如果確實需要進行異常處理,則按照如下方法來進行處理:
1. 自定義實現AsyncTaskExecutor的任務執行器
在這裡定義處理具體異常的邏輯和方式。
2. 配置由自定義的TaskExecutor替代內建的任務執行器
示例步驟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);
}
}
分析: 可以發現其是實現了AsyncTaskExecutor, 用獨立的執行緒來執行具體的每個方法操作。在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" />
7. @Async呼叫中的事務處理機制
在@Async標註的方法,同時也適用了@Transactional進行了標註;在其呼叫資料庫操作之時,將無法產生事務管理的控制,原因就在於其是基於非同步處理的操作。
那該如何給這些操作新增事務管理呢?可以將需要事務管理操作的方法放置到非同步方法內部,在內部被呼叫的方法上新增@Transactional.
例如: 方法A,使用了@Async/@Transactional來標註,但是無法產生事務控制的目的。
方法B,使用了@Async來標註, B中呼叫了C、D,C/D分別使用@Transactional做了標註,則可實現事務控制的目的。
相關推薦
Spring中@Async用法詳解及簡單例項
Spring中@Async用法 引言: 在Java應用中,絕大多數情況下都是通過同步的方式來實現互動處理的;但是在處理與第三方系統互動的時候,容易造成響應遲緩的情況,之前大部分都是使用多執行緒來完成此類任務,其實,在spring 3.x之後,就已經內建了@Async來完美解決這個問題,本文將完成
Spring中@Async用法總結
引言: 在Java應用中,絕大多數情況下都是通過同步的方式來實現互動處理的;但是在處理與第三方系統互動的時候,容易造成響應遲緩的情況,之前大部分都是使用多執行緒來完成此類任務,其實,在Spring 3.x之後,就已經內建了@Async來完美解決這個問題,本文將完成介紹@As
spring中@Async的用法
在Java應用中,絕大多數情況下都是通過同步的方式來實現互動處理的;但是在處理與第三方系統互動的時候,容易造成響應遲緩的情況,之前大部分都是使用多執行緒來完成此類任務,其實,在spring 3.x之後,就已經內建了@Async來完美解決這個問題,本文將完成介紹@
Spring中@Async
在Java應用中,絕大多數情況下都是通過同步的方式來實現互動處理的;但是在處理與第三方系統互動的時候,容易造成響應遲緩的情況,之前大部分都是使用多執行緒來完成此類任務,其實,在spring 3.x之後,就已經內建了@Async來完美解決這個問題 1. 何為非同
Spring中@Async註解實現“方法”的非同步呼叫
簡單介紹: Spring為任務排程與非同步方法執行提供了註解支援。通過在方法上設定@Async註解,可使得方法被非同步呼叫。也就是說呼叫者會在呼叫時立即返回,而被呼叫方法的實際執行是交給Spring的TaskExecutor來完成。 開啟@Async註解: <task:annotation
es6中async用法
async函式返回一個Promise物件,async函式可以看作多個非同步操作,包裝成的一個Promise物件,而await命令就是內部then命令的語法糖 1. async 函式的語法 async函式內部return語句的返回值,會成為then方法回撥函式的引數 a
腳本引用中使用defer和async用法和區別
兩個 不依賴 doc 體驗 html 中文 htm 停止 其他 是的,就是在頁面腳本引用的時候設置defer或者async,為什麽會有這兩個屬相來輔助腳本加載那,因為瀏覽器在遇到script標簽的時候,文檔的解析會停止,不再構建document,有時打開一個網頁上會出現空
spring 中 @import的用法
get abstract strac new artifact png release ide rac 第一步: 新建Java工程 FirstSpringJAVA 第二步:導入相關的spring jar包 <dependency> &l
SpringBoot | 第十一章:Spring中application.properties用法大全
對 Spring 裡面的 Properties 不理解的開發者可能會覺得有點亂,主要是因為配置方式很多種,使用方式也很多種。 本文不是原理分析、原始碼分析文章,只是希望可以幫助讀者更好地理解和使用 Spring Properties。 Properties 的使用 先來看看 Prop
ES6或ES7 中async函式的用法,通過一段程式碼理解它的用法
ES6或ES7 中async函式的用法,一行一行看完程式碼和後面的解釋,應該就會用了吧 首先,如果不懂Promise的用法,那可能你看不懂這裡寫的async的用法。 上面是async使用例子,async是非同步操作的新方案,asyncPrint函式中第21行的
Spring中ApplicationContextAware介面用法
載入Spring配置檔案時,如果Spring配置檔案中所定義的Bean類,如果該類實現了ApplicationContextAware介面,那麼在載入Spring配置檔案時,會自動呼叫ApplicationContextAware介面中的 public void setAp
spring中使用@Async註解進行非同步處理
引言: 在Java應用中,絕大多數情況下都是通過同步的方式來實現互動處理的;但是在處理與第三方系統互動的時候,容易造成響應遲緩的情況,之前大部分都是使用多執行緒來完成此類任務,其實,在spring 3.x之後,就已經內建了@Async來完美解決這個問題,本文將完成介紹@A
Spring中jdbcTemplate的用法例項(一)
一、首先配置JdbcTemplate; 要使用Jdbctemplate 物件來完成jdbc 操作。通常情況下,有三種種方式得到JdbcTemplate 物件。 第一種方式:我們可以在自己定義的DAO 實現類中注入一個DataSource 引用來完 成Jdbc
Spring中基於Java的配置@Configuration和@Bean用法
Spring中為了減少xml中配置,可以宣告一個配置類(例如SpringConfig)來對bean進行配置。 一、首先,需要xml中進行少量的配置來啟動Java配置: <?xml version="1.0" encoding="UTF-8"?> <bea
Spring中factory-method的用法
1. 通過靜態方法例項化一個bean,例項化出來的bean的型別對應於靜態方法的返回型別,這地點不同於普通的bean (1) 靜態方法無引數: <bean id="thefmbean" class="springtest.FactoryMethodBean
spring中的task用法案例
spring定時任務一 在xml中加上定時任務的名稱空間。程式碼:1. xmlns:task="http://www.springframework.org/schema/task"2. http://www.springframework.org/schema/task h
Spring中Assert工具類的用法
Spring在提供一個強大的應用開發框架的同時也提供了很多優秀的開發工具類,合理的運用這些工具,將有助於提高開發效率、增強程式碼質量。下面就最常用的Assert工具類,簡要介紹一下它的用法。 Assert斷言工具類,通常用於資料合法性檢查,在JAVA程式設計中,通常會
Spring中 lookup-method 用法
1、官方文件解釋 If the method is abstract, the dynamically-generated subclass implements the method. Otherwise, the dynamically-generated subcla
Spring.net 在mvc中的用法
1. 引dll檔案:Common.Loggong ,Spring.Core,Spring.Web ,Spring.Web.Mvc3 2. Global中public classMvcApplication : Spring.Web.Mvc.SpringM
spring中jdbc.properties用法
jdbc.properties程式碼: jdbc.driverClassName=oracle.jdbc.driver.OracleDriver jdbc.url=jdbc:oracle:thin:@10.10.1.1:1521:ORCL jdbc.username=tes