经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » Java相关 » Spring Boot » 查看文章
Spring Boot快速实现 IP地址解析的示例详解
来源：jb51　　时间：2022/8/16 19:27:59　　对本文有异议

大家好！ 我是慕歌，一只想教你学习 Spring Boot的野生coder！ 欢迎来到慕歌的 Sping boot系列教程，希望通过这个教程带大家搭建基础的 Spring Boot项目，该教程所有知识点均来源于本人的真实开发！

前言

在前一节的学习中，慕歌分享了如何构建自己的小型日志用于记录一些关键性的信息，监测用户的登录状态等... 在这一节中慕歌将就上一节中关于ip 的点进行详细的讲解，带大家在spring boot 项目中获取请求的ip与详细地址，我们的很多网站app 中都已经新增了ip 地址显示，大家也可以用在自己的开发中，显得更高级。

引入：

如果使用本地ip 解析的话，我们将会借助ip2region，该项目维护了一份较为详细的本地ip 地址对应表，如果为了离线环境的使用，需要导入该项目依赖，并指定版本，不同版本的方法可能存在差异。

  1. <!--    ip库-->
  2. <dependency>
  3. 	<groupId>org.lionsoul</groupId>
  4. 	<artifactId>ip2region</artifactId>
  5. 	<version>2.6.3</version>
  6.         </dependency>

官方gitee：gitee.com/lionsoul/ip…

开发：

在使用时需要将 xdb 文件下载到工程文件目录下，使用ip2region即使是完全基于 xdb 文件的查询，单次查询响应时间在十微秒级别，可通过如下两种方式开启内存加速查询：

  • vIndex 索引缓存 ：使用固定的 512KiB 的内存空间缓存 vector index 数据，减少一次 IO 磁盘操作，保持平均查询效率稳定在10-20微秒之间。
  • xdb 整个文件缓存：将整个 xdb 文件全部加载到内存，内存占用等同于 xdb 文件大小，无磁盘 IO 操作，保持微秒级别的查询效率。
  1. /**
  2.  * ip查询
  3.  */
  4. @Slf4j
  5. public class IPUtil {
  6.     private static final String UNKNOWN = "unknown";
  7.     protected IPUtil(){ }
  8.     /**
  9.      * 获取 IP地址
  10.      * 使用 Nginx等反向代理软件， 则不能通过 request.getRemoteAddr()获取 IP地址
  11.      * 如果使用了多级反向代理的话，X-Forwarded-For的值并不止一个，而是一串IP地址，
  12.      * X-Forwarded-For中第一个非 unknown的有效IP字符串，则为真实IP地址
  13.      */
  14.     public static String getIpAddr(HttpServletRequest request) {
  15.         String ip = request.getHeader("x-forwarded-for");
  16.         if (ip == null || ip.length() == 0 || UNKNOWN.equalsIgnoreCase(ip)) {
  17.             ip = request.getHeader("Proxy-Client-IP");
  18.         }
  19.         if (ip == null || ip.length() == 0 || UNKNOWN.equalsIgnoreCase(ip)) {
  20.             ip = request.getHeader("WL-Proxy-Client-IP");
  21.         }
  22.         if (ip == null || ip.length() == 0 || UNKNOWN.equalsIgnoreCase(ip)) {
  23.             ip = request.getRemoteAddr();
  24.         }
  25.         return "0:0:0:0:0:0:0:1".equals(ip) ? "127.0.0.1" : ip;
  26.     }
  27.     public static  String getAddr(String ip){
  28.         String dbPath = "src/main/resources/ip2region/ip2region.xdb";
  29.         // 1、从 dbPath 加载整个 xdb 到内存。
  30.         byte[] cBuff;
  31.         try {
  32.             cBuff = Searcher.loadContentFromFile(dbPath);
  33.         } catch (Exception e) {
  34.             log.info("failed to load content from `%s`: %s\n", dbPath, e);
  35.             return null;
  36.         }
  37.         // 2、使用上述的 cBuff 创建一个完全基于内存的查询对象。
  38.         Searcher searcher;
  39.         try {
  40.             searcher = Searcher.newWithBuffer(cBuff);
  41.         } catch (Exception e) {
  42.            log.info("failed to create content cached searcher: %s\n", e);
  43.             return null;
  44.         }
  45.         // 3、查询
  46.         try {
  47.             String region = searcher.searchByStr(ip);
  48.             return region;
  49.         } catch (Exception e) {
  50.             log.info("failed to search(%s): %s\n", ip, e);
  51.         }
  52.         return null;
  53.     }

这里我们将ip 解析封装成一个工具类，包含获取IP和ip 地址解析两个方法，ip 的解析可以在请求中获取。获取到ip后，需要根据ip ，在xdb 中查找对应的IP地址的解析，由于是本地数据库可能存在一定的缺失，部分ip 存在无法解析的情况。

在线解析:

如果想要获取更加全面的ip 地址信息，可使用在线数据库，这里提供的是 whois.pconline.com 的IP解析，该IP解析在我的使用过程中表现非常流畅，而且只有少数的ip 存在无法解析的情况。

  1. @Slf4j
  2. public class AddressUtils {
  3.     // IP地址查询
  4.     public static final String IP_URL = "http://whois.pconline.com.cn/ipJson.jsp";
  5.  
  6.     // 未知地址
  7.     public static final String UNKNOWN = "XX XX";
  8.  
  9.     public static String getRealAddressByIP(String ip) {
  10.         String address = UNKNOWN;
  11.         // 内网不查询
  12.         if (IpUtils.internalIp(ip)) {
  13.             return "内网IP";
  14.         }
  15.         if (true) {
  16.             try {
  17.                 String rspStr = sendGet(IP_URL, "ip=" + ip + "&json=true" ,"GBK");
  18.                 if (StrUtil.isEmpty(rspStr)) {
  19.                     log.error("获取地理位置异常 {}" , ip);
  20.                     return UNKNOWN;
  21.                 }
  22.                 JSONObject obj = JSONObject.parseObject(rspStr);
  23.                 String region = obj.getString("pro");
  24.                 String city = obj.getString("city");
  25.                 return String.format("%s %s" , region, city);
  26.             } catch (Exception e) {
  27.                 log.error("获取地理位置异常 {}" , ip);
  28.             }
  29.         }
  30.         return address;
  31.     }
  32.     public static String sendGet(String url, String param, String contentType) {
  33.         StringBuilder result = new StringBuilder();
  34.         BufferedReader in = null;
  35.         try {
  36.             String urlNameString = url + "?" + param;
  37.             log.info("sendGet - {}" , urlNameString);
  38.             URL realUrl = new URL(urlNameString);
  39.             URLConnection connection = realUrl.openConnection();
  40.             connection.setRequestProperty("accept" , "*/*");
  41.             connection.setRequestProperty("connection" , "Keep-Alive");
  42.             connection.setRequestProperty("user-agent" , "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
  43.             connection.connect();
  44.             in = new BufferedReader(new InputStreamReader(connection.getInputStream(), contentType));
  45.             String line;
  46.             while ((line = in.readLine()) != null) {
  47.                 result.append(line);
  48.             }
  49.             log.info("recv - {}" , result);
  50.         } catch (ConnectException e) {
  51.             log.error("调用HttpUtils.sendGet ConnectException, url=" + url + ",param=" + param, e);
  52.         } catch (SocketTimeoutException e) {
  53.             log.error("调用HttpUtils.sendGet SocketTimeoutException, url=" + url + ",param=" + param, e);
  54.         } catch (IOException e) {
  55.             log.error("调用HttpUtils.sendGet IOException, url=" + url + ",param=" + param, e);
  56.         } catch (Exception e) {
  57.             log.error("调用HttpsUtil.sendGet Exception, url=" + url + ",param=" + param, e);
  58.         } finally {
  59.             try {
  60.                 if (in != null) {
  61.                     in.close();
  62.                 }
  63.             } catch (Exception ex) {
  64.                 log.error("调用in.close Exception, url=" + url + ",param=" + param, ex);
  65.             }
  66.         }
  67.         return result.toString();
  68.     }
  69. }

场景：

那么在开发的什么流程获取ip 地址是比较合适的，这里就要用到我们的拦截器了。拦截进入服务的每个请求，进行前置操作，在进入时就完成请求头的解析，ip 获取以及ip 地址解析，这样在后续流程的全环节，都可以复用ip 地址等信息。

  1. /**
  2.  * 对ip 进行限制，防止IP大量请求
  3.  */
  4. @Slf4j
  5. @Configuration
  6. public class IpUrlLimitInterceptor implements HandlerInterceptor{
  7.  
  8.     @Override
  9.     public boolean preHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o) {
  10.  
  11.         //更新全局变量
  12.         Constant.IP = IPUtil.getIpAddr(httpServletRequest);
  13.         Constant.IP_ADDR = AddressUtils.getRealAddressByIP(Constant.IP);
  14.         Constant.URL = httpServletRequest.getRequestURI();
  15.         return true;
  16.     }
  17.  
  18.     @Override
  19.     public void postHandle(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o, ModelAndView modelAndView) {
  20.         //通过本地获取
  21. //        获得ip
  22. //        String ip = IPUtil.getIpAddr(httpServletRequest);
  23.         //解析具体地址
  24. //        String addr = IPUtil.getAddr(ip);
  25.  
  26.         //通过在线库获取
  27. //        String ip = IpUtils.getIpAddr(httpServletRequest);
  28. //        String ipaddr = AddressUtils.getRealAddressByIP(ipAddr);
  29. //        log.info("IP >> {},Address >> {}",ip,ipaddr);
  30.     }
  31.  
  32.     @Override
  33.     public void afterCompletion(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, Object o, Exception e) {
  34.  
  35.     }
  36. }
  1. 如果想要执行我们的ip 解析拦截器，需要在spring boot的视图层进行拦截才会触发我们的拦截器。
  1. @Configuration
  2. public class WebConfig implements WebMvcConfigurer {
  3.     @Autowired
  4.     IpUrlLimitInterceptor ipUrlLimitInterceptor;
  5. 	
  6. 	    //执行ip拦截器
  7.     @Override
  8.     public void addInterceptors(InterceptorRegistry registry){
  9.         registry.addInterceptor(ipUrlLimitInterceptor)
  10.                 // 拦截所有请求
  11.                 .addPathPatterns("/**");
  12.     }
  13. }
  1. 通过这样的一套流程下来，我们就能实现对每一个请求进行ip 获取、ip解析，为每个请求带上具体ip地址的小尾巴。

到此这篇关于Spring Boot快速实现 IP地址解析的文章就介绍到这了,更多相关Spring Boot IP地址内容请搜索w3xue以前的文章或继续浏览下面的相关文章希望大家以后多多支持w3xue！

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

Spring Boot热门文章

  • 史上最详 Thymeleaf 使用教程
  • Spring Boot如何通过java -jar启动
  • Spring Boot 2.x（六）：优雅的统一返回值
  • Springboot使用Logback实现日志配置与异常记录
  • 使用SpringBoot+EasyExcel+Vue实现excel表格的导入和导出详解
  • spring boot上传文件超出大小异常无法捕获问题
  • paging组件的用法和意义
  • springboot2.0集成rabbitmq的示例代码
  • Spring MVC学习step1——框架熟悉
  • spring boot ${}占位符不起作用的解决方案

    • Spring Boot推荐文章

  • 3分钟带你搞定Spring Boot中Schedule
  • 不单独部署注册中心，又要具备注册中心的功能，我能上天！
  • 从零开始学Spring Boot系列-集成Spring Security实现用户认证与授权
  • 不单独部署注册中心，又要具备注册中心的功能，咋不让我上天？
  • EasyExcel 无法读取图片？用poi写了一个工具类
  • 【进阶篇】使用 Stream 流对比两个集合的常用操作分享
  • 关于DDD和COLA的一些总结和思考
  • SnakeYaml反序列化分析
  • RestTemplate进行https请求时适配信任证书
  • Kryo反序列化链分析

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号