import java.io.*;
import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
import com.yoshino.util.datxip.*;
public class IpAreaRange {
private String ipRangeFileName;
private SizeBalancedTree ipRangeTree_S;
private SizeBalancedTree ipRangeTree_T;
private Map map;
private Map countOfRegion;
private City city;
public IpAreaRange() {
//this.ipRangeFileName = "" ;
//this.ipRangeTree_S = new SizeBalancedTree();
//this.ipRangeTree_T = new SizeBalancedTree();
//map = new HashMap();
//map = Collections.synchronizedMap(new HashMap());
try{
this.map = new ConcurrentHashMap();
ValueComparator bvc = new ValueComparator(map);
//countOfRegion = new TreeMap(bvc);
this.countOfRegion = Collections.synchronizedMap(new TreeMap(bvc));
this.city = new City(FilePath.ipFile);
}
catch (Exception ioex){
ioex.printStackTrace();
}
}
public IpAreaRange(String fileName) {
this.ipRangeFileName = fileName;
this.ipRangeTree_S = new SizeBalancedTree();
this.ipRangeTree_T = new SizeBalancedTree();
this.build();
}
/**
* 建立IP段SBT
*
*/
public void build() {
try {
File file = new File(ipRangeFileName);
BufferedInputStream fis = new BufferedInputStream(new FileInputStream(file));
BufferedReader reader = new BufferedReader(new InputStreamReader(fis, "utf-8"), 5 * 1024 * 1024);
String line = "";
int value = 0;
String area = "";
while ((line = reader.readLine()) != null) {
if (line.charAt(1) >= '0' && line.charAt(1) <= '9') {
String[] tempIpRange = line.split(" ");
String tempIp_S = tempIpRange[0];
String tempIp_T = tempIpRange[1];
NodeOfIp nodeIP_S = new NodeOfIp(IpV4Util.ipToInt(tempIp_S),area);
NodeOfIp nodeIP_T = new NodeOfIp(IpV4Util.ipToInt(tempIp_T),area);
ipRangeTree_S.insert(nodeIP_S);
ipRangeTree_T.insert(nodeIP_T);
}
else {
area = line;
}
}
}
catch (IOException e) {
System.out.println(e);
}
}
/**
* ä¼ å…¥IP地å€ï¼Œæœç´¢IPæ•°æ®åº“的结果，返回çœä»½ä¿¡æ¯
*
* @param checkIp String
* @return ans
*/
public String search(String checkIp) {
String region = "null";
try {
region = Arrays.toString(this.city.find(checkIp));
insertRegion(region);
}
catch (Exception e) {
System.out.println("Err " + e + " " + checkIp);
}
return region;
}
public void insertRegion(String region) {
if (map.containsKey(region)) {
Integer times = map.get(region);
map.put(region, times+1);
}
else {
map.put(region, 1);
}
}
public Map getRegionCount() {
countOfRegion.putAll(map);
return this.countOfRegion;
}
}