如下搭建的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增加拦截器与自定义拦截器的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。