手动拼接SOAP消息调用webservice

 

SOAP消息的组成：

 

 

1、创建需要发送的SOAP消息的XML(add方法为例子)

/**     * 创建访问add方法的SOAP消息的xml     */    @Test    public void test1(){        try {            //1、创建消息工厂            MessageFactory factory = MessageFactory.newInstance();            //2、根据消息工厂创建SoapMessage            SOAPMessage message = factory.createMessage();            //3、创建SOAPPart            SOAPPart part = message.getSOAPPart();            //4、获取SOAPENvelope            SOAPEnvelope envelope = part.getEnvelope();            //5、可以通过SoapEnvelope有效的获取相应的Body和Header等信息            SOAPBody body = envelope.getBody();            //6、根据Qname创建相应的节点(QName就是一个带有命名空间的)            QName qname = new QName("http://ws01.yzl.com",                     "add","ns");//
     
      这里指定ns是前缀，必须指定，随便定义即可，不定义这消息将无效            //如果使用以下方式进行设置，会见<>转换为<和>            //body.addBodyElement(qname).setValue("
      1
      2");            SOAPBodyElement ele = body.addBodyElement(qname);            ele.addChildElement("a").setValue("22");            ele.addChildElement("b").setValue("33");            //打印消息信息            message.writeTo(System.out);        } catch (Exception e) {            e.printStackTrace();        }    }
     

结果为下：

     
      
      
       
        22
        33
       
      
     

 

2、提交创建的SOAP消息的xml到服务器端与其进行通信

2.1、使用SOAPMessage和Service.Mode.MESSAGE的方式发送消息

/**     * 发送add方法的SOAP的消息并接受解析返回的soap消息（使用Service.Mode.MESSAGE模式进行发送数据）      
               
                    
                  
            
          *      */    @Test    public void test2(){        try {            String namespace = "http://ws01.yzl.com/";            String wsdlUrl = "http://localhost:8888/ws01?wsdl";                    //1、创建服务(Service)            URL url = new URL(wsdlUrl);            QName qname = new QName(namespace,"MyServiceImplService");            Service service = Service.create(url, qname);                        //2、创建Dispatch            //public interface Dispatch
     
      extends BindingProviderDispatch 接口提供对动态调用服务端点操作的支持。javax.xml.ws.Service 接口作为创建 Dispatch 实例的工厂。             Dispatch
      
        dispatch = service.createDispatch(new QName(namespace,"MyServiceImplPort"), SOAPMessage.class, Service.Mode.MESSAGE);                        //3、创建SOAPMessage            MessageFactory factory = MessageFactory.newInstance();            SOAPMessage message = factory.createMessage();            SOAPPart part = message.getSOAPPart();            SOAPEnvelope envelope = part.getEnvelope();            SOAPBody body = envelope.getBody();            QName portQname = new QName("http://ws01.yzl.com/",                     "add","ns");            SOAPBodyElement ele = body.addBodyElement(portQname);            ele.addChildElement("a").setValue("22");            ele.addChildElement("b").setValue("33");                        //4、通过Dispatch传递消息,并返回响应消息            SOAPMessage returnMessage = dispatch.invoke(message);            returnMessage.writeTo(System.out);//打印返回消息            System.out.println();                        //5、解析返回的SOAP消息的XML            Document doc = returnMessage.getSOAPBody().extractContentAsDocument();            //Document doc = returnMessage.getSOAPPart().getEnvelope().getBody().extractContentAsDocument();            String result = doc.getElementsByTagName("addResult").item(0).getTextContent();            System.out.println("result is :" + result);                    } catch (Exception e) {            e.printStackTrace();        }    }
      
     

结果：

     
      
      
       
        
         55
        
       
      
     result is :55

 

2.2、使用Source和Service.Mode.PAYLOAD的方式来发送消息

接口IMyService.java中添加方法:

/***这里将WebResult和WebParam定义为user是为了使用jaxb进行类的编排和反编排时方便*/@WebResult(name="user")public List
     
       getChildListByUser(@WebParam(name="user")User user);
     

@Overridepublic List
     
       getChildListByUser(User user) {　　List
      
        result = new ArrayList
       
        ();　　result.add(new User("张三", "11111"));　　result.add(new User("李四", "22222"));　　return result;}
       
      
     

 

这时wsdl中的定义如下：

调用代码:

/**     * 使用Source和Service.Mode.PAYLOAD的方式来发送消息     * 使用JAXB来对User对象进行编排和反编排     * 使用xpath解析xml     * @throws Exception     */    @Test    public void test3() throws Exception{        String namespace = "http://ws01.yzl.com/";        String wsdlUrl = "http://localhost:8888/ws01?wsdl";            //1、创建服务(Service)        URL url = new URL(wsdlUrl);        QName qname = new QName(namespace,"MyServiceImplService");        Service service = Service.create(url, qname);                //2、创建Dispatch(通过源数据的方式传递)        Dispatch dispatch = service.createDispatch(new QName(namespace,"MyServiceImplPort"),Source.class, Service.Mode.PAYLOAD);                //3、根据用户对象创建相应的xml(user对象的属性可以通过wsdl文件构建出来)        User user = new User("管理员","123456");        JAXBContext jaxb = JAXBContext.newInstance(User.class);        Marshaller ms = jaxb.createMarshaller();        ms.setProperty(Marshaller.JAXB_FRAGMENT, true);//去掉xml声明        StringWriter writer = new StringWriter();        ms.marshal(user, writer);        //System.out.println(writer.toString());//
     
      
       123456
      
      
       管理员
      
                     //4、封装相应的part addUser        String payload = "
     
      "+writer.toString()+"
     ";        System.out.println(payload);        StreamSource rs = new StreamSource(new StringReader(payload));                //5、通过dispatch传递payload        Source response = (Source)dispatch.invoke(rs);                //6、将Source转化为DOM进行操作，使用Transform对象转换        Transformer tran = TransformerFactory.newInstance().newTransformer();        DOMResult result = new DOMResult();        tran.transform(response, result);                //7、处理相应信息(通过xpath处理)        XPath xpath = XPathFactory.newInstance().newXPath();        NodeList nl = (NodeList)xpath.evaluate("//user", result.getNode(),XPathConstants.NODESET);        for(int i=0; i

结果如下：

     
      
       
        123456
       
       
        管理员
       
      
     张三李四