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

如下搭建的Webservice：

在服务端填写如下代码：

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

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();}
}

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

客户端：

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

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

客户端去判断：

客户关键端源码如下：

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/CXFServiceDemoInterceptor

Java笔记-CXF增加拦截器与自定义拦截器相关推荐

WebServices中使用cxf开发日志拦截器以及自定义拦截器
首先下载一个cxf实例,里面包含cxf的jar包.我下的是apache-cxf-2.5.9 1.为什么要设置拦截器? 为了在webservice请求过程中,能动态操作请求和响应数据, CXF设计了拦截 ...
flume拦截器及自定义拦截器
拦截器做什么呢? 时间拦截器以时间拦截器为例.会在Event的header中添加一个属性进去,属性的key叫做timestamp, value是当前的毫秒值. 问题是写到header然后呢?有啥用呢 ...
Elasticsearch 分布式搜索引擎 -- 自动补全（拼音分词器、自定义分词器、自动补全查询、实现搜索框自动补全）
文章目录 1. 自动补全 1.1 拼音分词器 1.2.1 自定义分词器 1.2.2 小结 1.2 自动补全 1.3 实现酒店搜索框自动补全 1.3.1 修改酒店映射结构 1.3.2 修改HotelDo ...
Elasticsearch7 分词器(内置分词器和自定义分词器)
文章目录 Elasticsearch7 分词器(内置分词器和自定义分词器) analysis 概览 char_filter html_strip mapping pattern_replace fil ...
ElasticSearch入门：ES分词器与自定义分词器
ES入门:ES分词器与自定义分词器分词器的简单介绍不同分词器的效果对比自定义分词器的应用分词器的简单介绍分词器是es中的一个组件,通俗意义上理解,就是将一段文本按照一定的逻辑,分析成多个词语 ...
59、Docker ElasticSearch安装拼音分词器及自定义分词器
一.使用拼音分词器 1.拼音分词器 2.docker下安装拼音分词器插件 3.测试拼音分词器 # 测试拼音分词器 POST /_analyze { "text": [" ...
从struts2拦截器到自定义拦截器
http://www.cnblogs.com/withyou/p/3170440.html 拦截器可谓struts2的核心了,最基本的bean的注入就是通过默认的拦截器实现的,一般在struts2.x ...
Struts2内置拦截器和自定义拦截器
内置拦截器 Struts2中内置类许多的拦截器,它们提供了许多Struts2的核心功能和可选的高级特性.这些内置的拦截器在struts-default.xml中配置.只有配置了拦截器,拦截器才可以正常 ...
Struts2第七篇【介绍拦截器、自定义拦截器、执行流程、应用】
什么是拦截器拦截器Interceptor-..拦截器是Struts的概念,它与过滤器是类似的-可以近似于看作是过滤器为什么我们要使用拦截器前面在介绍Struts的时候已经讲解过了,Struts为 ...

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

Java笔记-CXF增加拦截器与自定义拦截器相关推荐

最新文章

热门文章