舞蹈 心翼:CXF拦截器（Interceptor）的使用（2） - 豆豆网

　　和Message打交道就离不开Exchange。Exchange建立In/Out，InFault/OutFault Message 之间的联系。你可以从Exchange中获取到与消息传输相关的Conduit，Destination的信息，同时也可以设置和Session相关的其他信息，以及知道是否是OneWay的消息。

　　AbstractFeature

　　为了简化配置Interceptor的复杂操作，在这里设置了AbstractFeature，通过Feature我们可以向Bus，Client，Endpoint配置不同功能的Interceptor组。这样可以极大减轻我们配置文件的体积。

　　在此之前我们如果想把一组Log Interceptors添加到Bus中，需要写的配置文件如下

　　　　　　　　　　　　　　　　id="greeter"
　　　　　　　　　　　　　　　　address="http://localhost:8080/hello"
　　　　　　　　　　　　　　　　implementor="ws.HelloWorldImpl">
　　　　　　　　
　　　　　　　　　　　　　　　　
　　　　　　　　


　　三、CXF拦截器使用

　　CXF的使用也比Axis容易很多，可以单独使用，也可以与Spring完美整合，这里就通过上一个HelloWorld的例子来说明如何使用拦截器。

　　比如，要实现一个SOAP消息请求日志的功能，以便能动态监控请求消息的信息。

　　之需要在在上文例子的基础做一点点改动：

　　服务端

package ws;

import org.apache.cxf.endpoint.Server;
import org.apache.cxf.interceptor.LoggingInInterceptor;
import org.apache.cxf.jaxws.JaxWsServerFactoryBean;

/**
* 服务端程序设置与启动程序
*
* @author leizhimin 2009-6-11 14:41:23
*/
public class HelloWorldServer {
　　　　　　　　public static void main(String[] args) {
　　　　　　　　　　　　　　　　JaxWsServerFactoryBean factory = new JaxWsServerFactoryBean();
　　　　　　　　　　　　　　　　factory.setServiceClass(HelloWorldImpl.class);
　　　　　　　　　　　　　　　　factory.setAddress("http://localhost:8080/service/HelloWorld");
　　　　　　　　　　　　　　　　factory.getInInterceptors().add(new LoggingInInterceptor());
　　　　　　　　　　　　　　　　Server server = factory.create();
　　　　　　　　　　　　　　　　server.start();
　　　　　　　　}
}

package client;

import org.apache.cxf.interceptor.LoggingInInterceptor;
import org.apache.cxf.jaxws.JaxWsProxyFactoryBean;
import ws.HelloWorld;

/**
* 客户端调用代码
*
* @author leizhimin 2009-6-11 14:46:45
*/
public class TestClient {
　　　　　　　　public static void main(String[] args) {
　　　　　　　　　　　　　　　　JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
　　　　　　　　　　　　　　　　factory.setAddress("http://localhost:8080/service/HelloWorld");
　　　　　　　　　　　　　　　　factory.setServiceClass(HelloWorld.class);
　　　　　　　　　　　　　　　　factory.getInInterceptors().add(new LoggingInInterceptor());
　　　　　　　　　　　　　　　　HelloWorld helloWorld = (HelloWorld) factory.create();
　　　　　　　　　　　　　　　　String msg = helloWorld.sayHello("World");
　　　　　　　　　　　　　　　　System.out.println(msg);
　　　　　　　　}
}

　　在服务端和客户端分别加上一个日志拦截器，并将日志拦截器加入到拦截器链中。不过这里的日志拦截器是CXF自己定义好的，直接拿来使用即可。

　　四、测试

　　先运行服务端，然后运行客户端。

　　1、服务端控制台窗口：

　　在服务端控制台打印的日志截图是如下

信息: Inbound Message
----------------------------
ID: 1
Address: /service/HelloWorld
Encoding: UTF-8
Content-Type: text/xml; charset=UTF-8
Headers: {Content-Length=[179], Host=[localhost:8080], User-Agent=[Apache CXF 2.2.2], connection=[keep-alive], SOAPAction=[""], Pragma=[no-cache], Content-Type=[text/xml; charset=UTF-8], content-type=[text/xml; charset=UTF-8], Cache-Control=[no-cache], Accept=[*/*]}
Payload: World
--------------------------------------

　　分析日志可以看出，服务端日志输出了消息id、地址、编码、以及消息内容。

　　2、客户端控制台窗口：

　　在客户端控制台打印的日志截图是如下

　　图片看不清楚？请点击这里查看原图（大图）。

　　实际的日志内容如下：

信息: Inbound Message
----------------------------
ID: 1
Encoding: UTF-8
Content-Type: text/xml; charset=utf-8
Headers: {Content-Length=[206], Server=[Jetty(6.1.18)], content-type=[text/xml; charset=utf-8]}
Payload: Hello World!
--------------------------------------

　　分析日志可以看出，客户端日志输出了消息id、地址、编码、以及消息内容，这里的消息是请求后得到的响应消息。

　　五、定义自己的Interceptor

　　自定的Interceptor一定要实现CXF的Interceptor接口，这个接口中有两个方法：

　void handleFault(T message)

　　 当拦截消息处理失败时候所调用的方法。

　void handleMessage(T message)

　　 拦截了一个消息，并做处理的方法。

　　对于SOAP这种XML格式的消息，开发者处理太过于麻烦，并且CXF提供大量的已经实现好的拦截器可供使用，只要灵活运用这些拦截器就可以满足大部分开发的要求。

　　参考文档：

　　http://cwiki.apache.org/CXF20DOC/index.html

　　互联网的API翻译。

　　出处：http://lavasoft.blog.51cto.com/62575/167288