【发布时间】：2014-08-11 11:01:57
【问题描述】：
我需要调用一个响应时间非常长（秒）的 WS - 在他们这边没有实现任何轮询/回调机制。
我认为最有效的方法是在收到响应时使用非阻塞 io 和某种回调机制。由于我们主要使用 Spring 和 CXF，我开始了一个概念验证项目来测试我的概念和配置本身。
幸运的是，有一个用于 cxf 的 HttpAsyncClient，并且有很好的教程如何配置它。但是在某些时候我卡住了：使用同步模式没问题，但是当我想使用回调时，它会抛出以下异常：
javax.xml.ws.WebServiceException: Could not find wsdl:binding operation info for web method getDataFromWebServiceAsync.
at org.apache.cxf.jaxws.JaxWsClientProxy.invoke(JaxWsClientProxy.java:126)
at com.sun.proxy.$Proxy46.getDataFromWebServiceAsync(Unknown Source)
ws接口：
@WebService
public interface SampleWebService {
public Person getDataFromWebService(@WebParam String id);
public Future<?> getDataFromWebServiceAsync(@WebParam String id, @WebParam(name = "asyncHandler", targetNamespace = "") AsyncHandler<Person> asyncHandler);
}
客户端测试（作为 TestNG 测试实现）：
@Test(threadPoolSize = 5, invocationCount = 100)
public void testMultithreadedNonBlockingSampleWs()
throws InterruptedException, ExecutionException {
client.getDataFromWebServiceAsync("" + id.getAndIncrement(),
new AsyncHandler<Person>() {
@Override
public void handleResponse(Response<Person> resp) {
Person person;
try {
person = resp.get();
log.info(person.getName() + " | " + person.getAge()
+ " | " + person.getDescription());
Assert.assertNotNull(person);
Assert.assertNotNull(person.getName());
} catch (InterruptedException | ExecutionException e) {
log.error("EXCEPTION WHILE PROCESSING RESPONSE CALLBACK");
e.printStackTrace();
}
}
});
}
服务器端spring配置：
<jaxws:endpoint id="sampleService"
implementor="my.sample.SampleWebServiceImpl" address="/SampleWebService" />
客户端spring配置：
<jaxws:client id="client"
serviceClass="my.sample.SampleWebService"
address="http://localhost:8080/sample-ws-cxf/SampleWebService">
<jaxws:properties>
<entry key="javax.xml.ws.client.connectionTimeout" value="10" />
<entry key="javax.xml.ws.client.receiveTimeout" value="11000" />
<entry key="org.apache.cxf.transport.http.async.usePolicy" value="ALWAYS" />
<entry key="org.apache.cxf.transport.http.async.ioThreadCount" value="2" />
</jaxws:properties>
</jaxws:client>
从文章中我发现不清楚这种（非阻塞回调）是否真的可行，或者只有轮询/回调机制才能工作。只有这篇文章指出： http://czechscala.wordpress.com/2013/05/13/non-blocking-soap-web-services-invocation/
现在有人可以澄清一下吗？ 有什么方法可以做到这一点？ 或者以合理的方式处理长时间运行的 WS 调用的任何解决方案？
【问题讨论】：
-
我将“getDataFromWebServiceAsync”重命名为“getDataFromWebService_Async”，但没有任何改变。是否会导致我使用 java2wsdl 并且不知道如何在 Java 端反映“enableAsyncMapping”的问题？但我不应该需要它，因为正如我之前所说，在服务器端没有实现轮询/回调：我需要在客户端有一个简单的非阻塞解决方案。
-
我刚刚发现了这个非常相似的未解决问题：stackoverflow.com/questions/5910660/…。我正在使用 cxf 3.0.1，以及带有 spring 3.2.2.RELEASE 的 httpasyncclient 版本 4.0.1。
-
如果我称之为同步方式，没有错误，它说它使用 AsyncHTTPConduit: log.info("*** Conduit: "+ClientProxy.getClient(client).getConduit( ).getClass().getName());但我需要用回调来调用它。以同步方式调用非阻塞 IO 没有任何好处。提示？
标签： spring web-services cxf nonblocking