CXF之用Dispatch处理异步调用实例

服务接口：

package cxf.server; import javax.jws.WebService; @WebService public interface HelloWorld { String sayHi(String text); }  

 

服务接口实现：

package cxf.server; import javax.jws.WebService; @WebService(endpointInterface = "cxf.server.HelloWorld") public class HelloWorldImpl implements HelloWorld { public String sayHi(String text) { try { Thread.sleep(30); } catch (InterruptedException e) { e.<a href="/tag/printstacktrace/" target="_blank" class="keywords">printstacktrace</a>(); } Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("sayHi called"); return "Hello " + text; } }  

 

服务端配置:

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/<a href="/tag/springbean/" target="_blank" class="keywords">spring-bean</a>s.xsd http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"> <import resource="cla<a href="/tag/ssp/" target="_blank" class="keywords">ssp</a>ath:<a href="/tag/metainf/" target="_blank" class="keywords">meta-inf</a>/cxf/cxf.xml" /> <import resource="cla<a href="/tag/ssp/" target="_blank" class="keywords">ssp</a>ath:<a href="/tag/metainf/" target="_blank" class="keywords">meta-inf</a>/cxf/cxf-extension-soap.xml" /> <import resource="cla<a href="/tag/ssp/" target="_blank" class="keywords">ssp</a>ath:<a href="/tag/metainf/" target="_blank" class="keywords">meta-inf</a>/cxf/cxf-servlet.xml" /> <jaxws:server id="helloWorld" serviceClass="cxf.server.HelloWorld" address="/HelloWorld"> <jaxws:serviceBean> <bean class="cxf.server.HelloWorldImpl"/> </jaxws:serviceBean> <jaxws:features> <bean class="org.apache.cxf.feature.LoggingFeature"/> </jaxws:features> </jaxws:server> </beans>  

 

客户端调用1---轮询方式异步调用：

package cxf.client; import java.io.InputStream; import java.net.URL; import javax.xml.namespace.QName; import javax.xml<a href="/tag/so/" target="_blank" class="keywords">.so</a>ap.MessageFactory; import javax.xml<a href="/tag/so/" target="_blank" class="keywords">.so</a>ap<a href="/tag/so/" target="_blank" class="keywords">.so</a>APMessage; import javax.xml.transform.dom.DOMSource; import javax.xml.ws.<a href="/tag/dis/" target="_blank" class="keywords">dis</a>patch; import javax.xml.ws.Response; import javax.xml.ws.Service; public final class Client1 { public static void main(String args[]) throws Exception { URL wsdlUrl = new URL("http://localhost:8085/cxf-<a href="/tag/dis/" target="_blank" class="keywords">dis</a>patch-test/service/HelloWorld?wsdl"); QName serviceName = new QName("http://server.cxf/","HelloWorldService"); Service service = Service.create(wsdlUrl,serviceName); QName portName = new QName("http://server.cxf/","HelloWorldPort"); <a href="/tag/dis/" target="_blank" class="keywords">dis</a>patch<DOMSource> <a href="/tag/dis/" target="_blank" class="keywords">dis</a>p = service.create<a href="/tag/dis/" target="_blank" class="keywords">dis</a>patch(portName,DOMSource.class,Service.Mode.MESSAGE); InputStream input = Client1.class.getResourceA<a href="/tag/sst/" target="_blank" class="keywords">sst</a>ream("soap1.xml"); MessageFactory factory = MessageFactory.newInstance (); SOAPMessage soapMessage = factory.createMessage(null,input); DOMSource dom = new DOMSource(soapMessage.getSOAPPart()); //轮询方式 Response<DOMSource> rsp = <a href="/tag/dis/" target="_blank" class="keywords">dis</a>p.invokeAsync(dom); while(!rsp.isDone()){ Thread.sleep(5); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("sleep 5"); } DOMSource d<a href="/tag/omr/" target="_blank" class="keywords">omr</a>sp = rsp.get(); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println(d<a href="/tag/omr/" target="_blank" class="keywords">omr</a>sp.getNode().getLastChild().getNodeName()); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println(d<a href="/tag/omr/" target="_blank" class="keywords">omr</a>sp.getNode().getLastChild().getTextContent()); } }  

 

客户端调用2---回调方式异步调用：

package cxf.client; import java.io.InputStream; import java.net.URL; import java.util.concurrent.Future; import javax.xml.namespace.QName; import javax.xml<a href="/tag/so/" target="_blank" class="keywords">.so</a>ap.MessageFactory; import javax.xml<a href="/tag/so/" target="_blank" class="keywords">.so</a>ap<a href="/tag/so/" target="_blank" class="keywords">.so</a>APMessage; import javax.xml.ws.<a href="/tag/dis/" target="_blank" class="keywords">dis</a>patch; import javax.xml.ws.Service; public final class Client2 { public static void main(String args[]) throws Exception { URL wsdlUrl = new URL("http://localhost:8085/cxf-<a href="/tag/dis/" target="_blank" class="keywords">dis</a>patch-test/service/HelloWorld?wsdl"); QName serviceName = new QName("http://server.cxf/","HelloWorldPort"); <a href="/tag/dis/" target="_blank" class="keywords">dis</a>patch<SOAPMessage> <a href="/tag/dis/" target="_blank" class="keywords">dis</a>p = service.create<a href="/tag/dis/" target="_blank" class="keywords">dis</a>patch(portName,SOAPMessage.class,Service.Mode.MESSAGE); InputStream input = Client2.class.getResourceA<a href="/tag/sst/" target="_blank" class="keywords">sst</a>ream("soap1.xml"); MessageFactory factory = MessageFactory.newInstance (); SOAPMessage soapMessage = factory.createMessage(null,input); MyAsyncHandler<SOAPMessage> handler = new MyAsyncHandler<SOAPMessage>(); //回调方式 Future<?> rsp = <a href="/tag/dis/" target="_blank" class="keywords">dis</a>p.invokeAsync(soapMessage,handler); while(!rsp.isDone()){ Thread.sleep(5); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("aaaaaaa"); } SOAPMessage soapRsp = (SOAPMessage)rsp.get(); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println(soapRsp.getSOAPBody().getNodeName()); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println(soapRsp.getSOAPBody().getLastChild().getTextContent()); } }  

 

回调方式的AsyncHandler实现类:

package cxf.client; import javax.xml.ws.AsyncHandler; import javax.xml.ws.Response; public class MyAsyncHandler<T> implements AsyncHandler<T> { /** * 这个回调类必须实现handleResponse()<a href="/tag/fangfa/" target="_blank" class="keywords">方法</a>，它被<a href="/tag/diaoyong/" target="_blank" class="keywords">调用</a>由CXF运行时<a href="/tag/tongzhi/" target="_blank" class="keywords">通知</a>客户端响应已经到达。 */ @Override public void handleResponse(Response<T> res) { Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("eeeeee"); } }  

 

请求的xml数据：soap1.xml

<?xml version="1.0" encoding="utf-8" ?> <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/" xmlns:SOAP-ENC="http://schemas.xmlsoap.org/soap/encoding/" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:xsd="http://www.w3.org/2001/XMLSchema"> <SOAP-ENV:Body> <m:sayHi xmlns:m="http://server.cxf/"> <arg0>I like you!aha!!</arg0> </m:sayHi> </SOAP-ENV:Body> </SOAP-ENV:Envelope>  

 

 

还有一个单向调用(OneWay)

 

当一个请求不需要一个响应的时候，你的远程调用可以使用dispatch对象上的invokeOneWay()方法。略。