diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..4cec319
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,38 @@
+
+
+ 4.0.0
+
+ com.ggstar
+ ipdatabase
+ 1.0-SNAPSHOT
+
+
+
+
+ junit
+ junit
+ 4.11
+
+
+
+ org.apache.poi
+ poi-ooxml
+ 3.14
+
+
+
+ log4j
+ log4j
+ 1.2.17
+
+
+
+ org.apache.poi
+ poi
+ 3.14
+
+
+
+
\ No newline at end of file
diff --git a/src/main/java/com/ggstar/util/file/FileUtil.java b/src/main/java/com/ggstar/util/file/FileUtil.java
new file mode 100644
index 0000000..fc579c1
--- /dev/null
+++ b/src/main/java/com/ggstar/util/file/FileUtil.java
@@ -0,0 +1,62 @@
+package com.ggstar.util.file;
+
+import java.io.BufferedInputStream;
+import java.io.BufferedReader;
+import java.io.FileInputStream;
+import java.io.InputStreamReader;
+
+/**
+ * Created by lee on 2015/7/29.
+ */
+public class FileUtil {
+
+ private static final String UTF_8 = "UTF-8";
+
+ private static final String Unicode = "Unicode";
+
+ private static final String UTF_16BE = "UTF-16BE";
+
+ private static final String ANSI_ASCII = "ANSI|ASCII";
+
+ private static final String GBK = "GBK";
+
+
+
+ /**
+ * 自动根据文件编码格式读取文件
+ *
+ * @param filePath
+ * @return
+ * @throws Exception
+ */
+ public static BufferedReader readFile(String filePath) throws Exception {
+ return new BufferedReader(new InputStreamReader(new FileInputStream(filePath), codeString(filePath)));
+ }
+
+ public static String codeString(String fileName) throws Exception {
+ BufferedInputStream bin = new BufferedInputStream(
+ new FileInputStream(fileName));
+ int p = (bin.read() << 8) + bin.read();
+ String code;
+ //其中的 0xefbb、0xfffe、0xfeff、0x5c75这些都是这个文件的前面两个字节的16进制数
+ switch (p) {
+ case 0xefbb:
+ code = UTF_8;
+ break;
+ case 0xfffe:
+ code = Unicode;
+ break;
+ case 0xfeff:
+ code = UTF_16BE;
+ break;
+ case 0x5c75:
+ code = ANSI_ASCII;
+ break;
+ default:
+ code = GBK;
+ }
+
+ return code;
+ }
+
+}
diff --git a/src/main/java/com/ggstar/util/file/PoiUtil.java b/src/main/java/com/ggstar/util/file/PoiUtil.java
new file mode 100644
index 0000000..cf44870
--- /dev/null
+++ b/src/main/java/com/ggstar/util/file/PoiUtil.java
@@ -0,0 +1,26 @@
+package com.ggstar.util.file;
+
+import org.apache.poi.openxml4j.exceptions.InvalidFormatException;
+import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.poi.ss.usermodel.WorkbookFactory;
+
+import java.io.FileInputStream;
+import java.io.IOException;
+
+/**
+ * Created by lee on 2015/8/11.
+ */
+public class PoiUtil {
+
+ public static Workbook getWorkbook(String filePath){
+ try {
+ return WorkbookFactory.create(new FileInputStream(filePath));
+ } catch (IOException e) {
+ e.printStackTrace();
+ } catch (InvalidFormatException e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+}
diff --git a/src/main/java/com/ggstar/util/ip/IpHelper.java b/src/main/java/com/ggstar/util/ip/IpHelper.java
new file mode 100644
index 0000000..5c3ea63
--- /dev/null
+++ b/src/main/java/com/ggstar/util/ip/IpHelper.java
@@ -0,0 +1,118 @@
+package com.ggstar.util.ip;
+
+import com.ggstar.util.file.FileUtil;
+import com.ggstar.util.file.PoiUtil;
+import org.apache.poi.ss.usermodel.Row;
+import org.apache.poi.ss.usermodel.Sheet;
+import org.apache.poi.ss.usermodel.Workbook;
+
+import java.io.BufferedReader;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Created by lee on 2015/8/11.
+ */
+public class IpHelper {
+
+ private static IpTree ipTree = IpTree.getInstance();
+
+ private static final String ipFile = "ipDatabase.csv";
+
+ private static final String regionFile = "ipRegion.xlsx";
+
+ static{
+ buildTrain();
+ }
+
+ private static void buildTrain() {
+ List ipRelationList;
+ try {
+ ipRelationList = IpHelper.getIpRelation();
+ int count = 0;
+ for (IpRelation ipRelation : ipRelationList) {
+ System.out.println(ipRelation.getIpStart() + "," + ipRelation.getIpEnd() + "," + ipRelation.getProvince());
+ ipTree.train(ipRelation.getIpStart(), ipRelation.getIpEnd(), ipRelation.getProvince());
+ if(count > 10){
+ break;
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+
+ }
+
+ public static String findRegionByIp(String ip){
+ return ipTree.findIp(ip);
+ }
+
+ public static List getIpRelation() throws Exception {
+
+ //
+ Map regionRelationMap = getRegionRelationMap();
+ String file = IpHelper.class.getClassLoader().getResource(ipFile).getFile();
+ BufferedReader ipRelationReader = FileUtil.readFile(file);
+
+ String line;
+ List list = new ArrayList();
+ while((line = ipRelationReader.readLine()) != null){
+ String[] split = line.split(",");
+ String ipStart = split[0];
+ String ipEnd = split[1];
+ Integer ipCode = Integer.valueOf(split[2]);
+
+ String province = regionRelationMap.get(ipCode);
+ IpRelation ipRelation = new IpRelation();
+ ipRelation.setIpStart(ipStart);
+ ipRelation.setIpEnd(ipEnd);
+ ipRelation.setProvince(province);
+ list.add(ipRelation);
+ }
+ return list;
+
+ }
+
+ /**
+ * @return Map
+ * @throws Exception
+ */
+ public static Map getRegionRelationMap() throws Exception {
+// BufferedReader ipRelationReader = FileUtil.readFile(regionFile);
+ String file = IpHelper.class.getClassLoader().getResource(regionFile).getFile();
+
+ System.out.println(file);
+
+
+ Workbook workbook = PoiUtil.getWorkbook(file);
+
+ Sheet sheet = workbook.getSheetAt(0);
+ Map map = new HashMap();
+ int rowLen = sheet.getPhysicalNumberOfRows();
+ for (int i = 1; i < rowLen; i++) {
+ Row row = sheet.getRow(i);
+ String province = row.getCell(0).getStringCellValue();
+ Double a = row.getCell(2).getNumericCellValue();
+ Integer ipCode = a.intValue();
+ map.put(ipCode, province);
+ }
+
+// String line;
+// Map map = new HashMap<>();
+// ipRelationReader.readLine();
+// while((line = ipRelationReader.readLine()) != null){
+// String[] split = line.split("\t");
+// String province = split[0];
+// Integer ipCode = Integer.valueOf(split[2]);
+// map.put(ipCode, province);
+// }
+ return map;
+ }
+
+
+
+
+
+}
diff --git a/src/main/java/com/ggstar/util/ip/IpRelation.java b/src/main/java/com/ggstar/util/ip/IpRelation.java
new file mode 100644
index 0000000..1eb1016
--- /dev/null
+++ b/src/main/java/com/ggstar/util/ip/IpRelation.java
@@ -0,0 +1,57 @@
+package com.ggstar.util.ip;
+
+/**
+ * Created by lee on 2015/8/11.
+ */
+public class IpRelation {
+
+ private String ipStart;
+
+ private String ipEnd;
+
+ private int ipCode;
+
+ private String province;
+
+ private String city;
+
+ public String getCity() {
+ return city;
+ }
+
+ public void setCity(String city) {
+ this.city = city;
+ }
+
+ public int getIpCode() {
+ return ipCode;
+ }
+
+ public void setIpCode(int ipCode) {
+ this.ipCode = ipCode;
+ }
+
+ public String getIpEnd() {
+ return ipEnd;
+ }
+
+ public void setIpEnd(String ipEnd) {
+ this.ipEnd = ipEnd;
+ }
+
+ public String getIpStart() {
+ return ipStart;
+ }
+
+ public void setIpStart(String ipStart) {
+ this.ipStart = ipStart;
+ }
+
+ public String getProvince() {
+ return province;
+ }
+
+ public void setProvince(String province) {
+ this.province = province;
+ }
+}
diff --git a/src/main/java/com/ggstar/util/ip/IpTree.java b/src/main/java/com/ggstar/util/ip/IpTree.java
new file mode 100644
index 0000000..4a76194
--- /dev/null
+++ b/src/main/java/com/ggstar/util/ip/IpTree.java
@@ -0,0 +1,233 @@
+package com.ggstar.util.ip;
+
+/**
+ * Created by lee on 2015/8/11.
+ */
+public class IpTree {
+
+ private static IpTree instance = null;
+ private IpNode rootNode = new IpNode();
+
+ private final String NO_ADDRESS = "未知";
+
+ private IpTree() {
+
+ }
+
+ public static IpTree getInstance() {
+ if (instance == null) {
+ instance = new IpTree();
+ }
+ return instance;
+ }
+
+ public void train(String ipStart, String ipEnd, String addressCode) {
+
+ int ip_s = ipToInt(ipStart);
+ int ip_e = ipToInt(ipEnd);
+
+ if (ip_e == -1 || ip_s == -1)
+ return;
+
+ IpNode curNode = rootNode;
+ IpNode leftNode = null;
+ IpNode rightNode = null;
+ boolean flag = false;
+
+ for (int i = 0; i < 32; i++) {
+
+ int ip_s_bit = (0x80000000 & ip_s) >>> 31;
+ int ip_e_bit = (0x80000000 & ip_e) >>> 31;
+
+ if(flag == false) {
+
+ if ((ip_s_bit ^ ip_e_bit) == 0) {
+
+ if (ip_s_bit == 1) {
+ if (curNode.rightNode == null) {
+ curNode.rightNode = new IpNode();
+ }
+ curNode = curNode.rightNode;
+ }
+ else {
+ if (curNode.leftNode == null) {
+ curNode.leftNode = new IpNode();
+ }
+ curNode = curNode.leftNode;
+ }
+ if(i == 31) {
+ curNode.addressCode = addressCode;
+ }
+
+ }
+ else {
+ flag = true;
+ if(curNode.leftNode == null) {
+ curNode.leftNode = new IpNode();
+ }
+ leftNode = curNode.leftNode;
+
+ if(curNode.rightNode == null) {
+ curNode.rightNode = new IpNode();
+ }
+
+ rightNode = curNode.rightNode;
+
+ if(i == 31){
+ leftNode.addressCode = addressCode;
+ rightNode.addressCode = addressCode;
+ }
+ }
+ }else{
+ if (ip_s_bit == 1) {
+ if (leftNode.rightNode == null) {
+ leftNode.rightNode = new IpNode();
+ }
+ leftNode = leftNode.rightNode;
+ }
+ else {
+ if (leftNode.leftNode == null) {
+ leftNode.leftNode = new IpNode();
+ }
+ if (leftNode.rightNode == null) {
+ leftNode.rightNode = new IpNode();
+ }
+ leftNode.rightNode.addressCode = addressCode;
+ leftNode = leftNode.leftNode;
+ }
+ if(i == 31)
+ leftNode.addressCode = addressCode;
+
+ if (ip_e_bit == 1) {
+ if (rightNode.rightNode == null) {
+ rightNode.rightNode = new IpNode();
+ }
+ if(rightNode.leftNode == null){
+ rightNode.leftNode = new IpNode();
+ }
+ rightNode.leftNode.addressCode = addressCode;
+ rightNode = rightNode.rightNode;
+ }
+ else {
+ if (rightNode.leftNode == null) {
+ rightNode.leftNode = new IpNode();
+ }
+ rightNode = rightNode.leftNode;
+ }
+ if(i == 31)
+ rightNode.addressCode = addressCode;
+ }
+
+ ip_s = ip_s << 1;
+ ip_e = ip_e << 1;
+ }
+ }
+
+ public String findIp(String ip) {
+
+ IpNode curNode = rootNode;
+
+ int ip_int = ipToInt(ip);
+
+ if (ip_int == -1)
+ return NO_ADDRESS;
+
+ for (int i = 0; i < 32; i++) {
+
+ int ip_s_bit = (0x80000000 & ip_int) >>> 31;
+
+ if (ip_s_bit == 0)
+ curNode = curNode.leftNode;
+ else
+ curNode = curNode.rightNode;
+
+ if (curNode == null) {
+ return NO_ADDRESS;
+ }
+
+ if (curNode.addressCode != null && !curNode.addressCode.trim().equals(""))
+ return curNode.addressCode;
+
+ ip_int = ip_int << 1;
+ }
+
+ return NO_ADDRESS;
+ }
+
+ private int ipToInt(String strIP) {
+ try {
+
+ int[] ip = new int[4];
+
+ int position1 = strIP.indexOf(".");
+ int position2 = strIP.indexOf(".", position1 + 1);
+ int position3 = strIP.indexOf(".", position2 + 1);
+
+ ip[0] = Integer.parseInt(strIP.substring(0, position1));
+ ip[1] = Integer.parseInt(strIP.substring(position1 + 1, position2));
+ ip[2] = Integer.parseInt(strIP.substring(position2 + 1, position3));
+ ip[3] = Integer.parseInt(strIP.substring(position3 + 1));
+ int ip_int = (ip[0] << 24) + (ip[1] << 16) + (ip[2] << 8) + ip[3];
+
+ return ip_int;
+
+ } catch (Exception e) {
+ return -1;
+ }
+ }
+
+ private class IpNode {
+ private IpNode leftNode;
+
+ private IpNode rightNode;
+
+ private String addressCode;
+
+ }
+
+ private void loopTree(IpNode ipNode, int depth){
+ System.out.println(depth + "\t" + ipNode.addressCode);
+ if(ipNode.leftNode != null) {
+ System.out.println("left");
+ loopTree(ipNode.leftNode, depth + 1);
+ }
+ if(ipNode.rightNode != null) {
+ System.out.println("right");
+ loopTree(ipNode.rightNode, depth + 1);
+ }
+ }
+
+ public void loopTree(){
+ loopTree(rootNode, 0);
+ }
+
+
+
+ class node{
+
+ }
+
+ public static void main(String[] args) {
+ IpTree ipTree = new IpTree();
+ //ipTree.train("0.0.0.0", "0.0.0.0", "1000000000");
+ ipTree.train("0.0.0.0", "0.255.255.255", "1000000000");
+ ipTree.train("1.0.0.0", "1.0.0.255", "1036000000");
+ ipTree.train("1.0.1.0", "1.0.3.255", "1156350100");
+ ipTree.train("1.0.4.0", "1.0.7.255", "1036000000");
+ ipTree.train("1.0.8.0", "1.0.15.255", "1156440000");
+ ipTree.train("1.0.16.0", "1.0.31.255", "1392000000");
+
+ //ipTree.loopTree();
+
+
+ System.out.println(ipTree.findIp("1.0.1.254"));
+
+ System.out.println((2 >> 1)&1);
+
+
+ //HashSet s = new HashSet