Springboot根据IP分析出地址（使用淘宝和新浪IP库）

以你之姓@ 2022-05-31 13:23 289阅读 0赞

#### 1、添加请求地址到配置文件中 ####

把淘宝和新浪的请求地址添加到配置文件中，用，分开，并且把要分析的ip参数放到最后，这是为了方便后面的组装url

swallow.ip.analysis = http://ip.taobao.com/service/getIpInfo.php?ip=,http://int.dpool.sina.com.cn/iplookup/iplookup.php?format=js&ip=

#### 2、添加实体pojo ####

淘宝的返回信息实体：

package com.cy.example.carrier;
    
    public class IpAnalysisCa_Tb {
    
        /* * 1. 响应信息： （json格式的）国家 、省（自治区或直辖市）、市（县）、运营商 2. 返回数据格式： {"code":0,"data":{"ip":"210.75.225.254","country":"\u4e2d\u56fd","area":"\u534e\u5317", "region":"\u5317\u4eac\u5e02","city":"\u5317\u4eac\u5e02","county":"","isp":"\u7535\u4fe1", "country_id":"86","area_id":"100000","region_id":"110000","city_id":"110000", "county_id":"-1","isp_id":"100017"}} 其中code的值的含义为，0：成功，1：失败。 */
        private int code;
    
        private Data data;
    
        public int getCode() {
            return code;
        }
    
        public void setCode(int code) {
            this.code = code;
        }
    
        public Data getData() {
            return data;
        }
    
        public void setData(Data data) {
            this.data = data;
        }
    
        public class Data{
            private String ip;
    
            //国家
            private String country;
    
            private String area;
    
            private String region;
    
            private String city;
    
            private String county;
    
            private String isp;
    
            public String getIp() {
                return ip;
            }
    
            public void setIp(String ip) {
                this.ip = ip;
            }
    
            public String getCountry() {
                return country;
            }
    
            public void setCountry(String country) {
                this.country = country;
            }
    
            public String getArea() {
                return area;
            }
    
            public void setArea(String area) {
                this.area = area;
            }
    
            public String getRegion() {
                return region;
            }
    
            public void setRegion(String region) {
                this.region = region;
            }
    
            public String getCity() {
                return city;
            }
    
            public void setCity(String city) {
                this.city = city;
            }
    
            public String getCounty() {
                return county;
            }
    
            public void setCounty(String county) {
                this.county = county;
            }
    
            public String getIsp() {
                return isp;
            }
    
            public void setIsp(String isp) {
                this.isp = isp;
            }
        }
    
    }

新浪的返回信息实体：

package com.cy.example.carrier;
    
    public class IpAnalysisCa_Sina {
    
        /* * 2. 响应信息： （json格式的）国家 、省（自治区或直辖市）、市（县）、运营商 3. 返回数据格式： var remote_ip_info = {"ret":1,"start":-1,"end":-1,"country":"\u4e2d\u56fd" ,"province":"\u4e0a\u6d77","city":"\u4e0a\u6d77","district":"","isp":"","type":"","desc":""}; 其中code的值的含义为，1成功 */
        private int ret;
    
        private String country;
    
        private String province;
    
        private String city;
    
        private String isp;
    
        private String type;
    
        private String desc;
    
        public int getRet() {
            return ret;
        }
    
        public void setRet(int ret) {
            this.ret = ret;
        }
    
        public String getCountry() {
            return country;
        }
    
        public void setCountry(String country) {
            this.country = country;
        }
    
        public String getProvince() {
            return province;
        }
    
        public void setProvince(String province) {
            this.province = province;
        }
    
        public String getCity() {
            return city;
        }
    
        public void setCity(String city) {
            this.city = city;
        }
    
        public String getIsp() {
            return isp;
        }
    
        public void setIsp(String isp) {
            this.isp = isp;
        }
    
        public String getType() {
            return type;
        }
    
        public void setType(String type) {
            this.type = type;
        }
    
        public String getDesc() {
            return desc;
        }
    
        public void setDesc(String desc) {
            this.desc = desc;
        }
    }

#### 3、HTTP的工具类 ####

用于获取到ip后发起http请求，获取到请求ip的地址

package com.cy.example.util;
    
    import java.io.IOException;
    import java.util.ArrayList;
    import java.util.List;
    import java.util.Map;
    
    import org.apache.http.Consts;
    import org.apache.http.HttpEntity;
    import org.apache.http.NameValuePair;
    import org.apache.http.client.entity.UrlEncodedFormEntity;
    import org.apache.http.client.methods.CloseableHttpResponse;
    import org.apache.http.client.methods.HttpGet;
    import org.apache.http.client.methods.HttpPost;
    import org.apache.http.impl.client.CloseableHttpClient;
    import org.apache.http.impl.client.HttpClients;
    import org.apache.http.message.BasicNameValuePair;
    import org.apache.http.util.EntityUtils;
    
    public class HttpRequestUtil {
    
        private static final CloseableHttpClient httpclient = HttpClients.createDefault();
        private static final String userAgent = "Mozilla/5.0 (Windows NT 6.2; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/54.0.2840.87 Safari/537.36";
    
        public static String get(String url) {
            String result = null;
            CloseableHttpResponse response = null;
            try {
                HttpGet httpGet = new HttpGet(url);
                httpGet.setHeader("User-Agent", userAgent);
                response = httpclient.execute(httpGet);
                HttpEntity entity = response.getEntity();
                if (entity != null) {
                    result = EntityUtils.toString(entity);
                }
            } catch (Exception e) {
                e.printStackTrace();
            } finally {
                if (response != null) {
                    try {
                        response.close();
                    } catch (IOException e) {
                    }
                }
            }
            return result;
        }
    
        public static String post(String url, Map<String, String> map) {
             // 设置参数
            List<NameValuePair> formparams = new ArrayList<NameValuePair>();
            for (Map.Entry<String, String> entry : map.entrySet()) {
                formparams.add(new BasicNameValuePair(entry.getKey(), entry.getValue()));
            }
            // 编码
            UrlEncodedFormEntity formEntity = new UrlEncodedFormEntity(formparams, Consts.UTF_8);
            // 取得HttpPost对象
            HttpPost httpPost = new HttpPost(url);
            // 防止被当成攻击添加的
            httpPost.setHeader("User-Agent", userAgent);
            // 参数放入Entity
            httpPost.setEntity(formEntity);
            CloseableHttpResponse response = null;
            String result = null;
            try {
                // 执行post请求
                response = httpclient.execute(httpPost);
                // 得到entity
                HttpEntity entity = response.getEntity();
                // 得到字符串
                result = EntityUtils.toString(entity);
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (response != null) {
                    try {
                        response.close();
                    } catch (IOException e) {
                    }
                }
            }
            return result;
        }
    }

#### 4、具体的使用 ####

在我自己的使用的具体业务场景是：用户登录成功之后，会把相应的登陆记录实体发送到消息队列，在发送之前首先会把用户登录的ip解析出是哪个省份的，如果在请求淘宝ip地址库失败时，会请求在配置文件中的第二个地址，也就是新浪的ip库。

//拼装地ip地址
    String tbUrl = ipAnalysis.split(",")[0] + loginRecord.getC_loginIp();
            try {
                //获取淘宝库返回的内容
                String addr = HttpRequestUtil.get(tbUrl);
                //将返回的json数据转换成实体对象
                IpAnalysisCa_Tb ipAnalusisTb = JsonUtil.toBean(addr, IpAnalysisCa_Tb.class);
                //进行请求成功与否的判断
                if(0 == ipAnalusisTb.getCode()){
                    //判断是否是内网地址
                    if(StringUtil.IsEqual("XX", ipAnalusisTb.getData().getRegion())){
                        loginRecord.setC_province(ipAnalusisTb.getData().getCity());
                    }else{
                        loginRecord.setC_province(ipAnalusisTb.getData().getRegion());
                    }
    
                }else{
                    //这是新浪的请求地址，方法和以上相似就不一一备注了
                    String sinaUrl = ipAnalysis.split(",")[1] + loginRecord.getC_loginIp();
                    addr = HttpRequestUtil.get(sinaUrl);
                    IpAnalysisCa_Sina ipAnalusisSina = JsonUtil.toBean(addr, IpAnalysisCa_Sina.class);
                    if(1 == ipAnalusisSina.getRet()){
                        loginRecord.setC_province(ipAnalusisSina.getProvince());
                    }else{
                        loginRecord.setC_province("未知");
                    }
                }
    
            } catch (Exception e) {
                // TODO: handle exception
                logger.info("解析IP出错！");
                loginRecord.setC_province("未知");
            }
            logger.info("发送对象信息: " + loginRecord.toString());
            this.rabbitTemplate.convertAndSend(RabbitConfig.QUEUE_LOGINRECORD, loginRecord);

具体的项目链接：[https://github.com/cy576013581/swallow][https_github.com_cy576013581_swallow]喜欢点star噢

[https_github.com_cy576013581_swallow]: https://github.com/cy576013581/swallow