引入依赖
<dependency>
<groupId>org.lionsoul</groupId>
<artifactId>ip2region</artifactId>
<version>1.7.2</version>
</dependency>
<!-- 引入fastjson -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>2.0.7</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
<version>3.12.0</version>
</dependency>
创建IpUtils 工具类
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang3.StringUtils;
import org.lionsoul.ip2region.DataBlock;
import org.lionsoul.ip2region.DbConfig;
import org.lionsoul.ip2region.DbMakerConfigException;
import org.lionsoul.ip2region.DbSearcher;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import javax.servlet.http.HttpServletRequest;
import java.io.BufferedReader;
import java.io.FileNotFoundException;
import java.io.InputStreamReader;
import java.lang.reflect.Method;
import java.net.InetAddress;
import java.net.URL;
import java.net.URLConnection;
import java.net.UnknownHostException;
import java.util.Map;
import java.util.Objects;
public class IpUtils {
public static final String UNKNOWN = "未知";
private static final Logger logger = LoggerFactory.getLogger(IpUtils.class);
private static final String dbPath;
private static DbSearcher searcher;
private static DbConfig config;
//key 腾讯位置上申请的key 并 将服务器的IP加入白名单
private final static String format_url = "https://apis.map.qq.com/ws/location/v1/ip?ip={}&key=xxxx-xxxx-xxxx-xxxx-xxxx";
private final static String localIp = "127.0.0.1";
static {
dbPath = Objects.requireNonNull(IpUtils.class.getResource("/ip2region.db")).getPath();
try {
config = new DbConfig();
} catch (DbMakerConfigException e) {
e.printStackTrace();
}
try {
searcher = new DbSearcher(config, dbPath);
} catch (FileNotFoundException e) {
e.printStackTrace();
}
}
/**
* 获取ip地址
*
* @param request
* @return
*/
public static String getIp(HttpServletRequest request) {
String ipAddress;
try {
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 || ipAddress.length() == 0 || "unknown".equalsIgnoreCase(ipAddress)) {
ipAddress = request.getRemoteAddr();
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) {
ipAddress = "";
}
return "0:0:0:0:0:0:0:1".equals(ipAddress) ? localIp : ipAddress;
}
/**
* 解析ip地址
*
* @param ip ip地址
* @return 解析后的ip地址
*/
public static String getCityInfo(String ip) {
//解析ip地址，获取省市区
String s = analyzeIp(ip);
Map map = JSONObject.parseObject(s, Map.class);
System.out.println(map);
Integer status = (Integer) map.get("status");
String address = UNKNOWN;
if (status == 375) {
String mess = (String) map.get("message");
System.out.println(mess);
address = mess;
}
if (status == 0) {
Map result = (Map) map.get("result");
System.out.println(result);
Map addressInfo = (Map) result.get("ad_info");
String nation = (String) addressInfo.get("nation");
String province = (String) addressInfo.get("province");
String city = (String) addressInfo.get("city");
address = nation + "-" + province + "-" + city;
}
return address;
}
/**
* 根据ip2region解析ip地址
*
* @param ip ip地址
* @return 解析后的ip地址
*/
public static String getIp2region(String ip) {
if (StringUtils.isEmpty(dbPath)) {
logger.error("Error: Invalid ip2region.db file");
return null;
}
if (config == null || searcher == null) {
logger.error("Error: DbSearcher or DbConfig is null");
return null;
}
try {
//define the method
Method method = null;
//B-tree, B树搜索（更快）
method = searcher.getClass().getMethod("btreeSearch", String.class);
DataBlock dataBlock;
dataBlock = (DataBlock) method.invoke(searcher, ip);
String ipInfo = dataBlock.getRegion();
if (!StringUtils.isEmpty(ipInfo)) {
ipInfo = ipInfo.replace("|0", "");
ipInfo = ipInfo.replace("0|", "");
}
return ipInfo;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
/**
* 根据在腾讯位置服务上申请的key进行请求解析ip
*
* @param ip ip地址
* @return
*/
public static String analyzeIp(String ip) {
StringBuilder result = new StringBuilder();
BufferedReader in = null;
try {
String url = format_url.replace("{}", ip);
URL realUrl = new URL(url);
// 打开和URL之间的链接
URLConnection connection = realUrl.openConnection();
// 设置通用的请求属性
connection.setRequestProperty("accept", "*/*");
connection.setRequestProperty("connection", "Keep-Alive");
connection.setRequestProperty("user-agent",
"Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
// 创建实际的链接
connection.connect();
// 定义 BufferedReader输入流来读取URL的响应
in = new BufferedReader(new InputStreamReader(
connection.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result.append(line);
}
} catch (Exception e) {
logger.error("发送GET请求出现异常！异常信息为:{}", e.getMessage());
}
// 使用finally块来关闭输入流
finally {
try {
if (in != null) {
in.close();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
return result.toString();
}
}
调用
@SpringBootApplication
public class OwlAdminApplication{
public static void main(String[] args) {
SpringApplication.run(OwlAdminApplication.class, args);
HttpServletRequest request = null;
String ip = IpUtils.getIp(request);
String ipaddress = IpUtils.getCityInfo(ip);
System.out.println(ipaddress);
}
}
效果展示
