锋盈数科-知识库 Logo
首页
软件开发
计算机基础
Hello Halo
新手必读
关于本知识库
登录 →
锋盈数科-知识库 Logo
首页 软件开发 计算机基础 Hello Halo 新手必读 关于本知识库
登录
  1. 首页
  2. 软件开发
  3. JAVA
  4. SpringBoot整合Ip2region获取IP地址和定位

SpringBoot整合Ip2region获取IP地址和定位

0
  • JAVA
  • 发布于 2024-08-09
  • 0 次阅读
黄健
黄健

本文由 简悦 SimpRead 转码, 原文地址 blog.csdn.net

格式:每个 ip 数据段的 region 信息都固定了格式:国家 | 区域 | 省份 | 城市 | ISP

参考地址 1
参考地址 2

SpringBoot 整合 Ip2region 获取 IP 地址和定位
SpringBoot 整合 Ip2region 获取 IP 地址和定位
1.Ip2region 的介绍
1.1.Ip2region 是什么
ip2region v2.0 - 是一个离线 IP 地址定位库和 IP 定位数据管理框架,10 微秒级别的查询效率,提供了众多主流编程语言的 xdb 数据生成和查询客户端实现 。

1.2.Ip2region 特性
1.2.1 标准化的数据格式
每个 ip 数据段的 region 信息都固定了格式:国家 | 区域 | 省份 | 城市 | ISP,只有中国的数据绝大部分精确到了城市,其他国家部分数据只能定位到国家,后前的选项全部是 0。

1.2.2. 数据去重和压缩
xdb 格式生成程序会自动去重和压缩部分数据,默认的全部 IP 数据,生成的 ip2region.xdb 数据库是 11MiB,随着数据的详细度增加数据库的大小也慢慢增大。

1.2.3. 极速查询响应
即使是完全基于 xdb 文件的查询,单次查询响应时间在十微秒级别,可通过如下两种方式开启内存加速查询:

vIndex 索引缓存 :使用固定的 512KiB 的内存空间缓存 vector index 数据,减少一次 IO 磁盘操作,保持平均查询效率稳定在 10-20 微秒之间。

xdb 整个文件缓存:将整个 xdb 文件全部加载到内存,内存占用等同于 xdb 文件大小,无磁盘 IO 操作,保持微秒级别的查询效率。

1.2.4.IP 数据管理框架
2.0 格式的 xdb 支持亿级别的 IP 数据段行数,region 信息也可以完全自定义,例如:你可以在 region 中追加特定业务需求的数据,例如:GPS 信息 / 国际统一地域信息编码 / 邮编等。也就是你完全可以使用 ip2region 来管理你自己的 IP 定位数据。

2.Java 方式
2.1. 下载 ip2region.db
$ git clone https://github.com/lionsoul2014/ip2region.git

下载这个项目之后到 data / 文件夹下面找到 ip2region.db 复制到项目 resources 下

2.2.maven 仓库

org.springframework.boot
spring-boot-starter-web

org.springframework.boot
spring-boot-starter-test
test

org.apache.commons
commons-lang3
3.12.0

<!-- IP定位 -->
    <dependency>
        <groupId>org.lionsoul</groupId>
        <artifactId>ip2region</artifactId>
        <version>2.7.0</version>
    </dependency>

    <dependency>
        <groupId>eu.bitwalker</groupId>
        <artifactId>UserAgentUtils</artifactId>
        <version>1.21</version>
    </dependency>

2.3. 代码
package com.nacl.util;

import eu.bitwalker.useragentutils.UserAgent;
import org.apache.commons.lang3.StringUtils;
import org.lionsoul.ip2region.xdb.Searcher;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.FileCopyUtils;

import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.io.InputStream;
import java.net.InetAddress;
import java.net.UnknownHostException;

/**

  • @author HAOYANG

  • @create 2023-08-02 17:03
    */
    public class IpUtils {
    private static final Logger logger = LoggerFactory.getLogger(IpUtils.class);
    private final static String localIp = “127.0.0.1”;

    private static Searcher searcher = null;

    /**

    • 在服务启动时加载 ip2region.db 到内存中
    • 解决打包 jar 后找不到 ip2region.db 的问题
      */
      static {
      try {
      InputStream ris = IpUtils.class.getResourceAsStream(“/ip2region/ip2region.xdb”);
      byte[] dbBinStr = FileCopyUtils.copyToByteArray(ris);
      searcher = Searcher.newWithBuffer(dbBinStr);
      // 注意:不能使用文件类型,打成 jar 包后,会找不到文件
      logger.debug(“缓存成功!!!!”);
      } catch (IOException e) {
      logger.error(“解析 ip 地址失败, 无法创建搜索器: {}”, e);
      throw new RuntimeException(e);
      }
      }

    /**

    • 获取用户真实 IP 地址,不使用 request.getRemoteAddr(); 的原因是有可能用户使用了代理软件方式避免真实 IP 地址,

    • 参考文章: http://developer.51cto.com/art/201111/305181.htm

    • 可是,如果通过了多级反向代理的话,X-Forwarded-For 的值并不止一个,而是一串 IP 值,究竟哪个才是真正的用户端的真实 IP 呢?

    • 答案是取 X-Forwarded-For 中第一个非 unknown 的有效 IP 字符串。

    • 如:X-Forwarded-For:192.168.1.110, 192.168.1.120, 192.168.1.130,

    • 192.168.1.100

    • 用户真实 IP 为: 192.168.1.110

    • @param request

    • @return
      */
      public static String getIp(HttpServletRequest request) {
      String ipAddress;
      try {
      // 以下两个获取在 k8s 中,将真实的客户端 IP,放到了 x-Original-Forwarded-For。而将 WAF 的回源地址放到了 x-Forwarded-For 了。
      ipAddress = request.getHeader(“X-Original-Forwarded-For”);
      if (ipAddress == null || “unknown”.equalsIgnoreCase(ipAddress)) {
      ipAddress = request.getHeader(“X-Forwarded-For”);
      }

      //获取nginx等代理的ip
       if (ipAddress == null || "unknown".equalsIgnoreCase(ipAddress)) {
           ipAddress = request.getHeader("x-forwarded-for");
       }
       if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
           ipAddress = request.getHeader("Proxy-Client-IP");
       }
       if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
           ipAddress = request.getHeader("WL-Proxy-Client-IP");
       }
       if (ipAddress == null || "unknown".equalsIgnoreCase(ipAddress)) {
           ipAddress = request.getHeader("HTTP_CLIENT_IP");
       }
       if (ipAddress == null || "unknown".equalsIgnoreCase(ipAddress)) {
           ipAddress = request.getHeader("HTTP_X_FORWARDED_FOR");
       }
      
       // 2.如果没有转发的ip,则取当前通信的请求端的ip(兼容k8s集群获取ip)
       if (ipAddress == null || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
           ipAddress = request.getRemoteAddr();
           // 如果是127.0.0.1,则取本地真实ip
           if (localIp.equals(ipAddress)) {
               // 根据网卡取本机配置的IP
               InetAddress inet = null;
               try {
                   inet = InetAddress.getLocalHost();
                   ipAddress = inet.getHostAddress();
               } catch (UnknownHostException e) {
                   e.printStackTrace();
               }
           }
       }
      
       // 对于通过多个代理的情况,第一个IP为客户端真实IP,多个IP按照','分割
       if (ipAddress != null && ipAddress.length() > 15) {
           // = 15
           if (ipAddress.indexOf(",") > 0) {
               ipAddress = ipAddress.substring(0, ipAddress.indexOf(","));
           }
       }
      

      } catch (Exception e) {
      logger.error(“解析请求 IP 失败”, e);
      ipAddress = “”;
      }
      return “0:0:0:0:0:0:0:1”.equals(ipAddress) ? localIp : ipAddress;
      }

    /**

    • 获取访问设备
    • @param request
    • @return
      */
      public static UserAgent getUserAgent(HttpServletRequest request) {
      return UserAgent.parseUserAgentString(request.getHeader(“User-Agent”));
      }

    /**

    • 根据 ip 获取 城市信息
    • @param ipAddress
    • @return
      */
      public static String getCityInfo(String ipAddress) {
      String cityInfo = null;
      try {
      return searcher.search(ipAddress);
      } catch (Exception e) {
      logger.error(“搜索:{} 失败: {}”,ipAddress, e);
      }
      return null;
      }

    /**

    • 根据 ip2region 解析 ip 地址

    • @param ip ip 地址

    • @return 解析后的 ip 地址信息
      */
      public static String getIp2region(String ip) {

      if(searcher == null){
      logger.error(“Error: DbSearcher is null”);
      return null;
      }

      try {
      String ipInfo = searcher.search(ip);
      if (!StringUtils.isEmpty(ipInfo)) {
      ipInfo = ipInfo.replace(“|0”, “”);
      ipInfo = ipInfo.replace(“0|”, “”);
      }
      return ipInfo;
      } catch (Exception e) {
      e.printStackTrace();
      }
      return null;
      }

    /**

    • 获取 IP 地址

    • @return 本地 IP 地址
      */
      public static String getHostIp(){
      try{
      return InetAddress.getLocalHost().getHostAddress();
      }catch (UnknownHostException e){
      }
      return localIp;
      }

    /**

    • 获取主机名

    • @return 本地主机名
      */
      public static String getHostName(){
      try{
      return InetAddress.getLocalHost().getHostName();
      } catch (UnknownHostException e) {
      }
      return “未知”;
      }
      }

2.4. 测试类
package com.nacl;

import com.nacl.util.IpUtils;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

/**

  • @author HAOYANG
  • @create 2023-07-31 15:09
    */
    @SpringBootTest
    public class SensitiveTest {
    @Test
    void iptest(){
    String cityInfo = IpUtils.getCityInfo(“xxx.xxx.xxx.xxx”);
    System.out.println(cityInfo);
    }

}

标签: #JAVA 991
相关文章

Spring 实现 3 种异步接口 2024-10-18 09:07

大家好,我是苏三~ 如何处理比较耗时的接口? 这题我熟,直接上异步接口,使用 Callable、WebAsyncTask 和 DeferredResult、CompletableFuture等均可实现。 但这些方法有局限性,处理结果仅返回单个值。在某些场景下,如果需要接口异步处理的同时,还持续不断地

重学SpringBoot3-集成Redis(五)之布隆过滤器 2024-10-08 11:24

更多SpringBoot3内容请关注我的专栏:《SpringBoot3》 期待您的点赞👍收藏⭐评论✍ 重学SpringBoot3-集成Redis(五)之布隆过滤器 1. 什么是布隆过滤器? * 基本概念 适用场景 2. 使用 Redis 实现布隆过滤器 * 项目依赖 Redis 配置

SpringBoot整合异步任务执行 2024-10-08 11:24

同步任务: 同步任务是在单线程中按顺序执行,每次只有一个任务在执行,不会引发线程安全和数据一致性等 并发问题 同步任务需要等待任务执行完成后才能执行下一个任务,无法同时处理多个任务,响应慢,影响用 户体验 异步任务: 异步任务是在多线程中同时执行,多个任务可以并发执行,同时处理多个请求,响应快,资源

springboot kafka多数据源,通过配置动态加载发送者和消费者 2024-10-08 11:24

前言 最近做项目,需要支持kafka多数据源,实际上我们也可以通过代码固定写死多套kafka集群逻辑,但是如果需要不修改代码扩展呢,因为kafka本身不处理额外逻辑,只是起到削峰,和数据的传递,那么就需要对架构做一定的设计了。 准备test kafka本身非常容易上手,如果我们需要单元测试,引入ja

SpringBoot 集成 Redis 2024-10-08 11:24

一:SpringBoot 集成 Redis ①Redis是一个 NoSQL(not only)数据库, 常作用缓存 Cache 使用。 ②Redis是一个中间件、是一个独立的服务器;常用的数据类型: string , hash ,set ,zset , list ③通过Redis客户端可以使用多种语

SpringBoot整合QQ邮箱 2024-10-08 11:24

SpringBoot可以通过导入依赖的方式集成多种技术,这当然少不了我们常用的邮箱,现在本章演示SpringBoot整合QQ邮箱发送邮件…. 下面按步骤进行: 1.获取QQ邮箱授权码 1.1 登录QQ邮箱 1.2 开启SMTP服务 找到下图中的SMTP服务区域,如果当前账号未开启的话自己手动开启。

目录

IT 外包服务商

  • 意见投递
  • zyf6619

软件开发应用

主菜单

  • 首页
  • 软件开发
  • 计算机基础
  • Hello Halo
  • 新手必读
  • 关于本知识库
Copyright © 2024 your company All Rights Reserved. Powered by Halo.