下一個(gè)示例將演示Spring容器內(nèi)部的異步方法調(diào)用。 為什么我們需要異步方法調(diào)用？ 在某些情況下，我們并不真正知道是否需要重播或何時(shí)應(yīng)返回結(jié)果。 傳統(tǒng)方式在Java EE的異步處理世界中，使用隊(duì)列/主題。 我們可以在Spring中進(jìn)行相同的操作，但是如果需要簡單的異步調(diào)用，則可以按照以下步驟輕松地進(jìn)行操作：

1.聲明

<bean id="executionLogicImpl"class="com.test.components.execution_gateway.ExecutionLogicImpl"abstract="false" lazy-init="default" autowire="default"></bean>

2.聲明具有返回類型的接口方法– Future（Java 5+）：

有關(guān)Future對象的更多信息： http : //docs.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/Future.html

public interface ExecutionLogic {public Future<String> doSomeExecutionLogic(String message);}

*當(dāng)GatewayProxyFactoryBean注意到返回類型為Future時(shí)，它將通過讓AsyncTaskExecutor將方法切換到異步模式

3.我們將創(chuàng)建一個(gè)作業(yè)通道，該通道將收集所有請求并將它們異步發(fā)送到另一個(gè)類（ExecutionLogicImpl），以便處理它們（一些隨機(jī)的業(yè)務(wù)邏輯）：

<int:channel id="job1Channel" /><int:service-activator input-channel="job1Channel" ref="executionLogicImpl" method="doSomeExecutionLogic" />

類ExecutionLogicImpl：

public class ExecutionLogicImpl {public String doSomeExecutionLogic(String msg){try{System.out.println("doing long work on message="+msg);Thread.sleep(8000);}catch (InterruptedException e){// TODO Auto-generated catch blocke.printStackTrace();}return msg + "_completed";}}

測試類別：

import com.test.components.execution_gateway.ExecutionLogic;public class testExeceution{... ExecutionLogic executionLogic; public String sendMsgToExecutionQueue(String msg){Future<String> processedMessage = executionLogic.doSomeExecutionLogic(msg);String finalResult = "";try{finalResult = " " + processedMessage.get(TIMEOUT, TimeUnit.SECONDS);return "1 final result: " + finalResult; // + " " + response;}catch (ExecutionException e){return "1 final result: " + e + finalResult;// + " " + response;}catch (TimeoutException tex){return "1 final result: " + tex + finalResult; // + " " + response;}catch (Exception ex){return "1 final result: " + ex + finalResult;// + " " + response;}} ... }

*對于永遠(yuǎn)不會返回響應(yīng)的情況，可以使用Future對象啟用超時(shí)。

那么這里發(fā)生了什么？ 我們發(fā)送輸入以異步執(zhí)行。 一旦請求完成處理，發(fā)送方將立即等待響應(yīng)（響應(yīng)），結(jié)果將被發(fā)送回發(fā)送方。

參考： IdanFridman.com博客上的JCG合作伙伴 Idan Fridman 在Spring中使用Future對象調(diào)用Async方法調(diào)用 。

翻譯自: https://www.javacodegeeks.com/2013/06/invoking-async-method-call-using-future-object-in-spring.html

總結(jié)

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

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