apachecxf测试webservice添加header信息

2019独角兽企业重金招聘Python工程师标准>>>

使用apache-cxf自动生成webservice本地类&＃xff0c;有时需要在soap中添加header信息&＃xff0c;如下面

youthfliesyouthflies 我们可以在生成webservice client的时候&＃xff0c;手动添加上我们需要的header信息。新建一个 SoapHeaderInterceptor.java&＃xff0c;内容如下&＃xff1a;

package com.yeetrack.webservice;import java.util.List;import javax.xml.namespace.QName;import org.apache.cxf.binding.soap.SoapHeader; import org.apache.cxf.binding.soap.SoapMessage; import org.apache.cxf.binding.soap.interceptor.AbstractSoapInterceptor; import org.apache.cxf.headers.Header; import org.apache.cxf.helpers.DOMUtils; import org.apache.cxf.interceptor.Fault; import org.apache.cxf.phase.Phase; import org.w3c.dom.Document; import org.w3c.dom.Element;/*** &＃64;author youthflies* 自定义的soap拦截器&＃xff0c;用来添加header信息*/ public class SoapHeaderInterceptor extends AbstractSoapInterceptor {public SoapHeaderInterceptor(){super(Phase.WRITE);}&＃64;Overridepublic void handleMessage(SoapMessage message) throws Fault{// TODO Auto-generated method stub List headers&＃61;message.getHeaders(); headers.add(getHeader("username", "youthflies"));headers.add(getHeader("password", "youthflies"));}//http://webservice.webxml.com.cn/WebServices/MobileCodeWS.asmx?wsdlprivate Header getHeader(String key, String value) { QName qName&＃61;new QName("http://webservice.webxml.com.cn/", key); Document document&＃61;DOMUtils.createDocument(); Element element&＃61;document.createElementNS("http://webservice.webxml.com.cn/", key); element.setTextContent(value); SoapHeader header&＃61;new SoapHeader(qName, element); return(header); }} 再给个有子节点的header例子&＃xff1a;

public void handleMessage(SoapMessage arg0) throws Fault {QName qName&＃61;new QName("http://yourdomain.com/"); Document doc &＃61; DOMUtils.createDocument(); Element root &＃61; doc.createElement("AuthenticationToken"); Element username &＃61; doc.createElement("username"); username.setTextContent("yeetrack.com"); Element password &＃61; doc.createElement("password"); password.setTextContent("yeetrack.com"); Element args &＃61; doc.createElement("someargs"); args.setTextContent("其他参数"); root.appendChild(username); root.appendChild(password); root.appendChild(args); SoapHeader header &＃61; new SoapHeader(qName, root);// 获取SOAP消息的全部头 List headers &＃61; arg0.getHeaders(); headers.add(header); } 然后&＃xff0c;再我们的测试case中&＃xff0c;添加拦截器&＃xff1a;

//实例化接口实现类MobileCodeWS mobileCodeWS &＃61; new MobileCodeWS();//实例化接口MobileCodeWSSoap mobileCodeWSSoap &＃61; mobileCodeWS.getMobileCodeWSSoap();Client client &＃61; ClientProxy.getClient(mobileCodeWSSoap);client.getOutInterceptors().add(new SoapHeaderInterceptor());//调用接口中的方法System.out.println(mobileCodeWSSoap.getMobileCodeInfo("13898767654", "")); 依赖的jar包&＃xff1a;

org.apache.cxfcxf-rt-frontend-jaxws2.7.4 org.apache.cxfcxf-rt-bindings-soap2.7.4 org.apache.cxfcxf-rt-transports-http2.7.4 org.apache.ws.securitywss4j1.6.10 org.apache.cxfcxf-rt-ws-security2.7.5 效果如wireshark抓包&＃xff1a; wireshark抓取webservice maven cxf-codegen-plugin插件测试webservice