CXF创建Webservice接口与Spring整合实例

package cn.com.webservice.interceptor; import java.util.Iterator; import javax.xml.namespace.QName; import javax.xml.soap.SOAPException; import javax.xml.soap.SOAPHeader; import javax.xml.soap.SOAPMessage; import org.apache.cxf.binding.soap.SoapMessage; import org.apache.cxf.binding.soap.saaj.SAAJInInterceptor; import org.apache.cxf.interceptor.Fault; import org.apache.cxf.phase.AbstractPhaseInterceptor; import org.apache.cxf.phase.Phase; import org.apache.log4j.LogManager; import org.apache.log4j.Logger; import org.w3c.dom.Element; import org.w3c.dom.NodeList; import cn.com.webservice.util.HighsetInit; /** * webservice 拦截器 */ public class AuthInterceptor extends AbstractPhaseInterceptor<SoapMessage> { private static final Logger log = LogManager.getLogger(AuthInterceptor.class); private static final QName QNAME_AUTHORIZE = new QName("authorize"); private static final String WS_USERNAME = HighsetInit.getProperty("WS_USERNAME"); private static final String WS_PASSWORD = HighsetInit.getProperty("WS_PASSWORD"); public AuthInterceptor() { super(Phase.PRE_PROTOCOL); getAfter().add(SAAJInInterceptor.class.getName()); } public void handleMessage(SoapMessage message) throws Fault { SOAPMessage mess = message.getContent(SOAPMessage.class); if (mess == null) { SAAJInInterceptor.INSTANCE.handleMessage(message); mess = message.getContent(SOAPMessage.class); } SOAPHeader head = null; try { head = mess.getSOAPHeader(); } catch (SOAPException e) { log.error("获取soap header时异常", e); } boolean flag = false; String errMsg = ""; if (head != null) { // 验证ws用户名密码 Iterator<?> authEle = head.getChildElements(QNAME_AUTHORIZE); if (authEle != null && authEle.hasNext()) { Element authorize = (Element) authEle.next(); NodeList usernameNode = authorize.getElementsByTagName("username"); NodeList passwordNode = authorize.getElementsByTagName("password"); String username = null; String password = null; if (usernameNode != null && usernameNode.getLength() > 0) { username = usernameNode.item(0).getTextContent(); } if (passwordNode != null && passwordNode.getLength() > 0) { password = passwordNode.item(0).getTextContent(); } if (username != null && username.equals(WS_USERNAME) && password != null && password.equals(WS_PASSWORD)) { flag = true; } else { errMsg = "认证错误"; } } else { errMsg = "认证错误"; } } else { errMsg = "消息头不能为空"; } if (!flag) { SOAPException soapExc = new SOAPException(errMsg); throw new Fault(soapExc); } } }