使用AXIS进行webservice开发－添加SOAP Header

webservice作为SOAP思想的核心，早已经广泛的应用了，但是仍然有很多人不了解webservice，甚至是没听过。WebService是B2B集成成功的关键，用WebService来实现B2B集成的最大好处在于可以轻易实现互操作性。只要把商务逻辑“暴露”出来，成为WebService，就可以让任何指定的合作伙伴调用这些商务逻辑，而不管他们的系统在什么平台上运行，使用什么开发语言。

使用axis开发webservice变得非常容易，甚至不需要过多的了解webservice。使用eclipse可以已有的class生成webservice，这一点就不多说了，下面主要说添加SOAP Header.

首先看Handler

import org.apache.axis.AxisFault; import org.apache.axis.Message; import org.apache.axis.MessageContext; import org.apache.axis.handlers.BasicHandler; import javax.xml.soap.SOAPException; import javax.xml.soap.SOAPHeader; import org.apache.axis.message.SOAPHeaderElement; import org.apache.axis.message.SOAPEnvelope; import org.apache.axis.message.MessageElement; import javax.xml.namespace.QName; import java.util.Iterator; @SuppressWarnings("unchecked") public class BSHeaderHandler extends BasicHandler { private static final long serialVersionUID = 1L; private String username,passwd; // 在执行service前先处理handler // invoke()会被自动调用，而且 SOAP 信息可以由 msgContext 取得 public void invoke(MessageContext msgContext) throws AxisFault { boolean processedHeader = false; try { // 取得 Request 的 SOAP 信息 Message msg = msgContext.getRequestMessage(); SOAPEnvelope envelope = msg.getSOAPEnvelope(); SOAPHeader header = envelope.getHeader(); Iterator it = header.examineAllHeaderElements(); SOAPHeaderElement hel; while (it.hasNext()) { hel = (SOAPHeaderElement) it.next(); String headerName = hel.getNodeName(); if (headerName.equals("cp:MessageHeader")) { // 对于 mustUnderstand 设为 true 的 Header，必须 // 利用下列的方式把它设为"已经处理"，否则 service // 会回传 Did not understand "MustUnderstand" hel.setProcessed(true); checkUser(hel); processedHeader = true; } } } catch (SOAPException e) { throw new AxisFault("无法处理 SOAP Header.",e); } if (!processedHeader) { throw new AxisFault("接收 SOAP Header 失败"); } } private void checkUser(SOAPHeaderElement hel) throws AxisFault { MessageElement fele = hel.getChildElement(new QName( "http://cn.zuoguodang.service","username")); if (fele == null) { throw new AxisFault("找不到 username 标签."); } MessageElement tele = hel.getChildElement(new QName( "http://cn.zuoguodang.service","passwd")); if (tele == null) { throw new AxisFault("找不到 passwd 标签."); } username = fele.getValue(); passwd = tele.getValue(); if (!"zuoguodang".equals(username) || !"123456".equals(passwd)) { throw new AxisFault("认证失败"); } } } ?再看server-config.wsdd

<ns1:requestFlow> <ns1:handler type="java:cn.zuoguodang.service.BSHeaderHandler"/> <ns1:handler type="java:org.apache.axis.handlers.JWSHandler"> <ns1:parameter name="scope" value="session"/> </ns1:handler> <ns1:handler type="java:org.apache.axis.handlers.JWSHandler"> <ns1:parameter name="scope" value="request"/> <ns1:parameter name="extension" value=".jwr"/> </ns1:handler> </ns1:requestFlow>?请注意<ns1:handler type="java:cn.zuoguodang.service.BSHeaderHandler"/>这行，这就是加上去的验证。

最后看客户端调用

String endpoint = "http://192.168.0.100/webapp/MyService?wsdl"; // 产生 SOAP Header SOAPHeaderElement cpHeader = new SOAPHeaderElement( "http://cn.zuoguodang.service","MessageHeader"); cpHeader.setPrefix("cp"); cpHeader.setMustUnderstand(true); SOAPElement ele = cpHeader.addChildElement("username"); ele.addTextNode("zuoguodang"); ele = cpHeader.addChildElement("passwd"); ele.addTextNode("123456"); Service service = new Service(); Call call = (Call) service.createCall(); call.setTargetEndpointAddress(new java.net.URL(endpoint)); call.setOperationName(new QName("MyService","sysHello")); call.addParameter(new QName("http://cn.zuoguodang.service","name"),org.apache.axis.encoding.XMLType.XSD_STRING,ParameterMode.IN); call.setReturnType(XMLType.SOAP_STRING); // 设定 Header call.addHeader(cpHeader); System.out.println(call.invoke(new Object[]{"zuoguodang"}));?好了，已经完成添加SOAP Header。有错误之处请指出，email:zuoguodang@163.com。