JAX-WS 异步调用

在JAX-WS实现Glassfish上WebService的异步调用。

 

1.创建服务类

要调用服务，首先要有服务可以调用，我们就自己做一个简单的Web服务吧。

代码如下：

package com.sample; import javax.jws.WebMethod; import javax.jws.WebService; @WebService public class AddNumber { @WebMethod public int add(int a,int b){ return a+b; } }

将编译好的class文件打成war包后部署到Glassfish上。

 

2 创建client的异步调用

在JAX-WS中定义了两种标准接口：

1）javax.xml.ws.Response此接口继承Future<T>，提供了polling调用方法。

2）Javax.xml.ws.AsyncHandler，客户端实现此接口，接收结果使用异步的 callback。

 

 

2.1Polling client

1）撰写binding.xml文件，此文件利用jaxws:enableAsyncMapping绑定定义来设置

   允许异步调用。

 

<bindings xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/" wsdlLocation="http://localhost:8080/addNumber/AddNumberService?wsdl" xmlns="http://java.sun.com/xml/ns/jaxws"> <bindings node="wsdl:de<a href="/tag/Finitio/" target="_blank" class="keywords">Finitio</a>ns"> <enableAsyncMapping>true</enableAsyncMapping> </bindings> </bindings>

 2）接下来利用ijwsimport工具来生成客户端代码：

ijwsimport -keep  http://localhost/asytest/asynctestService?wsdl -b ./binding.xml

(其中binding.xml文件放在生成客户端代码的相同目录下。)

客户端测试代码如下：

package test; import com.sample.*; import javax.xml.ws.Response; public class AsyTest { public static void main(String [] args){ AddNumberService service=new AddNumberService(); AddNumber port=service.getAddNumberPort(); Response<AddResponse> asy=port.addAsync(1,2); while(!asy.isDone()){ Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("is not down"); } try{ AddResponse callNameResponse=asy.get(); int message=callNameResponse.getReturn(); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println(message); }catch(Exception ex){} } }

 

 

2.2 CallBack client 

 

由于此callBack当请求发出去以后当前的这个connection就会关闭 ,为了达到测试的目的，加入了sleep，让客户端程序等待服务器端得返回。

    callback类型的client要传入一个javax.xml.ws.AsyncHandler类型的匿名内部类，

当soap Message 到达时，Jax-ws会调handleResponse这个方法来处理response. 

客户端测试代码如下：

package test; import com.sample.*; import javax.xml.ws.AsyncHandler; import javax.xml.ws.Response; public class AsyCallTest { public static void main(String[]args) throws Exception{ AddNumberService service=new AddNumberService(); AddNumber port=service.getAddNumberPort(); port.addAsync(1,2,new AsyncHandler<AddResponse>(){ public void handleResponse(Response<AddResponse>res) { try { AddResponse response=null; response = res.get(); int message=response.getReturn(); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println(message); }catch(Exception e){ e.<a href="/tag/printstacktrace/" target="_blank" class="keywords">printstacktrace</a>(); }}}); Thread.sleep(10000); } }

 

 

以上就是利用JAX-WS进行Web服务的异步调用的两种方法。