CXF 调用ASP服务器端通过用户名密码验证

package com.sap.document.sap.soap.functions.mc_style_A001; import java.io.ByteArrayOutputStream; import java.io.IOException; import java.util.Set; import javax.xml.namespace.QName; import javax.xml.soap.SOAPEnvelope; import javax.xml.soap.SOAPException; import javax.xml.soap.SOAPHeader; import javax.xml.soap.SOAPHeaderElement; import javax.xml.soap.SOAPMessage; import javax.xml.ws.handler.MessageContext; import javax.xml.ws.handler.soap.SOAPHandler; import javax.xml.ws.handler.soap.SOAPMessageContext; /** * * @author outofmemory.cn * * <soapenv:Header> <SessionType>***</web:SessionType> <PasswordText>***</web:PasswordText> <UsernameToken>***</web:UsernameToken> </soapenv:Header> */ public class HeaderHandler implements SOAPHandler<SOAPMessageContext> { public boolean handleMessage(SOAPMessageContext smc) { Boolean isRequest = (Boolean) smc.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY); QName usernameQName = new QName("命名空间", "UsernameToken","siebelwsh"); QName passwordQName = new QName("命名空间", "PasswordText","siebelwsh"); QName sessionTypeQName = new QName("命名空间", "SessionType","siebelwsh"); if (isRequest.booleanValue()) { try { SOAPMessage soapMsg = smc.getMessage(); SOAPEnvelope soapEnv = soapMsg.getSOAPPart().getEnvelope(); SOAPHeader soapHeader = soapEnv.getHeader(); soapEnv.addNamespaceDeclaration("web", "urn:sap-com:document:sap:soap:functions:mc-style"); // 注意:其实这里<web:SessionType>***</web:SessionType> 的web可以相当于是一个变量 xmlns:web="http://***.com/webservices [urn:sap-com:document:sap:soap:functions:mc-style]" //if no header, add one if (soapHeader == null) { soapHeader = soapEnv.addHeader(); } String username = "****"; String password = "***"; //添加SiebelUsernameToken SOAPHeaderElement usernameHeaderElement = soapHeader.addHeaderElement(usernameQName); usernameHeaderElement.addTextNode(username); //添加SiebelPasswordText SOAPHeaderElement passwordHeaderElement = soapHeader.addHeaderElement(passwordQName); passwordHeaderElement.addTextNode(password); //添加SiebelSessionType SOAPHeaderElement SessionTypeHeaderElement = soapHeader.addHeaderElement(sessionTypeQName); SessionTypeHeaderElement.addTextNode("None"); soapMsg.saveChanges(); try { soapMsg.writeTo(System.out); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } catch (SOAPException e) { e.printStackTrace(); //logger.warn(e.getMessage()); } }else{ try { SOAPMessage soapMessage = smc.getMessage(); ByteArrayOutputStream baos = new ByteArrayOutputStream(); soapMessage.writeTo(baos); } catch (Exception ex) { ex.printStackTrace(); } } return isRequest; } public Set getHeaders() { //throw new UnsupportedOperationException("Not supported yet."); return null; } public boolean handleFault(SOAPMessageContext context) { //throw new UnsupportedOperationException("Not supported yet."); return true; } public void close(MessageContext context) { //throw new UnsupportedOperationException("Not supported yet."); } /**调用方法 */ public static void main(String args[]){ HeaderHandlerResolver handlerResolver = new HeaderHandlerResolver(); Service service = Service.create(new QName("urn:sap-com:document:sap:soap:functions:mc-style", "ZHTERPPM_DATA_001"));//得到service service.setHandlerResolver(handlerResolver);//回写heard消息验证用户名密码 service.addPort(new QName("urn:sap-com:document:sap:soap:functions:mc-style", "binding"),javax.xml.ws.soap.SOAPBinding.SOAP11HTTP_BINDING, "http://HTERPER3.hongta.com:8000/sap/bc/srt/rfc/sap/zht_erppm_data_001/201/zhterppm_data_001/binding"); // service.setHandlerResolver(handlerResolver); ZHTERPPMDATA001 queryService1 =(ZHTERPPMDATA001) service.getPort(new QName("urn:sap-com:document:sap:soap:functions:mc-style", "binding"), ZHTERPPMDATA001.class); TableOfZpmBasic ss = queryService1.zErppmB002("2017.01.01");//调用接口方法 List<ZpmBasic> zpmBasic = ss.getItem(); for(ZpmBasic zpmbasic :zpmBasic){ System.out.println(">>>>>>>>>>>>"+zpmbasic.getWerks()); } } }