SpringMVC通过拦截器实现IP黑名单

2023-08-18 03:11:04 74

本文实例为大家分享了SpringMVC通过拦截器实现IP黑名单的具体代码，供大家参考，具体内容如下

以前没有遇到这个需要，后面在网上找了很久，参考了很多文档给出的方案。

1.配置拦截器

这里使用全局拦截：

拦截器LoginInterceptor代码：

packagecom.nps.base.filter;
importjava.io.IOException;
importjava.util.Enumeration;
importjava.util.HashMap;
importjava.util.Map;
importjavax.servlet.http.HttpServletRequest;
importjavax.servlet.http.HttpServletResponse;
importorg.slf4j.Logger;
importorg.slf4j.LoggerFactory;
importorg.springframework.web.servlet.HandlerInterceptor;
importorg.springframework.web.servlet.ModelAndView;
importcom.nps.utils.IpInterceptUtils;

/**
*验证拦截器
*@authorHUANG
*/
publicclassLoginInterceptorimplementsHandlerInterceptor{
privatefinalstaticLoggerlogger=LoggerFactory
.getLogger(LoginInterceptor.class);

@Override
publicvoidafterCompletion(HttpServletRequestarg0,
HttpServletResponsearg1,Objectarg2,Exceptionarg3)
throwsException{

}

@Override
publicvoidpostHandle(HttpServletRequestarg0,HttpServletResponsearg1,
Objectarg2,ModelAndViewarg3)throwsException{

}

@Override
publicbooleanpreHandle(HttpServletRequestrequest,
HttpServletResponseresponse,Objecthandler)throwsException{
Stringip=getIpAddress(request);
if(IpInterceptUtils.chickIpBreak(ip)){
returnfalse;
}
Mapmap=getParameterMap(request);//获取url中的所有参数
StringservletUrl=request.getServletPath();//servlet地址
Stringurl=getRealUrl(servletUrl,map);

if(url.indexOf("/user/")==0){
Objectuser=request.getSession().getAttribute("User");
if(user==null){
//System.out.println("尚未登录，调到登录页面");
response.sendRedirect(request.getContextPath()+"/loginOut.do");
returnfalse;
}
}

returntrue;
}

/**
*获取请求主机IP地址,如果通过代理进来，则透过防火墙获取真实IP地址;
*
*@paramrequest
*@return
*@throwsIOException
*/
publicfinalstaticStringgetIpAddress(HttpServletRequestrequest)
throwsIOException{
//获取请求主机IP地址,如果通过代理进来，则透过防火墙获取真实IP地址

Stringip=request.getHeader("X-Forwarded-For");
//if(logger.isInfoEnabled()){
//logger.info("getIpAddress(HttpServletRequest)-X-Forwarded-For-Stringip="
//+ip);
//}

if(ip==null||ip.length()==0||"unknown".equalsIgnoreCase(ip)){
if(ip==null||ip.length()==0
||"unknown".equalsIgnoreCase(ip)){
ip=request.getHeader("Proxy-Client-IP");
//if(logger.isInfoEnabled()){
//logger.info("getIpAddress(HttpServletRequest)-Proxy-Client-IP-Stringip="
//+ip);
//}
}
if(ip==null||ip.length()==0
||"unknown".equalsIgnoreCase(ip)){
ip=request.getHeader("WL-Proxy-Client-IP");
//if(logger.isInfoEnabled()){
//logger.info("getIpAddress(HttpServletRequest)-WL-Proxy-Client-IP-Stringip="
//+ip);
//}
}
if(ip==null||ip.length()==0
||"unknown".equalsIgnoreCase(ip)){
ip=request.getHeader("HTTP_CLIENT_IP");
//if(logger.isInfoEnabled()){
//logger.info("getIpAddress(HttpServletRequest)-HTTP_CLIENT_IP-Stringip="
//+ip);
//}
}
if(ip==null||ip.length()==0
||"unknown".equalsIgnoreCase(ip)){
ip=request.getHeader("HTTP_X_FORWARDED_FOR");
//if(logger.isInfoEnabled()){
//logger.info("getIpAddress(HttpServletRequest)-HTTP_X_FORWARDED_FOR-Stringip="
//+ip);
//}
}
if(ip==null||ip.length()==0
||"unknown".equalsIgnoreCase(ip)){
ip=request.getRemoteAddr();
//if(logger.isInfoEnabled()){
//logger.info("getIpAddress(HttpServletRequest)-getRemoteAddr-Stringip="
//+ip);
//}
}
}elseif(ip.length()>15){
String[]ips=ip.split(",");
for(intindex=0;indexgetParameterMap(HttpServletRequestrequest){
Enumerationnames=request.getParameterNames();
Stringname;
Mapmap=newHashMap();
while(names.hasMoreElements()){
name=names.nextElement();
map.put(name,request.getParameter(name).trim().replaceAll("'",""));
}
returnmap;
}

/**
*获取url
*
*@paramuri
*@paramparams
*@return
*/
StringgetRealUrl(Stringuri,Mapparams){
StringBuffersb=newStringBuffer(uri);
if(params!=null){
inti=0;
for(Stringkey:params.keySet()){
i++;
if(i==1){
sb.append("?"+key+"="+params.get(key));
}else{
sb.append("&"+key+"="+params.get(key));
}
}
}
returnsb.toString();
}
}

2.校验IP工具

publicclassIpInterceptUtils{
privatestaticStringdate;
privatestaticPropertiesUtilp=null;
/***
*校验IP是否加入黑名单
*@paramip
*@returntrue是在黑名单
*@throwsIOException
*/
publicstaticbooleanchickIpBreak(Stringip)throwsIOException{
if(p==null){
p=newPropertiesUtil("conf/ip-black.properties");
}else{
Stringstr=newSimpleDateFormat("MMddHHmmss").format(newDate());
str=str.substring(0,9);
if(date==null||!date.equals(str)){
date=str;
p=newPropertiesUtil("conf/ip-black.properties");
}
}
Enumerationen=p.getProps().propertyNames();
while(en.hasMoreElements()){
Stringkey=(String)en.nextElement();
if(key.equals(ip)){
returntrue;
}
}
returnfalse;
}
}

3.配置文件读取类

PropertiesUtil

packagecom.nps.base.model;

importjava.io.FileInputStream;
importjava.io.FileNotFoundException;
importjava.io.FileOutputStream;
importjava.io.IOException;
importjava.io.InputStream;
importjava.io.OutputStream;
importjava.util.Enumeration;
importjava.util.HashMap;
importjava.util.Map;
importjava.util.Properties;

importorg.springframework.stereotype.Component;

/**
*读取Properties综合类,默认绑定到classpath下的config.properties文件。
*@author
*/
@Component("PropertiesUtil")
publicclassPropertiesUtil{
//配置文件的路径
privateStringconfigPath=null;

/**
*配置文件对象
*/
privatePropertiesprops=null;

/**
*默认构造函数，用于sh运行，自动找到classpath下的config.properties。
*/
publicPropertiesUtil()throwsIOException{
if(props==null){
InputStreamin=PropertiesUtil.class.getClassLoader().getResourceAsStream("conf/application.properties");
props=newProperties();
props.load(in);
//关闭资源
in.close();
}

}

/**
*默认构造函数，用于sh运行，自动找到classpath下的config.properties。
*/
publicPropertiesUtil(Stringpath)throwsIOException{
if(props==null){
InputStreamin=PropertiesUtil.class.getClassLoader().getResourceAsStream(path);
props=newProperties();
props.load(in);
//关闭资源
in.close();
}

}

/**
*根据key值读取配置的值
*Jun26,20109:15:43PM
*@author朱志杰
*@paramkeykey值
*@returnkey键对应的值
*@throwsIOException
*/
publicStringreadValue(Stringkey)throwsIOException{
returnprops.getProperty(key);
}

/**
*读取properties的全部信息
*@throwsFileNotFoundException配置文件没有找到
*@throwsIOException关闭资源文件，或者加载配置文件错误
*
*/
publicMapreadAllProperties()throwsFileNotFoundException,IOException{
//保存所有的键值
Mapmap=newHashMap();
Enumerationen=props.propertyNames();
while(en.hasMoreElements()){
Stringkey=(String)en.nextElement();
StringProperty=props.getProperty(key);
map.put(key,Property);
}
returnmap;
}

/**
*设置某个key的值,并保存至文件。
*@paramkeykey值
*@returnkey键对应的值
*@throwsIOException
*/
publicvoidsetValue(Stringkey,Stringvalue)throwsIOException{
Propertiesprop=newProperties();
InputStreamfis=newFileInputStream(this.configPath);
//从输入流中读取属性列表（键和元素对）
prop.load(fis);
//调用Hashtable的方法put。使用getProperty方法提供并行性。
//强制要求为属性的键和值使用字符串。返回值是Hashtable调用put的结果。
OutputStreamfos=newFileOutputStream(this.configPath);
prop.setProperty(key,value);
//以适合使用load方法加载到Properties表中的格式，
//将此Properties表中的属性列表（键和元素对）写入输出流
prop.store(fos,"lastupdate");
//关闭文件
fis.close();
fos.close();
}

/**
*@returntheprops
*/
publicPropertiesgetProps(){
returnprops;
}

publicstaticvoidmain(String[]args){
PropertiesUtilp;
try{
p=newPropertiesUtil("conf/ip-black.properties");
Enumerationen=p.props.propertyNames();
Stringstr="";
while(en.hasMoreElements()){
Stringkey=(String)en.nextElement();
System.out.println(key);
}

}catch(IOExceptione){
//TODOAuto-generatedcatchblock
e.printStackTrace();
}
}


}

附上黑名单IP文件格式

ip-black.properties配置文件

45.119.99.35
103.253.2.165
157.65.166.51
202.57.55.242
119.82.252.122
140.227.53.126
140.227.211.20
140.227.208.20
116.253.84.183

附加

之所以使用配置文件读取黑名单IP是为了加快数据读取速度，因为每次访问服务器都会被校验，使用数据库会加大数据库的压力，这个方法中每10秒就会重新读取配置文件缓存其实更好，不使用缓存主要是为了，因为放在缓存中还要写对应的操作方法，如果有什么更好的方法欢迎大家讨论。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

SpringMVC通过拦截器实现IP黑名单

热门推荐

随机推荐