常用的调用方式是基于cxf和axis2两种方式,推荐使用cxf方式,其中cxf动态调用和静态调用两种方式,而axis2则有三种方式,第一RPC方式,不生成客户端代码,第二,document方式,不生成客户端代码,第三,用wsdl2java工具,生成客户端方式调用,

CXF方式

静态方式

示例:
首先根据wsdl创建服务类

@WebService(targetNamespace="http://tempuri.org/")
public interface WssWorkFlowSoap {
    
    @WebResult(name = "StartOAWorkFlowResult",targetNamespace="http://tempuri.org/")
    @WebMethod(action = "http://tempuri.org/StartOAWorkFlow")
    public String StartOAWorkFlow(@WebParam(name = "userCode") String userCode, 
      @WebParam(name = "templateIdOrCode") String templateIdOrCode,
      @WebParam(name = "formData") String formData,@WebParam(name = "title") String title);

    @WebMethod(action="http://infservice.ws.oa.service/forEquipmentPurRequest")
    @WebResult(name = "oaApproveResult",targetNamespace="http://infservice.ws.oa.service/")
    public String forEquipmentPurRequest(
      @WebParam(targetNamespace="http://infservice.ws.oa.service/",name="oaApproveResult")
      String oaApproveResult);
    
}

调用类

@RequestMapping(value = "${frontPath}/demo")
public class DemoController extends BaseController {


    @RequestMapping(value = {"list", ""})
    @ResponseBody
    public String list() {

        JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();  
        // 要提供服务端的接口  
        factory.setServiceClass(HelloWorldDao.class);  
        factory.setAddress("http://127.0.0.1:8080/usc/ws/helloworld?wsdl");  
        HelloWorldDao hw = (HelloWorldDao) factory.create();  
        String result = hw.sayHello();
        System.out.println(result);
        
        JaxWsProxyFactoryBean factory1 = new JaxWsProxyFactoryBean();  
        // 要提供服务端的接口  
        factory1.setServiceClass(WssWorkFlowSoap.class);  
        factory1.setAddress("http://10.160.18.32:8010/svc/wssWorkFLow.asmx?wsdl");  
        WssWorkFlowSoap h1w = (WssWorkFlowSoap) factory1.create();  
        String result1 = h1w.HelloWorld();
                String formData = this.getFormData();
        String result2 = h1w.StartOAWorkFlow("hftest", "sbzccgsqdsplc", formData, "");
    
        return result;
    }

动态方式

示例:

JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
        org.apache.cxf.endpoint.Client client = dcf
                .createClient("http://localhost:7002/card/services/HelloWorld?wsdl");
        // url为调用webService的wsdl地址
        QName name = new QName("http://dao.xcf.digitalchina.com/", "sayHello");
        // namespace是命名空间,methodName是方法名
        String xmlStr = "aaaaaaaa";
        // paramvalue为参数值
        Object[] objects;
        try {
            objects = client.invoke(name, xmlStr);
            System.out.println(objects[0].toString());
        } catch (Exception e) {
            e.printStackTrace();
        }

区别:
静态调用需要依赖service类,因为客户端调用cxf webservice接口的过程中需要服务器端提供service,很不方便,如果同一个项目中则没有区别。动态调用完全不依赖service类,服务器端只要提供接口名和路径就可以方便的调用。

AXIS2方式

axis2用的比较多的是document方式,相关代码如下:

/**
    * @Description: TODO
    * @param  key2Endpoint url在conf.xml中的key  例子:/root/hisWebservice
    * @param  key2TargetNamespace targetNamespace在conf.xml中的key  例子:/root/targetNamespace
    * @param  key2MethodName methodName在conf.xml中的key  例子:/root/methodName
    * @param  message      格式:String
    * @return String    返回类型 
     */
    public String sendMessageStringByKey(String key2Endpoint, String key2TargetNamespace, String key2MethodName,
            String message) {
        return sendMessageString(getUrl(key2Endpoint), getUrl(key2TargetNamespace), getUrl(key2MethodName), message);
    }
    
public String sendMessageString(String endpoint, String targetNamespace, String methodName, String message) {
        String responseContent = null;
        try {
            Options options = new Options();
            EndpointReference targetEPR = new EndpointReference(endpoint);
            options.setTo(targetEPR);
            options.setAction("");
            options.setProperty(Configuration.DISABLE_SOAP_ACTION, true);
             ServiceClient sender = new ServiceClient();  
             sender.setOptions(options);      
             
             OMFactory fac = OMAbstractFactory.getOMFactory(); 
             OMNamespace omNs = fac.createOMNamespace(targetNamespace, "");  
             OMNamespace omNs1 = fac.createOMNamespace("", "");  
             
             OMElement method = fac.createOMElement(methodName, omNs);  
             OMElement symbol = fac.createOMElement("DATA", omNs1);
             symbol.setText(message);
             method.addChild(symbol);
            responseContent =   sender.sendReceive(method).toString();
        } catch (AxisFault e) {    
            e.printStackTrace();
        }
        
        return responseContent;
    }

三种方式演示如下:
以下是摘自AXIS2 webservice客户端调用服务端的三种方式

     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 : A url or path to a WSDL

例如:

wsdl2java -uri http://localhost:8080/cxfService_0617/services/Hellows?wsdl -s -o buildclient

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

Last modification:October 17th, 2018 at 06:02 pm