webservice之拦截器

Posted 永远的七号

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了webservice之拦截器相关的知识,希望对你有一定的参考价值。

记录一次webservice添加拦截器,来达到修改xml报文的目的

import org.apache.cxf.endpoint.Client;
import org.apache.cxf.frontend.ClientProxy;


 private  Soap createSoap() {
        service = new Service();
        soap = service.getServiceSoap();
        //拦截器改造报文头
        client = ClientProxy.getClient(soap);
        HeaderInInterceptor soapHeaderInInterceptor = new HeaderInInterceptor();
        soapHeaderInInterceptor.setHostUser("username", "password");
        client.getOutInterceptors().add(soapHeaderInInterceptor);
        return soap;
    }



public class HeaderInInterceptor extends AbstractSoapInterceptor {
    public HeaderInInterceptor() {
        super(Phase.WRITE);
    }

    private String msg;


    @Override
    public void handleMessage(SoapMessage message) throws Fault {
        try {
            List<Header> headers = message.getHeaders();
            QName qName = new QName("Authorization-My-Header");//需要增加的节点
            Document document = careteDocument(msg);
            Element documentElement = document.getDocumentElement();
            SoapHeader head = new SoapHeader(qName, documentElement);
            headers.add(head);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


    public void setHostUser(String username,String pw) {
        String  str = "<tem:AuthorizationSoapHeader soapenv:mustUnderstand=\\"1\\" xmlns:tem=\\"http://tempuri.org/\\" "
            + "xmlns:soapenv=\\"http://schemas.xmlsoap.org/soap/envelope/\\">\\n"
            + "\\t<tem:UserName>"+ username+"</tem:UserName>\\n"
            + "\\t<tem:Password>"+pw+"</tem:Password>\\n"
            + "</tem:AuthorizationSoapHeader>";
        this.msg = str;
    }


    public static Document careteDocument(String xml) throws Exception {
        InputStream strm ;
        strm = new ByteArrayInputStream(xml.getBytes("UTF-8"));
        DocumentBuilderFactory domFactory = DocumentBuilderFactory
            .newInstance();
        domFactory.setNamespaceAware(true);
        DocumentBuilder builder = domFactory.newDocumentBuilder();
        Document doc = builder.parse(strm);
        return doc;
    }
}

ps:一般来说,使用 “wsimport -clientjar {xxx.jar} -p {包名} -s {源码包名} {url}” 生成的客户端中,创建service都有无参和有参的方法

无参:每次去调用远端的URL来生成service

有参:将wsdl放在本地,通过url传入该方法,即可减少每次请求的网络开销

service = new Service(new URL("file://xxx/xxx.wsdl"));

 

 

以上是关于webservice之拦截器的主要内容,如果未能解决你的问题,请参考以下文章

学习webservice之cxf:cxf自定义拦截器

WebService -- Java 实现之 CXF ( 添加系统预定义的拦截器)

学习webservice之cxf:cxf日志拦截器

通过JDK自带工具生成WebService客户端代码

5.webService拦截器

7.添加基于Spring的WebService拦截器