使用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<a href="/tag/so/" target="_blank" class="keywords">.so</a>ap<a href="/tag/so/" target="_blank" class="keywords">.so</a>APException; import javax.xml<a href="/tag/so/" target="_blank" class="keywords">.so</a>ap<a href="/tag/so/" target="_blank" class="keywords">.so</a>APHeader; import org.apache.axis.message<a href="/tag/so/" target="_blank" class="keywords">.so</a>APHeaderElement; import org.apache.axis.message<a href="/tag/so/" target="_blank" class="keywords">.so</a>APEnvelope; import org.apache.axis.message.MessageElement; import javax.xml.namespace.QName; import java.util.I<a href="/tag/tera/" target="_blank" class="keywords">tera</a>tor; @SuppressWarnings("unchecked") public class BSHeaderHandler extends BasicHandler { private static final long serialVersionUID = 1L; private String username,passwd; // 在执行service前先处理handler // invoke()会被<a href="/tag/zidong/" target="_blank" class="keywords">自动</a><a href="/tag/diaoyong/" target="_blank" class="keywords">调用</a>，而且 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(); I<a href="/tag/tera/" target="_blank" class="keywords">tera</a>tor it = header.<a href="/tag/examine/" target="_blank" class="keywords">examine</a>AllHeaderElements(); 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 <a href="/tag/biaoqian/" target="_blank" class="keywords">标签</a>."); } MessageElement tele = hel.getChildElement(new QName( "http://cn.zuoguodang.service","passwd")); if (tele == null) { throw new AxisFault("找不到 passwd <a href="/tag/biaoqian/" target="_blank" class="keywords">标签</a>."); } 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:p<a href="/tag/ara/" target="_blank" class="keywords">ara</a>meter name="s<a href="/tag/cop/" target="_blank" class="keywords">cop</a>e" value="session"/> </ns1:handler> <ns1:handler type="java:org.apache.axis.handlers.JWSHandler"> <ns1:p<a href="/tag/ara/" target="_blank" class="keywords">ara</a>meter name="s<a href="/tag/cop/" target="_blank" class="keywords">cop</a>e" value="request"/> <ns1:p<a href="/tag/ara/" target="_blank" class="keywords">ara</a>meter 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.s<a href="/tag/eto/" target="_blank" class="keywords">eto</a>perationName(new QName("MyService","sysHello")); call.addP<a href="/tag/ara/" target="_blank" class="keywords">ara</a>meter(new QName("http://cn.zuoguodang.service","name"),org.apache.axis.encoding.XMLType.XSD_STRING,P<a href="/tag/ara/" target="_blank" class="keywords">ara</a>meterMode.IN); call.setReturnType(XMLType<a href="/tag/so/" target="_blank" class="keywords">.so</a>AP_STRING); // 设定 Header call.addHeader(cpHeader); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println(call.invoke(new Object[]{"zuoguodang"})); 好了，已经完成添加SOAP Header。有错误之处请指出，email:[email protected]。