CXF之Features运用实例

自定义客户端的拦截器：

package cxf.client; import org.apache.cxf.binding<a href="/tag/so/" target="_blank" class="keywords">.so</a>ap<a href="/tag/so/" target="_blank" class="keywords">.so</a>apMessage; import org.apache.cxf.binding<a href="/tag/so/" target="_blank" class="keywords">.so</a>ap.interceptor.AbstractSoapInterceptor; import org.apache.cxf.interceptor.Fault; import org.apache.cxf.phase.Phase; public class MyClientInterceptor extends AbstractSoapInterceptor { public MyClientInterceptor() { //一定要指定这个<a href="/tag/lanjie/" target="_blank" class="keywords">拦截</a>器放在<a href="/tag/lanjie/" target="_blank" class="keywords">拦截</a>器链的哪个阶段，这里放在最开始阶段。 super(Phase.SETUP); } @Override public void handleMessage(SoapMessage message) throws Fault { Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("client: MyClientInterceptor!!!!"); } }  

 

自定义客户端用Feature,将MyClientInterceptor添加到该Featrue:

package cxf.client; import org.apache.cxf.Bus; import org.apache.cxf.feature.AbstractFeature; import org.apache.cxf.interceptor.InterceptorProvider; public class MyClientFeature extends AbstractFeature{ @Override protected void initializeProvider(InterceptorProvider provider,Bus bus) { MyClientInterceptor myClientInt = new MyClientInterceptor(); provider.g<a href="/tag/eto/" target="_blank" class="keywords">eto</a>utInterceptors().add(myClientInt); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("client : MyClientFeature!!!!!!!"); } }  

 

客户端配置：

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/<a href="/tag/springbean/" target="_blank" class="keywords">spring-bean</a>s.xsd http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"> <jaxws:client id="client" address="http://localhost:8085/java_f<a href="/tag/irs/" target="_blank" class="keywords">irs</a>t_spring_support1/service/HelloWorld" serviceClass="cxf.server.HelloWorld"> <jaxws:features> <bean class="cxf.client.MyClientFeature"/> </jaxws:features> </jaxws:client> </beans>  

 

客户端调用：

package cxf.client; import org.springframework.context.support.Cla<a href="/tag/ssp/" target="_blank" class="keywords">ssp</a>athXmlApplicationContext; import cxf.server.HelloWorld; public final class Client { public static void main(String args[]) throws Exception { Cla<a href="/tag/ssp/" target="_blank" class="keywords">ssp</a>athXmlApplicationContext context = new Cla<a href="/tag/ssp/" target="_blank" class="keywords">ssp</a>athXmlApplicationContext(new String[] {"client-beans.xml"}); HelloWorld client = (HelloWorld)context.getBean("client"); String response = client.sayHi("Joe"); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("Response: " + response); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.exit(0); } }  

 

服务接口：

package cxf.server; import javax.jws.WebService; @WebService public interface HelloWorld { String sayHi(String text); }  

 

服务接口实现 ：

package cxf.server; import javax.jws.WebService; @WebService(endpointInterface = "cxf.server.HelloWorld") public class HelloWorldImpl implements HelloWorld { public String sayHi(String text) { Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("sayHi called"); return "Hello " + text; } }  

 

自定义的服务端的输入拦截器：

package cxf.server; import org.apache.cxf.binding<a href="/tag/so/" target="_blank" class="keywords">.so</a>ap<a href="/tag/so/" target="_blank" class="keywords">.so</a>apMessage; import org.apache.cxf.binding<a href="/tag/so/" target="_blank" class="keywords">.so</a>ap.interceptor.AbstractSoapInterceptor; import org.apache.cxf.interceptor.Fault; import org.apache.cxf.phase.Phase; public class MyServerInterceptor extends AbstractSoapInterceptor { public MyServerInterceptor() { //一定要指定这个<a href="/tag/lanjie/" target="_blank" class="keywords">拦截</a>器放在<a href="/tag/lanjie/" target="_blank" class="keywords">拦截</a>器链的哪个阶段，这里放在最开始阶段。 super(Phase.RECEIVE ); } @Override public void handleMessage(SoapMessage message) throws Fault { Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("server: MyServerInterceptor!!!"); } }  

 

自定义的服务端用的Feature,该Feature加入了MyServerInterceptor 拦截器:

package cxf.server; import org.apache.cxf.Bus; import org.apache.cxf.feature.AbstractFeature; import org.apache.cxf.interceptor.InterceptorProvider; public class MyServerFeature extends AbstractFeature { @Override protected void initializeProvider(InterceptorProvider provider,Bus bus) { MyServerInterceptor myInt = new MyServerInterceptor(); provider.ge<a href="/tag/tini/" target="_blank" class="keywords">tini</a>nterceptors().add(myInt); Sy<a href="/tag/stem/" target="_blank" class="keywords">stem</a>.out.println("server: MyServerFeature!!!!!!!!"); } }  

 

服务端配置： 

<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:jaxws="http://cxf.apache.org/jaxws" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/<a href="/tag/springbean/" target="_blank" class="keywords">spring-bean</a>s.xsd http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd"> <import resource="cla<a href="/tag/ssp/" target="_blank" class="keywords">ssp</a>ath:<a href="/tag/metainf/" target="_blank" class="keywords">meta-inf</a>/cxf/cxf.xml" /> <import resource="cla<a href="/tag/ssp/" target="_blank" class="keywords">ssp</a>ath:<a href="/tag/metainf/" target="_blank" class="keywords">meta-inf</a>/cxf/cxf-extension-soap.xml" /> <import resource="cla<a href="/tag/ssp/" target="_blank" class="keywords">ssp</a>ath:<a href="/tag/metainf/" target="_blank" class="keywords">meta-inf</a>/cxf/cxf-servlet.xml" /> <jaxws:endpoint id="helloWorld" implementor="cxf.server.HelloWorldImpl" address="/HelloWorld"> <jaxws:features> <bean class="cxf.server.MyServerFeature"/> </jaxws:features> </jaxws:endpoint> </beans>