Axis2开发WebService客户端 的3种方式

前端之家收集整理的这篇文章主要介绍了Axis2开发WebService客户端 的3种方式前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

第一RPC方式,不生成客户端代码

第二,document方式,不生成客户端代码

第三,用wsdl2java工具,生成客户端方式调用

Java代码  
  1. package samples.quickstart.client;  
  2.   
  3. import javax.xml.namespace.QName;  
  4. import org.apache.axiom.om.OMAbstractFactory;  
  5. import org.apache.axiom.om.OMElement;  
  6. import org.apache.axiom.om.OMFactory;  
  7. import org.apache.axiom.om.OMNamespace;  
  8. import org.apache.axis2.AxisFault;  
  9. import org.apache.axis2.addressing.EndpointReference;  
  10. import org.apache.axis2.client.Options;  
  11. import org.apache.axis2.client.ServiceClient;  
  12. import org.apache.axis2.rpc.client.RPCServiceClient;  
  13. import samples.quickstart.StockQuoteServiceStub;  
  14. import samples.quickstart.xsd.GetPrice;  
  15. import samples.quickstart.xsd.GetPriceResponse;  
  16. public class StockQuoteClient {  
  17.   /** 
  18.    * 方法一: 
  19.    * 应用rpc的方式调用 这种方式就等于远程调用, 
  20.    * 即通过url定位告诉远程服务器,告知方法名称,参数等, 调用远程服务,得到结果。 
  21.    * 使用 org.apache.axis2.rpc.client.RPCServiceClient类调用WebService 
  22.    * 
  23.     【注】: 
  24.      
  25.         如果被调用的WebService方法有返回值 应使用 invokeBlocking 方法 该方法有三个参数 
  26.           第一个参数的类型是QName对象,表示要调用方法名; 
  27.           第二个参数表示要调用的WebService方法的参数值,参数类型为Object[]; 
  28.             当方法没有参数时,invokeBlocking方法的第二个参数值不能是null,而要使用new Object[]{}。 
  29.           第三个参数表示WebService方法的 返回值类型的Class对象,参数类型为Class[]。 
  30.          
  31.         如果被调用的WebService方法没有返回值 应使用 invokeRobust 方法 
  32.           该方法只有两个参数,它们的含义与invokeBlocking方法的前两个参数的含义相同。 
  33.  
  34.         在创建QName对象时,QName类的构造方法的第一个参数表示WSDL文件的命名空间名, 
  35.         也就是 <wsdl:definitions>元素的targetNamespace属性值。 
  36.    */  
  37.   static void testRPCClient() {  
  38.     try {  
  39.       // axis1 服务端  
  40. // String url = "http://localhost:8080/StockQuote/services/StockQuoteServiceSOAP11port?wsdl";  
  41. // axis2 服务端  
  42.       String url = "http://localhost:8080/axis2ServerDemo/services/StockQuoteService?wsdl";  
  43. // 使用RPC方式调用WebService  
  44.       RPCServiceClient serviceClient = new RPCServiceClient();  
  45. // 指定调用WebService的URL  
  46.       EndpointReference targetEPR = new EndpointReference(url);  
  47.       Options options = serviceClient.getOptions();  
  48. //确定目标服务地址  
  49.       options.setTo(targetEPR);  
  50. //确定调用方法  
  51.       options.setAction("urn:getPrice");  
  52.        * 指定要调用的getPrice方法及WSDL文件的命名空间 
  53.        * 如果 webservice 服务端由axis2编写 
  54.        * 命名空间 不一致导致的问题 
  55.        * org.apache.axis2.AxisFault: java.lang.RuntimeException: Unexpected subelement arg0 
  56.        */  
  57.       QName qname = new QName("http://quickstart.samples/xsd""getPrice");  
  58. // 指定getPrice方法的参数值  
  59.       Object[] parameters = new Object[] { "13" };  
  60.         
  61. // 指定getPrice方法返回值的数据类型的Class对象  
  62.       Class[] returnTypes = new Class[] { double.class };  
  63. // 调用方法一 传递参数,调用服务,获取服务返回结果集  
  64.       OMElement element = serviceClient.invokeBlocking(qname, parameters);  
  65. //值得注意的是,返回结果就是一段由OMElement对象封装的xml字符串。  
  66. //我们可以对之灵活应用,下面我取第一个元素值,并打印之。因为调用方法返回一个结果  
  67.       String result = element.getFirstElement().getText();  
  68.       System.out.println(result);  
  69. // 调用方法二 getPrice方法输出方法的返回值  
  70.       Object[] response = serviceClient.invokeBlocking(qname, parameters, returnTypes);  
  71. // String r = (String) response[0];  
  72.       Double r = (Double) response[0];  
  73.       System.out.println(r);  
  74.     } catch (AxisFault e) {  
  75.       e.printStackTrace();  
  76.     }  
  77.   }  
  78.    * 方法二: 应用document方式调用 
  79.    * 用ducument方式应用现对繁琐而灵活。现在用的比较多。因为真正摆脱了我们不想要的耦合 
  80. void testDocument() {  
  81. // String url = "http://localhost:8080/axis2ServerDemo/services/StockQuoteService";  
  82.       String url = "http://localhost:8080/StockQuote/services/StockQuoteServiceSOAP11port?wsdl";  
  83.       Options options = new Options();  
  84. // options.setAction("urn:getPrice");  
  85.       ServiceClient sender = new ServiceClient();  
  86.       sender.setOptions(options);  
  87.       OMFactory fac = OMAbstractFactory.getOMFactory();  
  88.       String tns = "http://quickstart.samples/";  
  89. // 命名空间,有时命名空间不增加没事,不过最好加上,因为有时有事,你懂的  
  90.       OMNamespace omNs = fac.createOMNamespace(tns, "");  
  91.       OMElement method = fac.createOMElement("getPrice", omNs);  
  92.       OMElement symbol = fac.createOMElement("symbol",0); padding:0px; margin:0px; width:auto; border:0px">// symbol.setText("1");  
  93.       symbol.addChild(fac.createOMText(symbol, "Axis2 Echo String "));  
  94.       method.addChild(symbol);  
  95.       method.build();  
  96.       OMElement result = sender.sendReceive(method);  
  97. catch (AxisFault axisFault) {  
  98.       axisFault.printStackTrace();  
  99.    * 为SOAP Header构造验证信息, 
  100.   * 如果你的服务端是没有验证的,那么你不用在Header中增加验证信息 
  101.   * 
  102.   * @param serviceClient 
  103.   * @param tns 命名空间 
  104.   * @param user 
  105.   * @param passwrod 
  106.   */  
  107. void addValidation(ServiceClient serviceClient, String tns , String user, String passwrod) {  
  108.     OMFactory fac = OMAbstractFactory.getOMFactory();  
  109.     OMNamespace omNs = fac.createOMNamespace(tns, "nsl");  
  110.     OMElement header = fac.createOMElement("AuthenticationToken",250); line-height:18px">     OMElement ome_user = fac.createOMElement("Username",250); line-height:18px">     OMElement ome_pass = fac.createOMElement("Password",250); line-height:18px">       
  111.     ome_user.setText(user);  
  112.     ome_pass.setText(passwrod);  
  113.     header.addChild(ome_user);  
  114.     header.addChild(ome_pass);  
  115.     serviceClient.addHeader(header);  
  116.     
  117.    * 方法三:利用axis2插件生成客户端方式调用 
  118. void testCodeClient() {  
  119.       String url = "http://localhost:8080/axis2ServerDemo/services/StockQuoteService";  
  120.       StockQuoteServiceStub stub = new StockQuoteServiceStub(url);  
  121.       GetPrice request = new GetPrice();  
  122.       request.setSymbol("ABCD");  
  123.       GetPriceResponse response = stub.getPrice(request);  
  124.       System.out.println(response.get_return());  
  125. catch (org.apache.axis2.AxisFault e) {  
  126. catch (java.rmi.RemoteException e) {  
  127. void main(String[] args) {  
  128.      StockQuoteClient.testRPCClient();  
  129. // StockQuoteClient.testDocument();  
  130.     // StockQuoteClient.testCodeClient();  
  131. }  

 

wsdl2java 用于根据WSDL生成相应的服务端和客户端代码生成工具。
命令行格式为:WSDL2Java [options] -uri <url or path> : A url or path to a WSDL

例如:

wsdl2java -uri http://localhost:8080/cxfService_0617/services/Hellows?wsdl -s -o build\client

其中常用的options具体如下:
-o <path> : 指定生成代码输出路径
-a : 生成异步模式的代码
-s : 生成同步模式的代码
-p <pkg> : 指定代码的package名称
-l <languange> : 使用的语言(Java/C) 默认是java -t : 为代码生成测试用例 -ss : 生成服务端代码 默认不生成 -sd : 生成服务描述文件 services.xml,仅与-ss一同使用 -d <databinding> : 指定databingding,例如,adb,xmlbean,jibx,jaxme and jaxbri -g : 生成服务端和客户端的代码 -pn <port_name> : 当WSDL中有多个port时,指定其中一个port -sn <serv_name> : 选择WSDL中的一个service -u : 展开data-binding的类 -r <path> : 为代码生成指定一个repository -ssi : 为服务端实现代码生成接口类 -S : 为生成的源码指定存储路径 -R : 为生成的resources指定存储路径 –noBuildXML : 输出不生成build.xml文件 –noWSDL : 在resources目录中不生成WSDL文件 –noMessageReceiver : 不生成MessageReceiver类

猜你在找的WebService相关文章