使用 CXF 做 webservice 简单例子

applicationContext-cxf.xml:

<!--客户端 俱乐部平台提供接口 -->
    <jaxws:client id="thumbClubServiceClient" serviceClass="com.bplow.look.ws.service.ThumbClubService" address="http://localhost:8080/cms/services/thumbClubServiceWeb">
    </jaxws:client>
   
    <!--服务器端 俱乐部平台提供接口 -->
    <jaxws:endpoint id="thumbClubServiceEP" address="/thumbClubServiceWeb">
        <jaxws:implementor ref="thumbClubServiceWeb" />
        <jaxws:properties>
            <entry key="mtom-enabled" value="true" />
        </jaxws:properties>
    </jaxws:endpoint>
    <bean id="thumbClubServiceWeb" class="com.bplow.look.ws.service.impl.ThumbClubServiceImpl" />
    <bean id="thumbClubJdbcDaoWeb" class="com.bplow.look.ws.dao.ThumbClubJdbcDao" parent="baseJdbcDao"/>
    <bean id="thumbClubHibernateWeb" class="com.bplow.look.ws.dao.ThumbClubHibernate"/>

测试获取bean:

ThumbClubService thumbClubServiceClient =
            (ThumbClubService)SpringUtils.getBean("thumbClubServiceClient");

 

IP地址拦截器 ：

applicationContext-cxf.xml：

<!--客户端 拇指俱乐部平台提供接口 -->
    <jaxws:client id="thumbClubServiceClient" serviceClass="com.bplow.look.ws.service.ThumbClubService" address="http://localhost:8080/cms/services/thumbClubServiceWeb">
    </jaxws:client>
   
    <!--服务器端 拇指俱乐部平台提供接口 -->
    <jaxws:endpoint id="thumbClubServiceEP" address="/thumbClubServiceWeb">
        <jaxws:implementor ref="thumbClubServiceWeb" />
        <jaxws:inInterceptors>
            <bean class="com.bplow.look.ws.filter.IpAddressInInterceptor"/>
        </jaxws:inInterceptors>
        <jaxws:properties>
            <entry key="mtom-enabled" value="true" />
        </jaxws:properties>
    </jaxws:endpoint>
    <bean id="thumbClubServiceWeb" class="com.bplow.look.ws.service.impl.ThumbClubServiceImpl" />
    <bean id="thumbClubJdbcDaoWeb" class="com.bplow.look.ws.dao.ThumbClubJdbcDao" parent="baseJdbcDao"/>
    <bean id="thumbClubHibernateWeb" class="com.bplow.look.ws.dao.ThumbClubHibernate"/>

 

IpAddressInInterceptor.java：

package com.bplow.look.ws.filter;

import java.util.List;

import javax.servlet.http.HttpServletRequest;

import org.apache.cxf.interceptor.Fault;
import org.apache.cxf.message.Message;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.apache.cxf.transport.http.AbstractHTTPDestination;

 /** 
  * IP地址拦截器 
  * @author wmc 
  * 
  */ 
 public class IpAddressInInterceptor extends AbstractPhaseInterceptor<Message> {  
  
     public IpAddressInInterceptor() {
         super(Phase.RECEIVE);
     }
  
     public void handleMessage(Message message) {
         // 通过一个IpAddressConfig对象，从XML文件中读取预先设置的允许和拒绝的IP地址，这些值也可以来自数据库
         List<String> allowedList = IpAddressConfig.getAllowedList(); // 允许访问的IP地址
         List<String> deniedList = IpAddressConfig.getDeniedList(); // 拒绝访问的IP地址
         HttpServletRequest request = (HttpServletRequest) message.get(AbstractHTTPDestination.HTTP_REQUEST);
         String ipAddress = request.getRemoteAddr(); // 取客户端IP地址
         System.out.println("ip:               "+ipAddress);
         // 先处理拒绝访问的地址
         for (String deniedIpAddress : deniedList) {
             if (deniedIpAddress.equals(ipAddress)) {
                 throw new Fault(new IllegalAccessException("ip地址 " + ipAddress + " 拒绝访问"));
             }
         }
         // 如果允许访问的集合非空，继续处理，否则认为全部IP地址均合法
         if (allowedList.size() > 0) {
             boolean contains = false;
             for (String allowedIpAddress : allowedList) {
                 if (allowedIpAddress.equals(ipAddress)) {
                     contains = true;
                     break;
                 }
             }
             if (!contains) {
                 throw new Fault(new IllegalAccessException("ip地址 " + ipAddress + " 不允许访问"));
             }
         }
     }

 }

 

IpAddressConfig.java：

package com.bplow.look.ws.filter;

import java.util.ArrayList;
import java.util.List;

public class IpAddressConfig {
   
    // 允许访问的IP地址
    public static List<String> getAllowedList(){
        List<String> li = new ArrayList<String>();
        li.add("192.168.1.30");
        return li;
    }
   
    // 拒绝访问的IP地址
    public static List<String> getDeniedList(){
        List<String> li = new ArrayList<String>();
        li.add("127.0.0.1");
        return li;
    }

}