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:definitions"> <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()){ System.out.println("is not down"); } try{ AddResponse callNameResponse=asy.get(); int message=callNameResponse.getReturn(); System.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(); System.out.println(message); }catch(Exception e){ e.printStackTrace(); }}}); Thread.sleep(10000); } }

?

?

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