MaxCompute中实现IPv4和IPv6地址归属地转换

publicvoidsetup(ExecutionContextctx) throwsUDFException, IOException {//IPV4if(ipV4ObjsArray==null)        {BufferedInputStreambufferedInputStream=ctx.readResourceFileAsStream("ipv4.txt");BufferedReaderbr=newBufferedReader(newInputStreamReader(bufferedInputStream));ArrayList<IpV4Obj>ipV4ObjArrayList=newArrayList<>();Stringline=null;while ((line=br.readLine()) !=null) {String[] f=line.split("\\|", -1);if(f.length>=5)                {longstartIp=IpUtils.StringToLong(f[0]);longendIp=IpUtils.StringToLong(f[1]);Stringcity=f[3];Stringprovince=f[4];IpV4ObjipV4Obj=newIpV4Obj(startIp, endIp, city, province);ipV4ObjArrayList.add(ipV4Obj);                }            }br.close();List<IpV4Obj>collect=ipV4ObjArrayList.stream().sorted(Comparator.comparing(IpV4Obj::getStartIp)).collect(Collectors.toList());ArrayList<IpV4Obj>basicIpV4DataList=(ArrayList)collect;IpV4Obj[] ipV4Objs=newIpV4Obj[basicIpV4DataList.size()];ipV4ObjsArray=basicIpV4DataList.toArray(ipV4Objs);        }//IPV6if(ipV6ObjsArray==null)        {BufferedInputStreambufferedInputStream=ctx.readResourceFileAsStream("ipv6.txt");BufferedReaderbr=newBufferedReader(newInputStreamReader(bufferedInputStream));ArrayList<IpV6Obj>ipV6ObjArrayList=newArrayList<>();Stringline=null;while ((line=br.readLine()) !=null) {String[] f=line.split("\\|", -1);if(f.length>=5)                {StringstartIp=IpUtils.StringToBigIntString(f[0]);StringendIp=IpUtils.StringToBigIntString(f[1]);Stringcity=f[3];Stringprovince=f[4];IpV6ObjipV6Obj=newIpV6Obj(startIp, endIp, city, province);ipV6ObjArrayList.add(ipV6Obj);                }            }br.close();List<IpV6Obj>collect=ipV6ObjArrayList.stream().sorted(Comparator.comparing(IpV6Obj::getStartIp)).collect(Collectors.toList());ArrayList<IpV6Obj>basicIpV6DataList=(ArrayList)collect;IpV6Obj[] ipV6Objs=newIpV6Obj[basicIpV6DataList.size()];ipV6ObjsArray=basicIpV6DataList.toArray(ipV6Objs);        }    }

publicStringevaluate(Stringip){if(ip==null||ip.trim().isEmpty()||!(ip.contains(".")||ip.contains(":")))        {returnnull;        }intipV4OrV6=0;try {ipV4OrV6=IpUtils.isIpV4OrV6(ip);        } catch (Exceptione) {returnnull;        }//如果是IPV4if(ipV4OrV6==4)        {inti=binarySearch(ipV4ObjsArray, IpUtils.StringToLong(ip));if(i>=0)            {IpV4ObjipV4Obj=ipV4ObjsArray[i];returnipV4Obj.city+","+ipV4Obj.province;            }else{returnnull;            }        }elseif(ipV4OrV6==6)//如果是IPV6        {inti=binarySearchIPV6(ipV6ObjsArray, IpUtils.StringToBigIntString(ip));if(i>=0)            {IpV6ObjipV6Obj=ipV6ObjsArray[i];returnipV6Obj.city+","+ipV6Obj.province;            }else{returnnull;            }        }else{//如果不符合IPV4或IPV6格式returnnull;        }    }

--上次资源：add file ipv4.txt-f;add file ipv6.txt-f;add jar ipv4_ipv6_aton.jar;--注册函数：--类名：com.aliyun.odps.udf.udfFunction.IpLocationcreate function function_name as'com.aliyun.odps.udf.udfFunction.IpLocation' using 'ipv4_ipv6_aton.jar, ipv4.txt, ipv6.txt';