首页 > 代码库 > spark练习--由IP得到所在地
spark练习--由IP得到所在地
今天我们就来介绍,如何根据一个IP来求出这个IP所在的地址是什么,首先我们如果要做这个内容,那么我们要有一个IP地址的所在地字典,这个我们可以在网上购买,形如:
1.0.1.0|1.0.3.255|16777472|16778239|亚洲|中国|福建|福州||电信|350100|China|CN|119.306239|26.075302
1.0.8.0|1.0.15.255|16779264|16781311|亚洲|中国|广东|广州||电信|440100|China|CN|113.280637|23.125178
1.0.32.0|1.0.63.255|16785408|16793599|亚洲|中国|广东|广州||电信|440100|China|CN|113.280637|23.125178
1.1.0.0|1.1.0.255|16842752|16843007|亚洲|中国|福建|福州||电信|350100|China|CN|119.306239|26.075302
这个只是其中的一个小部分,我们可以来介绍一下这个如何查看,当我如果获取一个IP,那我们首先先把这个IP转换成为一个Long型的值,其中的转换方法,后文会有介绍,然后我们在看上面的数据,以第一条数据为例
1.0.1.0|1.0.3.255|16777472|16778239|亚洲|中国|福建|福州||电信|350100|China|CN|119.306239|26.075302
这个以‘|‘来作为分隔符,其中的第二三个数字分别为:16777472,16778239这两个数字,这个表示如果我们把上面的IP转换成为Long值的情况,如果这个long的大小在16777472与16778239之间,那我们就可以说,这个IP是中国福建的电信,好了,解释完成之后,我们就可以开始写代码了
package cn.wj.spark.day06 import java.io.{BufferedReader, FileInputStream, InputStreamReader} import scala.collection.mutable.ArrayBuffer /** * Created by WJ on 2017/1/4. */ object IPLocationDemo_2 { // 将IP转换成为Long值 def ip2Long(ip:String):Long ={ val fragments = ip.split("[.]") var ipNum = 0L for(i <- 0 until fragments.length){ ipNum = fragments(i).toLong | ipNum << 8L //8进制变为10进制 } ipNum } //进行二分法的查找,这个的前提是顺序已经是排序过的了 def binarySearch(lines: ArrayBuffer[String], ip: Long) : Int = { var low = 0 var high = lines.length - 1 while (low <= high) { val middle = (low + high) / 2 if ((ip >= lines(middle).split("\\|")(2).toLong) && (ip <= lines(middle).split("\\|")(3).toLong)) return middle if (ip < lines(middle).split("\\|")(2).toLong) high = middle - 1 else { low = middle + 1 } } -1 } //从一个文件里面读取数据 def readData(path:String) = { val br = new BufferedReader(new InputStreamReader(new FileInputStream(path))) var s:String = null var flag = true var lines = ArrayBuffer[String]() while(flag){ s = br.readLine() if(s != null) lines += s else flag = false } lines } def main(args: Array[String]): Unit = { val ip ="118.144.130.10" val ipNum = ip2Long(ip) println(ipNum) val lines = readData("e://Test/ip.txt") val index = binarySearch(lines,ipNum) println(lines(index)) } }
spark练习--由IP得到所在地