package com.javaweb.third.tencent;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.javaweb.common.core.domain.AjaxResult;
|
import com.javaweb.common.utils.StringUtils;
|
import com.javaweb.third.config.ThirdConfig;
|
|
|
import java.io.BufferedReader;
|
import java.io.InputStreamReader;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
*腾讯ip位置查询服务
|
*/
|
public class TencentIpUtil {
|
|
private static final String MY_IP_KEY= ThirdConfig.getTencentIpKey();
|
private static String URL_IP="https://apis.map.qq.com/ws/location/v1/ip?ip=IP&key=KEY";
|
public static AjaxResult queryIpLocation(String ip){
|
String address="";
|
String url=URL_IP.replace("IP",ip).replace("KEY",MY_IP_KEY);
|
String data= sendRequest(url, RequestType.GET);
|
JSONObject jsonObject= JSONObject.parseObject(data);
|
String status=String.valueOf(jsonObject.get("status"));
|
String msg=String.valueOf(jsonObject.get("message"));
|
if("0".equals(status)){
|
//查询成功
|
JSONObject ad_infoObj=jsonObject.getJSONObject("result").getJSONObject("ad_info");
|
String nation=String.valueOf(ad_infoObj.get("nation"));//国家
|
String province=String.valueOf(ad_infoObj.get("province"));//省
|
String city=String.valueOf(ad_infoObj.get("city"));//市
|
String district=String.valueOf(ad_infoObj.get("district"));//区
|
if("中国".equals(nation)){
|
address+= (StringUtils.isNotEmpty(province)?province.replace("省",""):"")+(StringUtils.isNotEmpty(city)?"-"+city.replaceAll("市",""):"")+(StringUtils.isNotEmpty(district)?"-"+district:"");
|
}else{
|
address+= (StringUtils.isNotEmpty(nation)?nation:"")+(StringUtils.isNotEmpty(province)?"-"+province:"")+(StringUtils.isNotEmpty(city)?"-"+city:"")+(StringUtils.isNotEmpty(district)?"-"+district:"");
|
}
|
return AjaxResult.success("查询成功!",address);
|
}else{
|
//失败的情况
|
return AjaxResult.error("查询失败!",msg);
|
}
|
|
}
|
public static void main(String[] args){
|
//String res= queryIpLocation("112.232.19.111");
|
// System.out.println(res);
|
}
|
public enum RequestType{
|
POST,
|
GET
|
}
|
private static String sendRequest(String requestUrl,RequestType type){
|
try {
|
URL url = new URL(requestUrl);
|
// 打开和URL之间的连接
|
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
|
connection.setRequestMethod(type.name());
|
// 设置通用的请求属性
|
connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
|
connection.setRequestProperty("Connection", "Keep-Alive");
|
connection.setUseCaches(false);
|
connection.setDoOutput(true);
|
connection.setDoInput(true);
|
|
// 得到请求的输出流对象
|
//DataOutputStream out = new DataOutputStream(connection.getOutputStream());
|
//out.writeBytes(params);
|
//out.flush();
|
//out.close();
|
|
// 建立实际的连接
|
connection.connect();
|
// 获取所有响应头字段
|
Map<String, List<String>> headers = connection.getHeaderFields();
|
// 遍历所有的响应头字段
|
// for (String key : headers.keySet()) {
|
//System.out.println(key + "--->" + headers.get(key));
|
//}
|
// 定义 BufferedReader输入流来读取URL的响应
|
BufferedReader in = null;
|
|
in = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
|
|
String result = "";
|
String getLine;
|
while ((getLine = in.readLine()) != null) {
|
result += getLine;
|
}
|
in.close();
|
// System.out.println("result:" + result);
|
return result;
|
}catch (Exception ex){
|
ex.printStackTrace();
|
return "";
|
}
|
}
|
}
|
