学步园

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

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

首先看Handler

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

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

最后看客户端调用

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