AXIS2 webservice客户端调用服务端的三种方式

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

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

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

Java代码  


package samples.quickstart.client;  

  

import javax.xml.namespace.QName;  

import org.apache.axiom.om.OMAbstractFactory;  

import org.apache.axiom.om.OMElement;  

import org.apache.axiom.om.OMFactory;  

import org.apache.axiom.om.OMNamespace;  

import org.apache.axis2.AxisFault;  

import org.apache.axis2.addressing.EndpointReference;  

import org.apache.axis2.client.Options;  

import org.apache.axis2.client.ServiceClient;  

import org.apache.axis2.rpc.client.RPCServiceClient;  

import samples.quickstart.StockQuoteServiceStub;  

import samples.quickstart.xsd.GetPrice;  

import samples.quickstart.xsd.GetPriceResponse;  

  

public class StockQuoteClient {  

  

  /** 

   * 方法一： 

   * 应用rpc的方式调用 这种方式就等于远程调用， 

   * 即通过url定位告诉远程服务器，告知方法名称，参数等， 调用远程服务，得到结果。 

   * 使用 org.apache.axis2.rpc.client.RPCServiceClient类调用WebService 

   * 

    【注】： 

     

        如果被调用的WebService方法有返回值 应使用 invokeBlocking 方法 该方法有三个参数 

          第一个参数的类型是QName对象，表示要调用的方法名； 

          第二个参数表示要调用的WebService方法的参数值，参数类型为Object[]； 

            当方法没有参数时，invokeBlocking方法的第二个参数值不能是null，而要使用new Object[]{}。 

          第三个参数表示WebService方法的 返回值类型的Class对象，参数类型为Class[]。 

         

         

        如果被调用的WebService方法没有返回值 应使用 invokeRobust 方法 

          该方法只有两个参数，它们的含义与invokeBlocking方法的前两个参数的含义相同。 

 

        在创建QName对象时，QName类的构造方法的第一个参数表示WSDL文件的命名空间名， 

        也就是 <wsdl:definitions>元素的targetNamespace属性值。 

   * 

   */  

  public static void testRPCClient() {  

    try {  

      // axis1 服务端  

// String url = "http://localhost:8080/StockQuote/services/StockQuoteServiceSOAP11port?wsdl";  

      // axis2 服务端  

      String url = "http://localhost:8080/axis2ServerDemo/services/StockQuoteService?wsdl";  

  

      // 使用RPC方式调用WebService  

      RPCServiceClient serviceClient = new RPCServiceClient();  

      // 指定调用WebService的URL  

      EndpointReference targetEPR = new EndpointReference(url);  

      Options options = serviceClient.getOptions();  

      //确定目标服务地址  

      options.setTo(targetEPR);  

      //确定调用方法  

      options.setAction("urn:getPrice");  

  

      /** 

       * 指定要调用的getPrice方法及WSDL文件的命名空间 

       * 如果 webservice 服务端由axis2编写 

       * 命名空间 不一致导致的问题 

       * org.apache.axis2.AxisFault: java.lang.RuntimeException: Unexpected subelement arg0 

       */  

      QName qname = new QName("http://quickstart.samples/xsd", "getPrice");  

      // 指定getPrice方法的参数值  

      Object[] parameters = new Object[] { "13" };  

        

      // 指定getPrice方法返回值的数据类型的Class对象  

      Class[] returnTypes = new Class[] { double.class };  

  

      // 调用方法一 传递参数，调用服务，获取服务返回结果集  

      OMElement element = serviceClient.invokeBlocking(qname, parameters);  

      //值得注意的是，返回结果就是一段由OMElement对象封装的xml字符串。  

      //我们可以对之灵活应用,下面我取第一个元素值，并打印之。因为调用的方法返回一个结果  

      String result = element.getFirstElement().getText();  

      System.out.println(result);  

  

      // 调用方法二 getPrice方法并输出该方法的返回值  

      Object[] response = serviceClient.invokeBlocking(qname, parameters, returnTypes);  

      // String r = (String) response[0];  

      Double r = (Double) response[0];  

      System.out.println(r);  

  

    } catch (AxisFault e) {  

      e.printStackTrace();  

    }  

  }  

  

  /** 

   * 方法二： 应用document方式调用 

   * 用ducument方式应用现对繁琐而灵活。现在用的比较多。因为真正摆脱了我们不想要的耦合 

   */  

  public static void testDocument() {  

    try {  

      // String url = "http://localhost:8080/axis2ServerDemo/services/StockQuoteService";  

      String url = "http://localhost:8080/StockQuote/services/StockQuoteServiceSOAP11port?wsdl";  

  

      Options options = new Options();  

      // 指定调用WebService的URL  

      EndpointReference targetEPR = new EndpointReference(url);  

      options.setTo(targetEPR);  

      // options.setAction("urn:getPrice");  

  

      ServiceClient sender = new ServiceClient();  

      sender.setOptions(options);  

        

        

      OMFactory fac = OMAbstractFactory.getOMFactory();  

      String tns = "http://quickstart.samples/";  

      // 命名空间，有时命名空间不增加没事，不过最好加上，因为有时有事，你懂的  

      OMNamespace omNs = fac.createOMNamespace(tns, "");  

  

      OMElement method = fac.createOMElement("getPrice", omNs);  

      OMElement symbol = fac.createOMElement("symbol", omNs);  

      // symbol.setText("1");  

      symbol.addChild(fac.createOMText(symbol, "Axis2 Echo String "));  

      method.addChild(symbol);  

      method.build();  

        

      OMElement result = sender.sendReceive(method);  

  

      System.out.println(result);  

  

    } catch (AxisFault axisFault) {  

      axisFault.printStackTrace();  

    }  

  }  

  

 /** 

  * 为SOAP Header构造验证信息， 

  * 如果你的服务端是没有验证的，那么你不用在Header中增加验证信息 

  * 

  * @param serviceClient 

  * @param tns 命名空间 

  * @param user 

  * @param passwrod 

  */  

  public void addValidation(ServiceClient serviceClient, String tns , String user, String passwrod) {  

    OMFactory fac = OMAbstractFactory.getOMFactory();  

    OMNamespace omNs = fac.createOMNamespace(tns, "nsl");  

    OMElement header = fac.createOMElement("AuthenticationToken", omNs);  

    OMElement ome_user = fac.createOMElement("Username", omNs);  

    OMElement ome_pass = fac.createOMElement("Password", omNs);  

      

    ome_user.setText(user);  

    ome_pass.setText(passwrod);  

      

    header.addChild(ome_user);  

    header.addChild(ome_pass);  

  

    serviceClient.addHeader(header);  

  }  

  

    

  /** 

   * 方法三：利用axis2插件生成客户端方式调用 

   * 

   */  

  public static void testCodeClient() {  

    try {  

      String url = "http://localhost:8080/axis2ServerDemo/services/StockQuoteService";  

      StockQuoteServiceStub stub = new StockQuoteServiceStub(url);  

      GetPrice request = new GetPrice();  

      request.setSymbol("ABCD");  

      GetPriceResponse response = stub.getPrice(request);  

      System.out.println(response.get_return());  

    } catch (org.apache.axis2.AxisFault e) {  

      e.printStackTrace();  

    } catch (java.rmi.RemoteException e) {  

      e.printStackTrace();  

    }  

  

  }  

  

  public static void main(String[] args) {  

     StockQuoteClient.testRPCClient();  

// StockQuoteClient.testDocument();  

    // StockQuoteClient.testCodeClient();  

  

  }  

}  

 

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类