JAVA使用Ip2region获取IP定位信息的操作方法

https://gitee测试数据/lionsoul/ip2region.git

< dependency >

     < groupId >org.lionsoul</ groupId >

     < artifactId >ip2region</ artifactId >

     < version >1.7.2</ version >

</ dependency >

https://gitee测试数据/lionsoul/ip2region/blob/master/data/ip2region.db

import lombok.Data;

/**

  * 域名信息.

  *

  * @author https://HdhCmsTestcnblogs测试数据/lixingwu

  * @date 2022-05-24 15:07:47

  */

@Data

public class IpInfo {

     /*** 国家 */

     private String country;

     /*** 地区 */

     private String region;

     /*** 省 */

     private String province;

     /*** 市 */

     private String city;

     /*** 运营商 */

     private String isp;

}

import cn.hutool.core.collection.CollUtil;

import cn.hutool.core.io.IoUtil;

import cn.hutool.core.io.StreamProgress;

import cn.hutool.core.lang.Dict;

import cn.hutool.core.net.NetUtil;

import cn.hutool.core.util.NumberUtil;

import cn.hutool.core.util.StrUtil;

import cn.hutool.http.HttpUtil;

import com.yunding.vote.domain.IpInfo;

import lombok.extern.slf4j.Slf4j;

import org.lionsoul.ip2region.DataBlock;

import org.lionsoul.ip2region.DbConfig;

import org.lionsoul.ip2region.DbMakerConfigException;

import org.lionsoul.ip2region.DbSearcher;

import javax.servlet.http.HttpServletRequest;

import java.io.ByteArrayOutputStream;

import java.io.IOException;

import java.util.HashSet;

import java.util.Optional;

/**

  * 使用单例模式（双重校验锁DCL）

  *

  * @author https://HdhCmsTestcnblogs测试数据/lixingwu

  * @date 2022-05-24 10:45:42

  */

@Slf4j

public class Ip2regionAnalysis {

     private volatile static Ip2regionAnalysis analysis;

     /**

      * TODO 这个数据库地址，改成自己的，不要用这地址啊，这个需要登录才能下载

      * ip数据库地址

      */

     public static final String IP_REGION_DB_URL = "https://gitee测试数据/lionsoul/ip2region/raw/master/data/ip2region.db" ;

     /**

      * ip数据库字节

      */

     private final byte [] dbBinStr;

     /**

      * 初始化，下载ip数据库文件转为为文件输出流

      */

     private Ip2regionAnalysis() {

         // 下载IP数据库文件

         ByteArrayOutputStream outputStream = new ByteArrayOutputStream();

         HttpUtil.download(IP_REGION_DB_URL, outputStream, false , new StreamProgress() {

             @Override

             public void start() {

                 log.info( "下载IP数据库文件..." );

             }

             @Override

             public void progress( long progressSize) {

             }

             @Override

             public void finish() {

                 double fileSize = NumberUtil.div(outputStream.size(), ( 1024 * 1024 ), 2 );

                 log.info( "IP数据库文件下载成功，数据库文件大小[{}MB]" , fileSize);

             }

         });

         dbBinStr = outputStream.toByteArray();

         IoUtil.close(outputStream);

     }

     /**

      * 获取IP解析单例

      *

      * @return Ip2regionAnalysis

      */

     public static Ip2regionAnalysis getInstance() {

         if (analysis == null ) {

             synchronized (Ip2regionAnalysis. class ) {

                 if (analysis == null ) {

                     analysis = new Ip2regionAnalysis();

                 }

             }

         }

         return analysis;

     }

     /**

      * <p>方法名称：解析Ip信息.</p>

      * <p>详细描述：.</p>

      * <p>创建时间：2022-05-24 11:26:59</p>

      * <p>创建作者：lixingwu</p>

      * <p>修改记录：</p>

      *

      * @param ip IP地址

      * @return 国家|区域|省份|城市|ISP

      */

     public Optional<String> getIpInfo(String ip) {

         if (IpAddressUtil.validIp(ip)) {

             try {

                 DbConfig config = new DbConfig();

                 DbSearcher searcher = new DbSearcher(config, dbBinStr);

                 // 搜索数据

                 DataBlock search = searcher.memorySearch(ip);

                 // 数据格式：国家|区域|省份|城市|ISP

                 return Optional.of(search.getRegion());

             } catch (DbMakerConfigException | IOException e) {

                 e.printStackTrace();

                 log.error( "Ip解析失败：{}" , e.toString());

             }

         }

         return Optional.empty();

     }

     /**

      * <p>方法名称：解析Ip信息.</p>

      * <p>详细描述：.</p>

      * <p>创建时间：2022-05-24 11:26:59</p>

      * <p>创建作者：lixingwu</p>

      * <p>修改记录：</p>

      *

      * @param ips IP地址集合

      * @return Dict({ ip : info })

      */

     public Dict getIpInfo(HashSet<String> ips) {

         try {

             DbConfig config = new DbConfig();

             DbSearcher searcher = new DbSearcher(config, dbBinStr);

             DataBlock search;

             Dict dataset = Dict.create();

             for (String ip : ips) {

                 if (IpAddressUtil.validIp(ip)) {

                     search = searcher.memorySearch(ip);

                     dataset.set(ip, search.getRegion());

                 }

             }

             return dataset;

         } catch (DbMakerConfigException | IOException e) {

             e.printStackTrace();

             log.error( "Ip解析失败：{}" , e.toString());

         }

         return Dict.create();

     }

     /**

      * <p>方法名称：数字ip获取信息.</p>

      * <p>详细描述：.</p>

      * <p>创建时间：2022-05-24 13:15:23</p>

      * <p>创建作者：lixingwu</p>

      * <p>修改记录：</p>

      *

      * @param ip 数字IP

      * @return 国家|区域|省份|城市|ISP

      */

     public Optional<String> getIpInfo( long ip) {

         String longIpv4 = NetUtil.longToIpv4(ip);

         return getIpInfo(longIpv4);

     }

     /**

      * <p>方法名称：获取请求对象的IP信息.</p>

      * <p>详细描述：.</p>

      * <p>创建时间：2022-05-24 11:50:59</p>

      * <p>创建作者：lixingwu</p>

      * <p>修改记录：</p>

      *

      * @param request 请求对象

      * @return 国家|区域|省份|城市|ISP

      */

     public Optional<String> getIpInfo(HttpServletRequest request) {

         String ip = IpAddressUtil.getIpAddr(request);

         return getIpInfo(ip);

     }

     /**

      * <p>方法名称：获取IP信息的字典.</p>

      * <p>详细描述：.</p>

      * <p>创建时间：2022-05-24 11:52:58</p>

      * <p>创建作者：lixingwu</p>

      * <p>修改记录：</p>

      *

      * @param ip IP地址

      * @return the dict

      */

     public IpInfo getIpInfoBean(String ip) {

         Optional<String> ipInfo = getIpInfo(ip);

         IpInfo info = new IpInfo();

         if (ipInfo.isPresent()) {

             //国家|区域|省份|城市|ISP

             String[] split = StrUtil.split(ipInfo.get(), "|" );

             info.setCountry(split[ 0 ]);

             info.setRegion(split[ 1 ]);

             info.setProvince(split[ 2 ]);

             info.setCity(split[ 3 ]);

             info.setIsp(split[ 4 ]);

         }

         return info;

     }

     /**

      * <p>方法名称：数字ip获取信息字典.</p>

      * <p>详细描述：.</p>

      * <p>创建时间：2022-05-24 13:15:23</p>

      * <p>创建作者：lixingwu</p>

      * <p>修改记录：</p>

      *

      * @param ip 数字IP

      * @return 国家|区域|省份|城市|ISP

      */

     public IpInfo getIpInfoBean( long ip) {

         String longIpv4 = NetUtil.longToIpv4(ip);

         return getIpInfoBean(longIpv4);

     }

     /**

      * <p>方法名称：获取IP信息的字典.</p>

      * <p>详细描述：.</p>

      * <p>创建时间：2022-05-24 11:52:58</p>

      * <p>创建作者：lixingwu</p>

      * <p>修改记录：</p>

      *

      * @param request 请求对象

      * @return the dict

      */

     public IpInfo getIpInfoBean(HttpServletRequest request) {

         String ip = IpAddressUtil.getIpAddr(request);

         return getIpInfoBean(ip);

     }

     /**

      * 测试

      */

     public static void main(String[] args) {

         log.info( "121.8.215.106 \t {}" , Ip2regionAnalysis.getInstance().getIpInfoBean( "121.8.215.106" ));

         log.info( "183.247.152.98 \t {}" , Ip2regionAnalysis.getInstance().getIpInfoBean( "183.247.152.98" ));

         log.info( "14.29.139.251 \t {}" , Ip2regionAnalysis.getInstance().getIpInfoBean( "14.29.139.251" ));

         log.info( "183.247.152.98 \t {}" , Ip2regionAnalysis.getInstance().getIpInfoBean( "183.247.152.98" ));

         log.info( "27.105.130.93 \t {}" , Ip2regionAnalysis.getInstance().getIpInfoBean( "27.105.130.93" ));

         log.info( "124.205.155.147 \t {}" , Ip2regionAnalysis.getInstance().getIpInfoBean( "124.205.155.147" ));

         // 批量解析，返回字典数据：ip:解析信息

         final HashSet<String> ipSet = CollUtil.newHashSet(

                 "47.92.113.71" , "221.226.75.86" , "124.205.155.155" ,

                 "47.57.188.208" , "121.8.215.106" , "121.8.215.106"

         );

         Dict dict = Ip2regionAnalysis.getInstance().getIpInfo(ipSet);

         log.info( "{}" , dict.toString());

         log.info( "{}\t{}" , "121.8.215.106" , dict.getStr( "121.8.215.106" ));

     }

}

import cn.hutool.extra.servlet.ServletUtil;

import com.yunding.vote测试数据mon.api.CommonResult;

import com.yunding.vote测试数据mon.limiter.RInterfaceLimit;

import com.yunding.vote.domain.IpInfo;

import com.yunding.vote.util.Ip2regionAnalysis;

import io.swagger.annotations.Api;

import io.swagger.annotations.ApiOperation;

import lombok.extern.slf4j.Slf4j;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;

/**

  * 公共控制层，该类方法不会记录日志

  */

@RestController

@Api (tags = "公共控制层" , description = "公共控制层" )

@RequestMapping ( "/common" )

@Slf4j

public class CommonController {

     @Resource

     private HttpServletRequest request;

     @ApiOperation ( "获取IP的信息，100QPS" )

     @GetMapping (value = "/ipInfo/{ip}" )

     @RInterfaceLimit (rate = 100 )

     public CommonResult<IpInfo> getIpInfo( @PathVariable String ip) {

         String clientIp = ServletUtil.getClientIP(request);

         IpInfo ipInfo = Ip2regionAnalysis.getInstance().getIpInfoBean(ip);

         return CommonResult.success(ipInfo);

     }

}

GET http: //127.0.0.1:8080/api/v1/common/ipInfo/121.8.215.106

>>>

{

   "code" : 200 ,

   "data" : {

     "country" : "中国" ,

     "region" : 0 ,

     "province" : "广东省" ,

     "city" : "广州市" ,

     "isp" : "电信"

   },

   "message" : "操作成功"

}