Go语言视频零基础入门到精通

admin

使用Spring结合CXF创建好服务器端的WebService后，如果我们需要对访问者的IP进行限制，那么我们可以创建一个继承自AbstractPhaseInterceptor类的拦截器。
比如：AccessInterceptor.java类

1. import java.util.Arrays;
   
2. import java.util.List;
   
3. 
   
4. import javax.servlet.http.HttpServletRequest;
   
5. 
   
6. import org.apache.commons.logging.Log;
   
7. import org.apache.commons.logging.LogFactory;
   
8. import org.apache.cxf.interceptor.Fault;
   
9. import org.apache.cxf.message.Message;
   
10. import org.apache.cxf.phase.AbstractPhaseInterceptor;
    
11. import org.apache.cxf.phase.Phase;
    
12. import org.apache.cxf.transport.http.AbstractHTTPDestination;
    
13. 
    
14. import bgi.health.commons.SystemProperties;
    
15. 
    
16. public class AccessInterceptor extends AbstractPhaseInterceptor<Message> {
    
17.     //获取Log日志类
    
18.     private final Log logger = LogFactory.getLog(AccessInterceptor.class);
    
19.    //获取读取配置文件的实体
    
20.     private SystemProperties property = SystemProperties.getInstance();
    
21. 
    
22.    //创建默认的构造方法
    
23.     public AccessInterceptor(){
    
24.         super(Phase.RECEIVE);
    
25.     }
    
26.    
    
27.     @Override
    
28.     public void handleMessage(Message msg) throws Fault {
    
29. 
    
30.       //获取request。
    
31.         HttpServletRequest request = (HttpServletRequest) msg.get(AbstractHTTPDestination.HTTP_REQUEST);
    
32. 
    
33.       //获取当前访问者的IP地址
    
34.         String ipAddress = this.getIp(request);
    
35. 
    
36.      //得到允许访问的IP地址列表 ,从配置文件中读取
    
37.         String accessIpStr = property.getProperty("hims.client.ip");
    
38.         if(accessIpStr!=null && !"".equals(accessIpStr.trim())){
    
39.             String[] ips = accessIpStr.split(",");
    
40.             List<String> iplist = Arrays.asList(ips);
    
41.             if(iplist.contains(ipAddress)){
    
42.                 logger.info("IP address " + ipAddress + " is allowed");
    
43.             }else{
    
44.                 logger.warn("IP address " + ipAddress + " is not allowed");
    
45. 
    
46.                //如果IP地址不被允许，则抛出异常信息给CXF处理。
    
47.                 throw new Fault(new IllegalAccessException("IP address " + ipAddress + " is not allowed"));
    
48.             }
    
49.         }
    
50.     }
    
51.    //得到访问者的IP地址。
    
52.     private String getIp(HttpServletRequest request){
    
53.         String ip = request.getHeader("x-forwarded-for");
    
54.         if(ip==null || ip.length()==0 || "unknown".equalsIgnoreCase(ip)){
    
55.             ip = request.getHeader("Proxy-Client-IP");
    
56.         }
    
57.         if(ip==null || ip.length()==0 || "unknown".equalsIgnoreCase(ip)){
    
58.             ip = request.getHeader("WL-Proxy-Client-IP");
    
59.         }
    
60.         if(ip==null || ip.length()==0 || "unknown".equalsIgnoreCase(ip)){
    
61.             ip = request.getRemoteAddr();
    
62.         }
    
63.         return ip;
    
64.     }
    
65. }

复制代码

然后，在CXF配置文件中配置该拦截器：

1.   <bean id="accessInterceptor" class="******.AccessInterceptor" />
   
2. 
   
3.     <cxf:bus>  
   
4.         <cxf:inInterceptors>  
   
5.             <ref bean="accessInterceptor" />  
   
6.         </cxf:inInterceptors>  
   
7.     </cxf:bus>

复制代码

最后：如果访问者的IP不在配置文件的范围内，那么访问WebService接口时，会出现如下情况：

1. <soap:Envelope>
   
2. <soap:Body>
   
3. <soap:Fault>
   
4. <faultcode>soap:Server</faultcode>
   
5. <faultstring>IP address 127.0.0.1 is not allowed</faultstring>
   
6. </soap:Fault>
   
7. </soap:Body>
   
8. </soap:Envelope>

复制代码

其中:127.0.0.1为访问者IP。

五菱

楼主总结的很好啊！