社区管理系统

/* * LumaQQ - Java QQ Client * * Copyright (C) 2004 luma <stubma@163.com> * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */ package com.briup.run.common.util.ip; import java.io.FileNotFoundException; import java.io.IOException; import java.io.RandomAccessFile; import java.util.HashMap; import java.util.Map; /** * <pre> * 关于IP数据库文件格式，请参考LumaQQ主页文档“纯真IP数据库格式详解”一文。 * </pre> * * @author luma */ public class IPSeeker { /** * <pre> * 用来封装ip相关信息，目前只有两个字段，ip所在的国家和地区 * </pre> * * @author luma */ private class IPLocation { public String country; public String area; public IPLocation() { country = area = ""; } public IPLocation getCopy() { IPLocation ret = new IPLocation(); ret.country = country; ret.area = area; return ret; } } // 一些固定常量，比如记录长度等等 private static final int IP_RECORD_LENGTH = 7; private static final byte REDIRECT_MODE_1 = 0x01; private static final byte REDIRECT_MODE_2 = 0x02; // 用来做为cache，查询一个ip时首先查看cache，以减少不必要的重复查找 private Map<String, IPLocation> ipCache; // 随机文件访问类 private RandomAccessFile ipFile; // 单一模式实例 private static IPSeeker instance = new IPSeeker(); // 起始地区的开始和结束的绝对偏移 private long ipBegin, ipEnd; // 为提高效率而采用的临时变量 private IPLocation loc; private byte[] buf; private byte[] b4; private byte[] b3; /** * 私有构造函数 */ private IPSeeker() { ipCache = new HashMap<String, IPLocation>(); loc = new IPLocation(); buf = new byte[100]; b4 = new byte[4]; b3 = new byte[3]; try { ipFile = new RandomAccessFile(Utils.IP_FILE, "r"); } catch (FileNotFoundException e) { e.printStackTrace(); } // 如果打开文件成功，读取文件头信息 if(ipFile != null) { try { ipBegin = readLong4(0); ipEnd = readLong4(4); if(ipBegin == -1 || ipEnd == -1) { ipFile.close(); ipFile = null; } } catch (IOException e) { //IP地址信息文件格式有错误，IP显示功能将无法使用 e.printStackTrace(); ipFile = null; } } } /** * @return 单一实例 */ public static IPSeeker getInstance() { return instance; } /** * 根据IP得到国家名 * @param ip ip的字节数组形式 * @return 国家名字符串 */ public String getCountry(byte[] ip) { // 检查ip地址文件是否正常 if(ipFile == null) return "getCountry(byte[] ip) error!"; // 保存ip，转换ip字节数组为字符串形式 String ipStr = Utils.getIpStringFromBytes(ip); // 先检查cache中是否已经包含有这个ip的结果，没有再搜索文件 if(ipCache.containsKey(ipStr)) { IPLocation ipLoc = ipCache.get(ipStr); return ipLoc.country; } else { IPLocation ipLoc = getIPLocation(ip); ipCache.put(ipStr, ipLoc.getCopy()); return ipLoc.country; } } /** * 根据IP得到国家名 * @param ip IP的字符串形式 * @return 国家名字符串 */ public String getCountry(String ip) { return getCountry(Utils.getIpByteArrayFromString(ip)); } /** * 根据IP得到地区名 * @param ip ip的字节数组形式 * @return 地区名字符串 */ public String getArea(byte[] ip) { // 检查ip地址文件是否正常 if(ipFile == null) return "getArea(byte[] ip) error!"; // 保存ip，转换ip字节数组为字符串形式 String ipStr = Utils.getIpStringFromBytes(ip); // 先检查cache中是否已经包含有这个ip的结果，没有再搜索文件 if(ipCache.containsKey(ipStr)) { IPLocation ipLoc = ipCache.get(ipStr); return ipLoc.area; } else { IPLocation ipLoc = getIPLocation(ip); ipCache.put(ipStr, ipLoc.getCopy()); return ipLoc.area; } } /** * 根据IP得到地区名 * @param ip IP的字符串形式 * @return 地区名字符串 */ public String getArea(String ip) { return getArea(Utils.getIpByteArrayFromString(ip)); } /** * 根据ip搜索ip信息文件，得到IPLocation结构，所搜索的ip参数从类成员ip中得到 * @param ip 要查询的IP * @return IPLocation结构 */ private IPLocation getIPLocation(byte[] ip) { IPLocation info = null; long offset = locateIP(ip); if(offset != -1) info = getIPLocation(offset); if(info == null) { info = new IPLocation(); info.country = "unknown country"; info.area = "unknown area"; } return info; } /** * 从offset位置读取4个字节为一个long，因为java为big-endian格式，所以没办法 * 用了这么一个函数来做转换 * @param offset * @return 读取的long值，返回-1表示读取文件失败 */ private long readLong4(long offset) { long ret = 0; try { ipFile.seek(offset); ret |= (ipFile.readByte() & 0xFF); ret |= ((ipFile.readByte() << 8) & 0xFF00); ret |= ((ipFile.readByte() << 16) & 0xFF0000); ret |= ((ipFile.readByte() << 24) & 0xFF000000); return ret; } catch (IOException e) { return -1; } } /** * 从offset位置读取3个字节为一个long，因为java为big-endian格式，所以没办法 * 用了这么一个函数来做转换 * @param offset 整数的起始偏移 * @return 读取的long值，返回-1表示读取文件失败 */ private long readLong3(long offset) { long ret = 0; try { ipFile.seek(offset); ipFile.readFully(b3); ret |= (b3[0] & 0xFF); ret |= ((b3[1] << 8) & 0xFF00); ret |= ((b3[2] << 16) & 0xFF0000); return ret; } catch (IOException e) { return -1; } } /** * 从当前位置读取3个字节转换成long * @return 读取的long值，返回-1表示读取文件失败 */ private long readLong3() { long ret = 0; try { ipFile.readFully(b3); ret |= (b3[0] & 0xFF); ret |= ((b3[1] << 8) & 0xFF00); ret |= ((b3[2] << 16) & 0xFF0000); return ret; } catch (IOException e) { return -1; } } /** * 从offset位置读取四个字节的ip地址放入ip数组中，读取后的ip为big-endian格式，但是 * 文件中是little-endian形式，将会进行转换 * @param offset * @param ip */ private void readIP(long offset, byte[] ip) { try { ipFile.seek(offset); ipFile.readFully(ip); byte temp = ip[0]; ip[0] = ip[3]; ip[3] = temp; temp = ip[1]; ip[1] = ip[2]; ip[2] = temp; } catch (IOException e) { e.printStackTrace(); } } /** * 把类成员ip和beginIp比较，注意这个beginIp是big-endian的 * @param ip 要查询的IP * @param beginIp 和被查询IP相比较的IP * @return 相等返回0，ip大于beginIp则返回1，小于返回-1。 */ private int compareIP(byte[] ip, byte[] beginIp) { for(int i = 0; i < 4; i++) { int r = compareByte(ip[i], beginIp[i]); if(r != 0) return r; } return 0; } /** * 把两个byte当作无符号数进行比较 * @param b1 * @param