Java笔记-CXF增加拦截器与自定义拦截器

我就是我 2022-11-28 13:44 302阅读 0赞

如下搭建的Webservice：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70][]

在服务端填写如下代码：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 1][]

这里就是添加进和出的拦截器

public class Main {
    
        public static void main(String[] args) {
    
            MyService myService = new MyServiceImpl();
            JaxWsServerFactoryBean factoryBean = new JaxWsServerFactoryBean();
            factoryBean.setAddress("http://127.0.0.1/MyService");   //设置暴露地址
            factoryBean.setServiceClass(MyService.class);   //接口
            factoryBean.setServiceBean(myService);  //设置实现类
    
            factoryBean.getInInterceptors().add(new LoggingInInterceptor());
            factoryBean.getOutInterceptors().add(new LoggingOutInterceptor());
    
            factoryBean.create();   //创建webservice接口
        }
    }

客户端增加拦截器：

public class Main {
    
        public static void main(String[] args){
    
            MyServiceService service = new MyServiceService();
            MyService myService = service.getMyServicePort();
    
            Client myClient = ClientProxy.getClient(myService);
            myClient.getInInterceptors().add(new LoggingInInterceptor());
            myClient.getOutInterceptors().add(new LoggingOutInterceptor());
            myService.getRoles();
        }
    }

发送请求后可以看到打印了，服务端：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 2][]

客户端：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 3][]

下面是自定义的，加个用户名和密码：

他这里还是把用户名密码放到xml里面，如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 4][]

客户端去判断：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 5][]

客户关键端源码如下：

package cn.it1995.interceptor;
    
    import org.apache.cxf.binding.soap.SoapMessage;
    import org.apache.cxf.headers.Header;
    import org.apache.cxf.helpers.DOMUtils;
    import org.apache.cxf.interceptor.Fault;
    import org.apache.cxf.phase.AbstractPhaseInterceptor;
    import org.apache.cxf.phase.Phase;
    import org.w3c.dom.Document;
    import org.w3c.dom.Element;
    
    import javax.xml.namespace.QName;
    import java.util.List;
    
    public class AddHeaderInterceptor extends AbstractPhaseInterceptor<SoapMessage> {
    
        private String userName;
        private String password;
    
        public AddHeaderInterceptor(String userName, String password){
    
            super(Phase.PREPARE_SEND);
            this.userName = userName;
            this.password = password;
        }
    
        public void handleMessage(SoapMessage message) throws Fault{
    
            List<Header> headerList = message.getHeaders();
    
            Document doc = DOMUtils.createDocument();
            Element ele = doc.createElement("authHeader");
            Element uElement = doc.createElement("userName");
            uElement.setTextContent(userName);
            Element pElement = doc.createElement("password");
            pElement.setTextContent(password);
    
            ele.appendChild(uElement);
            ele.appendChild(pElement);
            headerList.add(new Header(new QName("java"), ele));
        }
    }

服务端关键源码如下：

package cn.it1995.interceptor;
    
    import org.apache.cxf.binding.soap.SoapMessage;
    import org.apache.cxf.headers.Header;
    import org.apache.cxf.interceptor.Fault;
    import org.apache.cxf.phase.AbstractPhaseInterceptor;
    import org.apache.cxf.phase.Phase;
    import org.w3c.dom.Element;
    import org.w3c.dom.NodeList;
    
    import java.util.List;
    
    public class MyInterceptor extends AbstractPhaseInterceptor<SoapMessage> {
    
    
        public MyInterceptor(){
    
            super(Phase.PRE_INVOKE);
        }
    
        @SuppressWarnings("null")
        public void handleMessage(SoapMessage message) throws Fault {
    
            List<Header> headers = message.getHeaders();
            if(headers == null && headers.size() == 0){
    
                throw new Fault(new IllegalArgumentException("没有Header，拦截器进行拦截"));
            }
    
            Header firstHeader = headers.get(0);
            Element ele =  (Element) firstHeader.getObject();
            NodeList uList = ele.getElementsByTagName("userName");
            NodeList pList = ele.getElementsByTagName("password");
            if(uList.getLength() != 1){
    
                throw new Fault(new IllegalArgumentException("用户名格式不对"));
            }
            if(pList.getLength() != 1){
    
                throw new Fault(new IllegalArgumentException("密码格式不对"));
            }
    
            String userName = uList.item(0).getTextContent();
            String password = pList.item(0).getTextContent();
    
            if(!userName.equals("ABC") || !password.equals("123456")){
    
                throw new Fault(new IllegalArgumentException("用户名密码错误"));
            }
    
        }
    }

源码打包下载地址：

客户端：

[https://github.com/fengfanchen/Java/tree/master/CXFClientDemoInterceptor][https_github.com_fengfanchen_Java_tree_master_CXFClientDemoInterceptor]

服务端：

[https://github.com/fengfanchen/Java/tree/master/CXFServiceDemoInterceptor][https_github.com_fengfanchen_Java_tree_master_CXFServiceDemoInterceptor]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70]: /images/20221124/cfa994fa0d454e6db0c551eb7e5347b7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 1]: /images/20221124/314a2ef4fc1649c28ce0f8ffd3a957f4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 2]: /images/20221124/8594aa7a6f8a412ca0ea0ef94174cd56.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 3]: /images/20221124/6fefac1182e748109d8aea2b0b4914c9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 4]: /images/20221124/80676f7ae4704857a6bcac8a90be73a6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxNzg0NDI3NjE_size_16_color_FFFFFF_t_70 5]: /images/20221124/58a382926fb442e2ba26e44d171f75a9.png
[https_github.com_fengfanchen_Java_tree_master_CXFClientDemoInterceptor]: https://github.com/fengfanchen/Java/tree/master/CXFClientDemoInterceptor
[https_github.com_fengfanchen_Java_tree_master_CXFServiceDemoInterceptor]: https://github.com/fengfanchen/Java/tree/master/CXFServiceDemoInterceptor