1， SOAPMessage结构图
2， SOAP消息的创建
1>前面的一个简单WebService 服务
package com.yangw.soap.service; import javax.jws.WebParam; import javax.jws.WebResult; import javax.jws.WebService; //说明该接口是服务接口，可以指定我们自己的命名空间 @WebServicepublic interface IMyService { /** * 使用注解指明返回值名，参数名 */ @WebResult(name="addResult") public int add(@WebParam(name="a")int a,@WebParam(name="b")int b); }
package com.yangw.soap.service; import javax.jws.WebService; //说明该类是服务接口的实现类 @WebService(endpointInterface="com.yangw.soap.service.IMyService") public class MyServiceImpl implements IMyService { @Override public int add(int a, int b) { System.out.println("a+b="+(a+b)); return a+b; } }
package com.yangw.soap.service; import javax.xml.ws.Endpoint; public class MyService { /** * @param args */ public static void main(String[] args) { //发布服务 Endpoint.publish("http://localhost:8899/ns", new MyServiceImpl()); } }
2>SOAPMessage的创建
package com.yangw.soap.test; import java.io.IOException; 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.SOAPMessage; import javax.xml.soap.SOAPPart; import org.junit.Test; public class TestSoap { /** * 自己创建soap协议 */ @Test public void test() { try { //1,创建消息工厂 MessageFactory factory=MessageFactory.newInstance(); //2,根据消息工厂创建soap消息 SOAPMessage msg=factory.createMessage(); //3,创建SOAPPart SOAPPart part=msg.getSOAPPart(); //4,获取soapEnvelope SOAPEnvelope envelope=part.getEnvelope(); //5,通过SOAPEnvelope可以有效的获取相应的Header和Body等 SOAPBody body=envelope.getBody(); //6,根据QName创建相应的节点（QName就是一个带有命名空间的节点） QName qName=new QName("http://service.soap.yangw.com/", "add", "ns"); //相当于<ns:add xmlns="http://service.soap.yangw.com/" /> //7,将QName加入到body中 // body.addBodyElement(qName).setValue("123123"); /** * <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"> * <SOAP-ENV:Header/> * <SOAP-ENV:Body> * <ns:add xmlns:ns="http://service.soap.yangw.com/">123123</ns:add> * </SOAP-ENV:Body> * </SOAP-ENV:Envelope> */ //如果使用下面注释住的这个方式，会将<>转换为<> //body.addBodyElement(qName).setValue("<a>11</a><b>22</b>"); //加子元素 SOAPBodyElement bodyEle=body.addBodyElement(qName); bodyEle.addChildElement("a").setValue("11"); bodyEle.addChildElement("b").setValue("22"); //打印消息 msg.writeTo(System.out); /** * <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"> * <SOAP-ENV:Header/> * <SOAP-ENV:Body> * <ns:add xmlns:ns="http://service.soap.yangw.com/"> * <a>11</a> * <b>22</b> * </ns:add> * </SOAP-ENV:Body> * </SOAP-ENV:Envelope> */ } catch (SOAPException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } } }
3， SOAPMessage的传递
private String ns="http://service.soap.yangw.com/"; private String wsdlUrl="http://localhost:8899/ns?wsdl"; /** * Soap消息的传递 */ @Test public void test02() { try { //1,创建服务 URL url=new URL(wsdlUrl); QName qName=new QName(ns,"MyServiceImplService"); Service service=Service.create(url, qName); //2,创建Dispatch Dispatch<SOAPMessage> dispatch=service.createDispatch(new QName(ns,"MyServiceImplPort"),//(创建Port的时候指定名称空间) 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="XXX" /> SOAPBodyElement bodyEle=body.addBodyElement(eName); bodyEle.addChildElement("a").setValue("22"); bodyEle.addChildElement("b").setValue("33"); msg.writeTo(System.out); //输出消息到控制台 /** * <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"> * <SOAP-ENV:Header/> * <SOAP-ENV:Body> * <nn:add xmlns:nn="http://service.soap.yangw.com/"> * <a>22</a> * <b>33</b> * </nn:add> * </SOAP-ENV:Body> * </SOAP-ENV:Envelope> */ System.out.println(" invoke ..."); //5, 通过Dispatch传递消息 SOAPMessage resMsg= dispatch.invoke(msg); resMsg.writeTo(System.out); /** * <S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/"> * <S:Header/> * <S:Body> * <ns2:addResponse xmlns:ns2="http://service.soap.yangw.com/"> * <addResult>55</addResult> * </ns2:addResponse> * </S:Body> * </S:Envelope> */ //6, 将响应的消息转换为DOM对象 Document doc=resMsg.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(); } }
4， 基于PayLoad的方式传递SOAP消息，其实是附件的形式 下面实例是传递了一个自定义User对象 它可以传递字符串
package com.yangw.soap.service; import java.util.Date; import javax.xml.bind.annotation.XmlRootElement; @XmlRootElement public class User { private String userName; private String password; private int age; private Date birthday; public User() { super(); } public User(String userName, String password, int age, Date birthday) { super(); this.userName = userName; this.password = password; this.age = age; this.birthday = birthday; } public String getUserName() { return userName; } public void setUserName(String userName) { this.userName = userName; } public String getPassword() { return password; } public void setPassword(String password) { this.password = password; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } public Date getBirthday() { return birthday; } public void setBirthday(Date birthday) { this.birthday = birthday; } }
package com.yangw.soap.service; import java.util.List; import javax.jws.WebParam; import javax.jws.WebResult; import javax.jws.WebService; //说明该接口是服务接口 @WebService public interface IMyService { /** * 使用注解指明返回值名，参数名 */ @WebResult(name="addResult") public int add(@WebParam(name="a")int a,@WebParam(name="b")int b); //返回对象是什么类型就写什么值，不区分单个对象还是List @WebResult(name="user") public User addUser(@WebParam(name="user")User user); @WebResult(name="user") public User login(@WebParam(name="username")String username,@WebParam(name="password")String password); @WebResult(name="user") public List<User> list(); }
package com.yangw.soap.service; import java.util.ArrayList; import java.util.Date; import java.util.List; import javax.jws.WebService; //说明该类是服务接口的实现类 @WebService(endpointInterface="com.yangw.soap.service.IMyService") public class MyServiceImpl implements IMyService { private static List<User> users=new ArrayList<User>(); static{ users.add(new User("yangw","123456",12,new Date())); users.add(new User("awei","123456",25,new Date())); } @Override public int add(int a, int b) { System.out.println("a+b="+(a+b)); return a+b; } @Override public User addUser(User user) { users.add(user); return user; } @Override public User login(String username, String password) { for(User user:users){ if(user.getUserName().equals(username)&&user.getPassword().equals(password)){ return user; } } return null; } @Override public List<User> list() { return users; } }
真正的处理消息的组成，发送和接收
/** * Soap消息的传递,PAYLOAD方式可以传字符串的. */ @Test public void test03() { try { //1,创建服务 URL url=new URL(wsdlUrl); QName qName=new QName(ns,"MyServiceImplService"); Service service=Service.create(url, qName); //2,创建Dispatch ，通过Source的方式传递 Dispatch<Source> dispatch=service.createDispatch(new QName(ns,"MyServiceImplPort"), Source.class, Service.Mode.PAYLOAD); //3, 根据用户对象创建相应的xml(编排) User user=new User("ahuang","123321",23,new Date()); 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); //5，通过Dispatch传递 payLoad Source response=dispatch.invoke(new StreamSource(new StringReader(payLoad))); //6， 将Source转换为DOM操作，使用Transform对象 Transformer tran=TransformerFactory.newInstance().newTransformer(); DOMResult result=new DOMResult(); tran.transform(response, result); //7，处理响应信息 XPath xpath=XPathFactory.newInstance().newXPath(); NodeList nl=(NodeList) xpath.evaluate("//user", result.getNode(),XPathConstants.NODESET); //反编排 User u=(User) ctx.createUnmarshaller().unmarshal(nl.item(0)); System.out.println(u.getUserName()); } 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(); } }
5， list方法测试
package com.yangw.soap.service; import java.util.List; import javax.jws.WebParam; import javax.jws.WebResult; import javax.jws.WebService; //说明该接口是服务接口 @WebService public interface IMyService { /** * 使用注解指明返回值名，参数名 */ @WebResult(name="addResult") public int add(@WebParam(name="a")int a,@WebParam(name="b")int b); //返回对象是什么类型就写什么值，不区分单个对象还是List @WebResult(name="user") public User addUser(@WebParam(name="user")User user); @WebResult(name="user") public User login(@WebParam(name="username")String username,@WebParam(name="password")String password); @WebResult(name="user") public List<User> list1(); @WebResult(name="user") //设置header为true，让它以头信息的形式传递 //这是显示的方式传递头部信息的方式 public List<User> list2(@WebParam(name="authInfo",header=true)String authInfo); }
不带参数的list()方法
/** * Soap消息的传递 --测试 list()方法，不带参数的形式 */ @Test public void test04() { try { //1,创建服务 URL url=new URL(wsdlUrl); QName qName=new QName(ns,"MyServiceImplService"); Service service=Service.create(url, qName); //2,创建Dispatch (创建Port的时候指定名称空间) 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,"list1", "nn"); //前缀必须指定，名字可以任意 <nn:add xmlns="XXX" /> body.addBodyElement(eName); msg.writeTo(System.out); //输出消息到控制台 /** *<SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"> * <SOAP-ENV:Header/> * <SOAP-ENV:Body> * <nn:list xmlns:nn="http://service.soap.yangw.com/"/> * </SOAP-ENV:Body> *</SOAP-ENV:Envelope> */ System.out.println(" invoke ..."); //5, 通过Dispatch传递消息 SOAPMessage resMsg= dispatch.invoke(msg); resMsg.writeTo(System.out); System.out.println(); /** *<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/"> * <S:Header/> * <S:Body> * <ns2:listResponse xmlns:ns2="http://service.soap.yangw.com/"> * <user> * <age>12</age> * <birthday>2014-03-03T14:21:02.468+08:00</birthday> * <password>123456</password> * <userName>yangw</userName> * </user> * <user> * <age>25</age> * <birthday>2014-03-03T14:21:02.468+08:00</birthday> * <password>123456</password> * <userName>awei</userName> * </user> * </ns2:listResponse> * </S:Body> *</S:Envelope> */ //6, 将响应的消息转换为DOM对象 Document doc=resMsg.getSOAPPart().getEnvelope().getBody().extractContentAsDocument(); NodeList nl=doc.getElementsByTagName("user"); JAXBContext ctx=JAXBContext.newInstance(User.class); for(int i=0;i<nl.getLength();i++){ Node node=nl.item(i); //import org.w3c.dom.Node; User user=(User) ctx.createUnmarshaller().unmarshal(node); System.out.println(user.getUserName()+":"+user.getPassword()); } } catch (SOAPException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } catch (JAXBException e) { e.printStackTrace(); } }
带参数的list()方法测试
/** * Soap消息的传递 --测试 list(String)方法，带参数的形式，一般都是把参数放到头信息中作验证 */ @Test public void test05() { try { //1,创建服务 URL url=new URL(wsdlUrl); QName qName=new QName(ns,"MyServiceImplService"); Service service=Service.create(url, qName); //2,创建Dispatch (创建Port的时候指定名称空间) 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(); //3.2 头信息的处理 SOAPHeader header=envelope.getHeader(); if(header==null) header=envelope.addHeader(); QName hName=new QName(ns,"authInfo", "nn"); header.addHeaderElement(hName).setValue("aabbcc"); SOAPBody body=envelope.getBody(); //4, 创建QName来指定消息中传递的数据 QName eName=new QName(ns,"list2", "nn"); //前缀必须指定，名字可以任意 <nn:add xmlns="XXX" /> body.addBodyElement(eName); msg.writeTo(System.out); //输出消息到控制台 /** * <SOAP-ENV:Envelope xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/"> * <SOAP-ENV:Header> * <nn:authInfo xmlns:nn="http://service.soap.yangw.com/">aabbcc</nn:authInfo> * </SOAP-ENV:Header> * <SOAP-ENV:Body> * <nn:list2 xmlns:nn="http://service.soap.yangw.com/"/> * </SOAP-ENV:Body> * </SOAP-ENV:Envelope> */ System.out.println(" invoke ..."); //5, 通过Dispatch传递消息 SOAPMessage resMsg= dispatch.invoke(msg); resMsg.writeTo(System.out); System.out.println(); /** *<S:Envelope xmlns:S="http://schemas.xmlsoap.org/soap/envelope/"> * <S:Header/> * <S:Body> * <ns2:listResponse xmlns:ns2="http://service.soap.yangw.com/"> * <user> * <age>12</age> * <birthday>2014-03-03T14:21:02.468+08:00</birthday> * <password>123456</password> * <userName>yangw</userName> * </user> * <user> * <age>25</age> * <birthday>2014-03-03T14:21:02.468+08:00</birthday> * <password>123456</password> * <userName>awei</userName> * </user> * </ns2:listResponse> * </S:Body> *</S:Envelope> */ //6, 将响应的消息转换为DOM对象 Document doc=resMsg.getSOAPPart().getEnvelope().getBody().extractContentAsDocument(); NodeList nl=doc.getElementsByTagName("user"); JAXBContext ctx=JAXBContext.newInstance(User.class); for(int i=0;i<nl.getLength();i++){ Node node=nl.item(i); //import org.w3c.dom.Node; User user=(User) ctx.createUnmarshaller().unmarshal(node); System.out.println(user.getUserName()+":"+user.getPassword()); } } catch (SOAPException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } catch (JAXBException e) { e.printStackTrace(); } }
上面头消息的处理是显示消息的处理，用wsimport导出之后，可以看到会“自动生成一个List对象”
接口上的名称空间应该与实现类上的名称空间一致.
