soap消息的分析与处理

import java.io.IOException;

import java.io.StringReader;

import java.io.StringWriter;

import java.net.URL;

import javax.xml.bind.JAXBContext;

import javax.xml.bind.JAXBException;

import javax.xml.bind.Marshaller;

import javax.xml.namespace.QName;

import javax.xml.soap.MessageFactory;

import javax.xml.soap.SOAPBody;

import javax.xml.soap.SOAPBodyElement;

import javax.xml.soap.SOAPEnvelope;

import javax.xml.soap.SOAPException;

import javax.xml.soap.SOAPHeader;

import javax.xml.soap.SOAPMessage;

import javax.xml.soap.SOAPPart;

import javax.xml.transform.Source;

import javax.xml.transform.Transformer;

import javax.xml.transform.TransformerConfigurationException;

import javax.xml.transform.TransformerException;

import javax.xml.transform.TransformerFactory;

import javax.xml.transform.TransformerFactoryConfigurationError;

import javax.xml.transform.dom.DOMResult;

import javax.xml.transform.stream.StreamSource;

import javax.xml.ws.Dispatch;

import javax.xml.ws.Service;

import javax.xml.ws.soap.SOAPFaultException;

import javax.xml.xpath.XPath;

import javax.xml.xpath.XPathConstants;

import javax.xml.xpath.XPathExpressionException;

import javax.xml.xpath.XPathFactory;

import org.junit.Test;

import org.soap.service.User;

import org.w3c.dom.Document;

import org.w3c.dom.Node;

import org.w3c.dom.NodeList;

public class TestSoap {

private String ns = "http://service.soap.org/";

private String wsdlUrl = "http://localhost:8989/ms?wsdl";

@Test

public void test01() {

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://java.zttc.edu.cn/webservice",

"add","ns");//<ns:add xmlns=">

//如果使用以下方式进行设置，会见<>转换为<和&gt

//body.addBodyElement(qname).setValue("<a>1</a><b>2</b>");

SOAPBodyElement ele = body.addBodyElement(qname);

ele.addChildElement("a").setValue("22");

ele.addChildElement("b").setValue("33");

//打印消息信息

message.writeTo(System.out);

} catch (SOAPException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

@Test

public void test02() {

try {

//1、创建服务(Service)

URL url = new URL(wsdlUrl);

QName sname = new QName(ns,"MyServiceImplService");

Service service = Service.create(url,sname);

//2、创建Dispatch

Dispatch<SOAPMessage> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),

SOAPMessage.class, Service.Mode.MESSAGE);

//3、创建SOAPMessage

SOAPMessage msg = MessageFactory.newInstance().createMessage();

SOAPEnvelope envelope = msg.getSOAPPart().getEnvelope();

SOAPBody body = envelope.getBody();

//4、创建QName来指定消息中传递数据

QName ename = new QName(ns,"add","nn");//<nn:add xmlns="xx"/>

SOAPBodyElement ele = body.addBodyElement(ename);

ele.addChildElement("a").setValue("22");

ele.addChildElement("b").setValue("33");

msg.writeTo(System.out);

System.out.println("\n invoking.....");

//5、通过Dispatch传递消息,会返回响应消息

SOAPMessage response = dispatch.invoke(msg);

response.writeTo(System.out);

System.out.println();

//将响应的消息转换为dom对象

Document doc = response.getSOAPPart().getEnvelope().getBody().extractContentAsDocument();

String str = doc.getElementsByTagName("addResult").item(0).getTextContent();

System.out.println(str);

} catch (SOAPException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

@Test

public void test03() {

try {

//1、创建服务(Service)

URL url = new URL(wsdlUrl);

QName sname = new QName(ns,"MyServiceImplService");

Service service = Service.create(url,sname);

//2、创建Dispatch(通过源数据的方式传递)

Dispatch<Source> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),

Source.class, Service.Mode.PAYLOAD);

//3、根据用户对象创建相应的xml

User user = new User(3,"zs","张三","11111");

JAXBContext ctx = JAXBContext.newInstance(User.class);

Marshaller mar = ctx.createMarshaller();

mar.setProperty(Marshaller.JAXB_FRAGMENT, true);

StringWriter writer= new StringWriter();

mar.marshal(user, writer);

//4、封装相应的part addUser

String payload = "<nn:addUser xmlns:nn=\""+ns+"\">"+writer.toString()+"</nn:addUser>";

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);

User ru = (User)ctx.createUnmarshaller().unmarshal(nl.item(0));

System.out.println(ru.getNickname());

} catch (IOException e) {

e.printStackTrace();

} catch (JAXBException e) {

e.printStackTrace();

} catch (TransformerConfigurationException e) {

e.printStackTrace();

} catch (TransformerFactoryConfigurationError e) {

e.printStackTrace();

} catch (TransformerException e) {

e.printStackTrace();

} catch (XPathExpressionException e) {

e.printStackTrace();

}

@Test

public void test04() {

try {

//1、创建服务(Service)

URL url = new URL(wsdlUrl);

QName sname = new QName(ns,"MyServiceImplService");

Service service = Service.create(url,sname);

//2、创建Dispatch

Dispatch<SOAPMessage> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),

SOAPMessage.class, Service.Mode.MESSAGE);

//3、创建SOAPMessage

SOAPMessage msg = MessageFactory.newInstance().createMessage();

SOAPEnvelope envelope = msg.getSOAPPart().getEnvelope();

SOAPBody body = envelope.getBody();

//3.2、处理header信息

SOAPHeader header = envelope.getHeader();

if(header==null) header = envelope.addHeader();

QName hname = new QName(ns,"authInfo","nn");

header.addHeaderElement(hname).setValue("aabbccdd");

//4、创建QName来指定消息中传递数据

QName ename = new QName(ns,"list","nn");//<nn:add xmlns="xx"/>

body.addBodyElement(ename);

msg.writeTo(System.out);

System.out.println("\n invoking.....");

//5、通过Dispatch传递消息,会返回响应消息

SOAPMessage response = dispatch.invoke(msg);

response.writeTo(System.out);

System.out.println();

//将响应的消息转换为dom对象

Document doc = response.getSOAPBody().extractContentAsDocument();

NodeList nl = doc.getElementsByTagName("user");

JAXBContext ctx = JAXBContext.newInstance(User.class);

for(int i=0;i<nl.getLength();i++) {

Node n = nl.item(i);

User u = (User)ctx.createUnmarshaller().unmarshal(n);

System.out.println(u.getNickname());

}

} catch (SOAPException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

} catch (JAXBException e) {

e.printStackTrace();

}

@Test

public void test05() {

try {

//1、创建服务(Service)

URL url = new URL(wsdlUrl);

QName sname = new QName(ns,"MyServiceImplService");

Service service = Service.create(url,sname);

//2、创建Dispatch

Dispatch<SOAPMessage> dispatch = service.createDispatch(new QName(ns,"MyServiceImplPort"),

SOAPMessage.class, Service.Mode.MESSAGE);

//3、创建SOAPMessage

SOAPMessage msg = MessageFactory.newInstance().createMessage();

SOAPEnvelope envelope = msg.getSOAPPart().getEnvelope();

SOAPBody body = envelope.getBody();

//4、创建QName来指定消息中传递数据

QName ename = new QName(ns,"login","nn");//<nn:add xmlns="xx"/>

SOAPBodyElement ele = body.addBodyElement(ename);

ele.addChildElement("username").setValue("ss");

ele.addChildElement("password").setValue("dd");

msg.writeTo(System.out);

System.out.println("\n invoking.....");

//5、通过Dispatch传递消息,会返回响应消息

SOAPMessage response = dispatch.invoke(msg);

response.writeTo(System.out);

System.out.println();

} catch(SOAPFaultException e){

System.out.println(e.getMessage());

} catch (SOAPException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

<?xml version="1.0" encoding="UTF-8" standalone="yes"?>

<javaee:handler-chains

xmlns:javaee="

http://java.sun.com/xml/ns/javaee"

xmlns:xsd="http://www.w3.org/2001/XMLSchema">

<javaee:handler-chain>

<javaee:handler>

<javaee:handler-class>org.soap.service.handler.MyHeaderHandler</javaee:handler-class>

</javaee:handler>

</javaee:handler-chain>

</javaee:handler-chains>

soap消息的分析与处理

继续阅读

Httpclient远程调用WebService示例（Eclipse+httpclient）

httpClient实现对webService服务的调用

httpclient妙用一 httpclient作为客户端调用webservice转自:https://blog.csdn.net/zilong_zilong/article/details/53932667httpclient作为客户端调用webservice

实习小结2010-07-25

Visual C++下Web Service Client的实现

前后端分离框架跨域问题的解决办法-java和python做后端的实现

[事业]关于你的一生--IT人职业规划

WebService(3)-AXIS高级特性传递复杂对象

WebService CXF学习（进阶篇2）：复杂对象传递(List，Map)

Axis2 不能传递Map等复杂数据类型解决方案 .

WebService复杂类型数据传输(dom4j方式)

设置axis2访问webservice 权限

微软笔试面试题

ASP.NET2.0下使用AJAX调用Webservice的方法

Silverlight WCF 初尝小结

CLR线程池的I/O线程