40.5. 使用回调方法实施同步客户端
概述
进行异步操作调用的替代方法是实施回调类。然后,您可以调用将回调对象用作参数的异步远程方法。运行时将响应返回到回调对象。
要实现使用回调的应用程序,请执行以下操作:
创建 实现 AsyncHandler 接口的回调类。
注意您的回调对象可以执行应用程序所需的任何响应处理。
-
使用
operationNameAsync()
进行远程调用,它将回调对象用作参数,并返回Future<?>
对象。 如果您的客户端需要访问响应数据,您可以轮询返回的
Future<?&
gt; 对象的isDone()
方法,以查看远程端点是否已发送响应。如果回调对象执行所有响应处理,则不需要检查响应是否已到达。
实现回调
回调类必须实施 javax.xml.ws.AsyncHandler 接口。接口定义了单一方法: 处理Response
Response<T
> 重新调用 handleResponse()
方法,以通知响应到达的客户端。例 40.8 “javax.xml.ws.AsyncHandler Interface” 展示了您必须实现的 AsyncHandler 接口的概述。
例 40.8. javax.xml.ws.AsyncHandler Interface
public interface javax.xml.ws.AsyncHandler { void handleResponse(Response<T> res) }
例 40.9 “回调实施类” 显示 例 40.1 “用于同步示例的 WSDL 合同” 中定义的 greetMeSometime 操作的回调类。
例 40.9. 回调实施类
package demo.hw.client; import javax.xml.ws.AsyncHandler; import javax.xml.ws.Response; import org.apache.hello_world_async_soap_http.types.*; public class GreeterAsyncHandler implements AsyncHandler<GreetMeSometimeResponse> { private GreetMeSometimeResponse reply; public void handleResponse(Response<GreetMeSometimeResponse> response) { try { reply = response.get(); } catch (Exception ex) { ex.printStackTrace(); } } public String getResponse() { return reply.getResponseType(); } }
例 40.9 “回调实施类” 中显示的回调实现执行以下操作:
定义一个成员变量 响应
,其中包含从远程端点返回的响应。
实施 handleResponse()
。
这种实施只是提取响应,并将其分配给成员变量 回复
。
实施名为 getResponse()
的方法。
此方法是一种方便的方法,从 回复中提取数据
并返回。
实施消费者
例 40.10 “同步操作调用的回调方法” 演示了使用回调方法对 例 40.1 “用于同步示例的 WSDL 合同” 中定义的 GreetMeSometime 操作进行异步调用的客户端。
例 40.10. 同步操作调用的回调方法
package demo.hw.client; import java.io.File; import java.util.concurrent.Future; import javax.xml.namespace.QName; import javax.xml.ws.Response; import org.apache.hello_world_async_soap_http.*; public final class Client { ... public static void main(String args[]) throws Exception { ... // Callback approach GreeterAsyncHandler callback = new GreeterAsyncHandler(); Future<?> response = port.greetMeSometimeAsync(System.getProperty("user.name"), callback); while (!response.isDone()) { // Do some work } resp = callback.getResponse(); ... System.exit(0); } }
例 40.10 “同步操作调用的回调方法” 中的代码执行以下操作:
实例化回调对象。
调用 greetMeSometimeAsync()
,它获取代理上的回调对象。
方法调用会立即将 Future<?
> 对象返回到客户端。Apache CXF 运行时处理从远程端点接收回复的详细信息,调用回调对象的 handleResponse()
方法,并填充 Response< GreetMeSomesponse>
对象。
运行时会将请求传输到远程端点的 greetMeSometime()
方法,并处理调用的异步性质而不了解远程端点的知识。端点,因此,服务实施不需要担心客户端是否要等待响应的详细信息。
使用返回的 Future<?
> 对象的 isDone()
方法检查响应是否从远程端点到达。
调用 callback 对象的 getResponse()
方法以获取响应数据。