`
hz_chenwenbiao
  • 浏览: 1007752 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

LumaQQ与IP查询二(转)

阅读更多

下面是改进了一点点的版本:

1 IPSeeker.java

 

package com.worthtech.app.util.ip;

import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.RandomAccessFile;
import java.nio.ByteOrder;
import java.nio.MappedByteBuffer;
import java.nio.channels.FileChannel;
import java.util.ArrayList;
import java.util.Hashtable;
import java.util.List;

/**
 * <pre>
 * 用来读取QQwry.dat文件,以根据ip获得好友位置,QQwry.dat的格式是
 * 一. 文件头,共8字节
 *    1. 第一个起始IP的绝对偏移, 4字节
 *     2. 最后一个起始IP的绝对偏移, 4字节
 * 二. &quot;结束地址/国家/区域&quot;记录区
 *     四字节ip地址后跟的每一条记录分成两个部分
 *     1. 国家记录
 *     2. 地区记录
 *     但是地区记录是不一定有的。而且国家记录和地区记录都有两种形式
 *     1. 以0结束的字符串
 *     2. 4个字节,一个字节可能为0x1或0x2
 *   a. 为0x1时,表示在绝对偏移后还跟着一个区域的记录,注意是绝对偏移之后,而不是这四个字节之后
 *        b. 为0x2时,表示在绝对偏移后没有区域记录
 *        不管为0x1还是0x2,后三个字节都是实际国家名的文件内绝对偏移
 *   如果是地区记录,0x1和0x2的含义不明,但是如果出现这两个字节,也肯定是跟着3个字节偏移,如果不是
 *        则为0结尾字符串
 * 三. &quot;起始地址/结束地址偏移&quot;记录区
 *     1. 每条记录7字节,按照起始地址从小到大排列
 *        a. 起始IP地址,4字节
 *        b. 结束ip地址的绝对偏移,3字节
 * 
 * 注意,这个文件里的ip地址和所有的偏移量均采用little-endian格式,而java是采用
 * big-endian格式的,要注意转换
 * </pre>
 * 
 * @author 马若劼
 */
public class IPSeeker {
	/**
	 * <pre>
	 * 用来封装ip相关信息,目前只有两个字段,ip所在的国家和地区
	 * </pre>
	 * 
	 * @author 马若劼
	 */
	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 String IP_FILE = IPSeeker.class.getResource(
			"qqwry.dat").toString().substring(5);

	// 一些固定常量,比如记录长度等等
	private static final int IP_RECORD_LENGTH = 7;
	private static final byte AREA_FOLLOWED = 0x01;
	private static final byte NO_AREA = 0x2;

	// 用来做为cache,查询一个ip时首先查看cache,以减少不必要的重复查找
	private final Hashtable ipCache;
	// 随机文件访问类
	private RandomAccessFile ipFile;
	// 内存映射文件
	private MappedByteBuffer mbb;
	// 单一模式实例
	private static IPSeeker instance = new IPSeeker();
	// 起始地区的开始和结束的绝对偏移
	private long ipBegin, ipEnd;
	// 为提高效率而采用的临时变量
	private final IPLocation loc;
//	private final byte[] buf;//不需要了
	private final byte[] b4;
	private final byte[] b3;

	/**
	 * 私有构造函数
	 */
	private IPSeeker() {
		ipCache = new Hashtable();
		loc = new IPLocation();
//		buf = new byte[100];//不需要了,这里初始化不好!
		b4 = new byte[4];
		b3 = new byte[3];
		try {
			ipFile = new RandomAccessFile(IP_FILE, "r");
		} catch (FileNotFoundException e) {
			System.out.println(IPSeeker.class.getResource("QQWry.dat").toString());
			System.out.println(IP_FILE);
			System.out.println("IP地址信息文件没有找到,IP显示功能将无法使用");
			ipFile = null;

		}
		// 如果打开文件成功,读取文件头信息
		if (ipFile != null) {
			try {
				ipBegin = readLong4(0);
				ipEnd = readLong4(4);
				if (ipBegin == -1 || ipEnd == -1) {
					ipFile.close();
					ipFile = null;
				}
			} catch (IOException e) {
				System.out.println("IP地址信息文件格式有错误,IP显示功能将无法使用");
				ipFile = null;
			}
		}
	}

	/**
	 * @return 单一实例
	 */
	public static IPSeeker getInstance() {
		return instance;
	}

	/**
	 * 给定一个地点的不完全名字,得到一系列包含s子串的IP范围记录
	 * 
	 * @param s
	 *            地点子串
	 * @return 包含IPEntry类型的List
	 */
	public List getIPEntriesDebug(String s) {
		List ret = new ArrayList();
		long endOffset = ipEnd + 4;
		for (long offset = ipBegin + 4; offset <= endOffset; offset += IP_RECORD_LENGTH) {
			// 读取结束IP偏移
			long temp = readLong3(offset);
			// 如果temp不等于-1,读取IP的地点信息
			if (temp != -1) {
				IPLocation loc = getIPLocation(temp);
				// 判断是否这个地点里面包含了s子串,如果包含了,添加这个记录到List中,如果没有,继续
				if (loc.country.indexOf(s) != -1 || loc.area.indexOf(s) != -1) {
					IPEntry entry = new IPEntry();
					entry.country = loc.country;
					entry.area = loc.area;
					// 得到起始IP
					readIP(offset - 4, b4);
					entry.beginIp = Util.getIpStringFromBytes(b4);
					// 得到结束IP
					readIP(temp, b4);
					entry.endIp = Util.getIpStringFromBytes(b4);
					// 添加该记录
					ret.add(entry);
				}
			}
		}
		return ret;
	}

	/**
	 * 给定一个地点的不完全名字,得到一系列包含s子串的IP范围记录
	 * 
	 * @param s
	 *            地点子串
	 * @return 包含IPEntry类型的List
	 */
	public List getIPEntries(String s) {
		List ret = new ArrayList();
		try {
			// 映射IP信息文件到内存中
			if (mbb == null) {
				FileChannel fc = ipFile.getChannel();
				mbb = fc.map(FileChannel.MapMode.READ_ONLY, 0, ipFile.length());
				mbb.order(ByteOrder.LITTLE_ENDIAN);
			}

			int endOffset = (int) ipEnd;
			for (int offset = (int) ipBegin + 4; offset <= endOffset; offset += IP_RECORD_LENGTH) {
				int temp = readInt3(offset);
				if (temp != -1) {
					IPLocation loc = getIPLocation(temp);
					// 判断是否这个地点里面包含了s子串,如果包含了,添加这个记录到List中,如果没有,继续
					if (loc.country.indexOf(s) != -1
							|| loc.area.indexOf(s) != -1) {
						IPEntry entry = new IPEntry();
						entry.country = loc.country;
						entry.area = loc.area;
						// 得到起始IP
						readIP(offset - 4, b4);
						entry.beginIp = Util.getIpStringFromBytes(b4);
						// 得到结束IP
						readIP(temp, b4);
						entry.endIp = Util.getIpStringFromBytes(b4);
						// 添加该记录
						ret.add(entry);
					}
				}
			}
		} catch (IOException e) {
			System.out.println(e.getMessage());
		}
		return ret;
	}

	/**
	 * 从内存映射文件的offset位置开始的3个字节读取一个int
	 * 
	 * @param offset
	 * @return
	 */
	private int readInt3(int offset) {
		mbb.position(offset);
		return mbb.getInt() & 0x00FFFFFF;
	}

	/**
	 * 从内存映射文件的当前位置开始的3个字节读取一个int
	 * 
	 * @return
	 */
	private int readInt3() {
		return mbb.getInt() & 0x00FFFFFF;
	}

	/**
	 * 根据IP得到国家名
	 * 
	 * @param ip
	 *            ip的字节数组形式
	 * @return 国家名字符串
	 */
	public String getCountry(byte[] ip) {
		// 检查ip地址文件是否正常
		if (ipFile == null)
			return "错误的IP数据库文件";
		// 保存ip,转换ip字节数组为字符串形式
		String ipStr = Util.getIpStringFromBytes(ip);
		// 先检查cache中是否已经包含有这个ip的结果,没有再搜索文件
		if (ipCache.containsKey(ipStr)) {
			IPLocation loc = (IPLocation) ipCache.get(ipStr);
			return loc.country;
		} else {
			IPLocation loc = getIPLocation(ip);
			ipCache.put(ipStr, loc.getCopy());
			return loc.country;
		}
	}

	/**
	 * 根据IP得到国家名
	 * 
	 * @param ip
	 *            IP的字符串形式
	 * @return 国家名字符串
	 */
	public String getCountry(String ip) {
		return getCountry(Util.getIpByteArrayFromString(ip));
	}

	/**
	 * 根据IP得到地区名
	 * 
	 * @param ip
	 *            ip的字节数组形式
	 * @return 地区名字符串
	 */
	public String getArea(byte[] ip) {
		// 检查ip地址文件是否正常
		if (ipFile == null)
			return "错误的IP数据库文件";
		// 保存ip,转换ip字节数组为字符串形式
		String ipStr = Util.getIpStringFromBytes(ip);
		// 先检查cache中是否已经包含有这个ip的结果,没有再搜索文件
		if (ipCache.containsKey(ipStr)) {
			IPLocation loc = (IPLocation) ipCache.get(ipStr);
			return loc.area;
		} else {
			IPLocation loc = getIPLocation(ip);
			ipCache.put(ipStr, loc.getCopy());
			return loc.area;
		}
	}

	/**
	 * 根据IP得到地区名
	 * 
	 * @param ip
	 *            IP的字符串形式
	 * @return 地区名字符串
	 */
	public String getArea(String ip) {
		return getArea(Util.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 = "未知国家";
			info.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
	 */
	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) {
			System.out.println(e.getMessage());
		}
	}

	/**
	 * 从offset位置读取四个字节的ip地址放入ip数组中,读取后的ip为big-endian格式,但是
	 * 文件中是little-endian形式,将会进行转换
	 * 
	 * @param offset
	 * @param ip
	 */
	private void readIP(int offset, byte[] ip) {
		mbb.position(offset);
		mbb.get(ip);
		byte temp = ip[0];
		ip[0] = ip[3];
		ip[3] = temp;
		temp = ip[1];
		ip[1] = ip[2];
		ip[2] = temp;
	}

	/**
	 * 把类成员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 b2
	 * @return 若b1大于b2则返回1,相等返回0,小于返回-1
	 */
	private int compareByte(byte b1, byte b2) {
		if ((b1 & 0xFF) > (b2 & 0xFF)) // 比较是否大于
			return 1;
		else if ((b1 ^ b2) == 0)// 判断是否相等
			return 0;
		else
			return -1;
	}

	/**
	 * 这个方法将根据ip的内容,定位到包含这个ip国家地区的记录处,返回一个绝对偏移 方法使用二分法查找。
	 * 
	 * @param ip
	 *            要查询的IP
	 * @return 如果找到了,返回结束IP的偏移,如果没有找到,返回-1
	 */
	private long locateIP(byte[] ip) {
		long m = 0;
		int r;
		// 比较第一个ip项
		readIP(ipBegin, b4);
		r = compareIP(ip, b4);
		if (r == 0)
			return ipBegin;
		else if (r < 0)
			return -1;
		// 开始二分搜索
		for (long i = ipBegin, j = ipEnd; i < j;) {
			m = getMiddleOffset(i, j);
			readIP(m, b4);
			r = compareIP(ip, b4);
			// log.debug(Utils.getIpStringFromBytes(b));
			if (r > 0)
				i = m;
			else if (r < 0) {
				if (m == j) {
					j -= IP_RECORD_LENGTH;
					m = j;
				} else
					j = m;
			} else
				return readLong3(m + 4);
		}
		// 如果循环结束了,那么i和j必定是相等的,这个记录为最可能的记录,但是并非
		// 肯定就是,还要检查一下,如果是,就返回结束地址区的绝对偏移
		m = readLong3(m + 4);
		readIP(m, b4);
		r = compareIP(ip, b4);
		if (r <= 0)
			return m;
		else
			return -1;
	}

	/**
	 * 得到begin偏移和end偏移中间位置记录的偏移
	 * 
	 * @param begin
	 * @param end
	 * @return
	 */
	private long getMiddleOffset(long begin, long end) {
		long records = (end - begin) / IP_RECORD_LENGTH;
		records >>= 1;
		if (records == 0)
			records = 1;
		return begin + records * IP_RECORD_LENGTH;
	}

	/**
	 * 给定一个ip国家地区记录的偏移,返回一个IPLocation结构
	 * 
	 * @param offset
	 * @return
	 */
	private IPLocation getIPLocation(long offset) {
		try {
			// 跳过4字节ip
			ipFile.seek(offset + 4);
			// 读取第一个字节判断是否标志字节
			byte b = ipFile.readByte();
			if (b == AREA_FOLLOWED) {
				// 读取国家偏移
				long countryOffset = readLong3();
				// 跳转至偏移处
				ipFile.seek(countryOffset);
				// 再检查一次标志字节,因为这个时候这个地方仍然可能是个重定向
				b = ipFile.readByte();
				if (b == NO_AREA) {
					loc.country = readString(readLong3());
					ipFile.seek(countryOffset + 4);
				} else
					loc.country = readString(countryOffset);
				// 读取地区标志
				loc.area = readArea(ipFile.getFilePointer());
			} else if (b == NO_AREA) {
				loc.country = readString(readLong3());
				loc.area = readArea(offset + 8);
			} else {
				loc.country = readString(ipFile.getFilePointer() - 1);
				loc.area = readArea(ipFile.getFilePointer());
			}
			return loc;
		} catch (IOException e) {
			return null;
		}
	}

	/**
	 * @param offset
	 * @return
	 */
	private IPLocation getIPLocation(int offset) {
		// 跳过4字节ip
		mbb.position(offset + 4);
		// 读取第一个字节判断是否标志字节
		byte b = mbb.get();
		if (b == AREA_FOLLOWED) {
			// 读取国家偏移
			int countryOffset = readInt3();
			// 跳转至偏移处
			mbb.position(countryOffset);
			// 再检查一次标志字节,因为这个时候这个地方仍然可能是个重定向
			b = mbb.get();
			if (b == NO_AREA) {
				loc.country = readString(readInt3());
				mbb.position(countryOffset + 4);
			} else
				loc.country = readString(countryOffset);
			// 读取地区标志
			loc.area = readArea(mbb.position());
		} else if (b == NO_AREA) {
			loc.country = readString(readInt3());
			loc.area = readArea(offset + 8);
		} else {
			loc.country = readString(mbb.position() - 1);
			loc.area = readArea(mbb.position());
		}
		return loc;
	}

	/**
	 * 从offset偏移开始解析后面的字节,读出一个地区名
	 * 
	 * @param offset
	 * @return 地区名字符串
	 * @throws IOException
	 */
	private String readArea(long offset) throws IOException {
		ipFile.seek(offset);
		byte b = ipFile.readByte();
		if (b == 0x01 || b == 0x02) {
			long areaOffset = readLong3(offset + 1);
			if (areaOffset == 0)
				return "未知地区";
			else
				return readString(areaOffset);
		} else
			return readString(offset);
	}

	/**
	 * @param offset
	 * @return
	 */
	private String readArea(int offset) {
		mbb.position(offset);
		byte b = mbb.get();
		if (b == 0x01 || b == 0x02) {
			int areaOffset = readInt3();
			if (areaOffset == 0)
				return "未知地区";
			else
				return readString(areaOffset);
		} else
			return readString(offset);
	}

	/**
	 * 从offset偏移处读取一个以0结束的字符串
	 * 
	 * @param offset
	 * @return 读取的字符串,出错返回空字符串
	 */
	private String readString(long offset) {
		try {
			ipFile.seek(offset);
			//int i;
			//for (i = 0, buf[i] = ipFile.readByte(); buf[i] != 0; buf[++i] = ipFile.readByte());
			//上面的写法读取数据如果超过100个字节就会报数组越界异常
			int i = 0;
			byte[] buf = new byte[256];
			while ((buf[i] = ipFile.readByte()) != 0) {
			    ++ i;
			    if (i >= buf.length) {
			        byte[] tmp = new byte[i + 100];
			        System.arraycopy(buf, 0, tmp, 0, i);
			        buf = tmp;
			    }
			}
			/////////
			if (i != 0)
				return Util.getString(buf, 0, i, "GBK");
		} catch (IOException e) {
			System.out.println(e.getMessage());
		}
		return "";
	}

	/**
	 * 从内存映射文件的offset位置得到一个0结尾字符串
	 * 
	 * @param offset
	 * @return
	 */
	private String readString(int offset) {
		try {
			mbb.position(offset);
			//int i;
			//for (i = 0, buf[i] = mbb.get(); buf[i] != 0; buf[++i] = mbb.get());
			int i = 0;
			byte[] buf = new byte[256];
			while ((buf[i] = mbb.get()) != 0) {
			    ++ i;
			    if (i >= buf.length) {
			        byte[] tmp = new byte[i + 100];
			        System.arraycopy(buf, 0, tmp, 0, i);
			        buf = tmp;
			    }
			}
			if (i != 0)
				return Util.getString(buf, 0, i, "GBK");
		} catch (IllegalArgumentException e) {
			System.out.println(e.getMessage());
		}
		return "";
	}

	public String getAddress(String ip) {
		String country = getCountry(ip).equals(" CZ88.NET") ? ""
				: getCountry(ip);
		String area = getArea(ip).equals(" CZ88.NET") ? "" : getArea(ip);
		String address = country + " " + area;
		return address.trim();		
	}
	
	
	
	public static void main(String[] args) {
        IPSeeker ipseeker = IPSeeker.getInstance();   
        String sip[] = { "60.177.69.138", "124.91.62.239", "124.91.62.239",   
                "59.40.87.8", "221.222.73.88", "60.51.114.120",   
                "222.212.223.146", "60.51.114.120", "60.51.114.120",   
                "60.51.114.120", "60.51.114.120", "211.99.23.121",   
                "58.45.85.107", "58.45.85.107", "121.32.94.204",   
                "117.22.46.178", "218.19.2.195", "58.218.23.10",   
                "58.218.23.10", "202.173.10.2", "60.178.167.241",   
                "58.213.137.5", "58.38.165.221", "58.38.165.221",   
                "61.150.15.25", "58.45.82.76", "218.8.200.210", "59.33.24.233",   
                "60.176.240.196", "60.9.86.85", "60.51.114.120",   
                "60.51.114.120", "125.120.155.45", "219.140.61.180",   
                "219.140.61.180", "59.49.158.100", "59.49.158.100",   
                "58.218.23.10", "221.220.25.54", "222.71.176.119",   
                "220.168.115.124", "58.38.165.221", "218.3.251.246",   
                "58.213.137.5", "218.3.251.246", "121.33.219.235",   
                "222.130.195.225", "60.51.114.120", "218.3.251.246",   
                "219.140.61.180", "219.140.61.180", "125.120.155.45",   
                "60.9.97.186", "124.228.44.177", "218.19.2.195",   
                "222.70.225.180", "58.38.165.221", "58.38.165.221",   
                "60.168.67.99", "58.38.165.221", "58.38.165.221",   
                "61.29.214.76", "220.234.156.254", "60.51.114.120",   
                "60.51.114.120", "60.51.114.120", "222.168.148.111",   
                "117.24.28.13", "59.49.158.100", "60.209.253.61",   
                "61.150.15.83", "60.208.156.110", "124.227.192.131",   
                "125.120.155.90", "218.83.58.250", "60.191.89.102",   
                "222.71.176.119", "60.178.167.241", "60.208.111.203",   
                "222.74.231.66", "58.221.253.118", "122.89.146.55",   
                "60.51.114.120", "58.221.253.118", "59.49.158.100",   
                "218.10.158.162", "220.160.38.98", "124.227.192.131",   
                "219.245.44.214", "211.158.41.214", "219.245.44.185",   
                "218.0.113.43", "211.158.41.214", "218.68.82.73",   
                "125.120.144.14", "125.120.155.90", "60.171.169.251",   
                "124.78.165.8", "124.78.165.8", "218.22.186.125",
                "202.98.224.68","218.21.40.190","218.202.208.0",
                "58.18.118.0","218.21.68.175"};
        for (int i = 0; i < sip.length; i++) {
        	//较详细的信息:
//          System.out.println(ipseeker.getAddress(sip[i]));
        	//只打印国家省份信息:
        	System.out.println(ipseeker.getCountry(sip[i]));
        }   
   
    }   
}

 

 2 IPEntry.java

/*
* 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.worthtech.app.util.ip;


/**
 * <pre>
 * 一条IP范围记录,不仅包括国家和区域,也包括起始IP和结束IP
 * </pre>
 * 
 * @author luma
 */
public class IPEntry {
    public String beginIp;
    public String endIp;
    public String country;
    public String area;
    
    /**
     * 构造函数
     */
    public IPEntry() {
        beginIp = endIp = country = area = "";
    }
}

 

3 Util.java

package com.worthtech.app.util.ip;


import java.io.UnsupportedEncodingException;
import java.util.StringTokenizer;

import org.apache.log4j.Level;

import  com.showtime.util.LogFactory;



/**
 * 工具类,提供一些方便的方法
 */
public class Util {
	
	private static StringBuilder sb = new StringBuilder();
	/**
     * 从ip的字符串形式得到字节数组形式
     * @param ip 字符串形式的ip
     * @return 字节数组形式的ip
     */
    public static byte[] getIpByteArrayFromString(String ip) {
        byte[] ret = new byte[4];
        StringTokenizer st = new StringTokenizer(ip, ".");
        try {
            ret[0] = (byte)(Integer.parseInt(st.nextToken()) & 0xFF);
            ret[1] = (byte)(Integer.parseInt(st.nextToken()) & 0xFF);
            ret[2] = (byte)(Integer.parseInt(st.nextToken()) & 0xFF);
            ret[3] = (byte)(Integer.parseInt(st.nextToken()) & 0xFF);
        } catch (Exception e) {
          LogFactory.log("从ip的字符串形式得到字节数组形式报错", Level.ERROR, e);
        }
        return ret;
    }
    /**
     * @param ip ip的字节数组形式
     * @return 字符串形式的ip
     */
    public static String getIpStringFromBytes(byte[] ip) {
	    sb.delete(0, sb.length());
    	sb.append(ip[0] & 0xFF);
    	sb.append('.');   	
    	sb.append(ip[1] & 0xFF);
    	sb.append('.');   	
    	sb.append(ip[2] & 0xFF);
    	sb.append('.');   	
    	sb.append(ip[3] & 0xFF);
    	return sb.toString();
    }
    
    /**
     * 根据某种编码方式将字节数组转换成字符串
     * @param b 字节数组
     * @param offset 要转换的起始位置
     * @param len 要转换的长度
     * @param encoding 编码方式
     * @return 如果encoding不支持,返回一个缺省编码的字符串
     */
    public static String getString(byte[] b, int offset, int len, String encoding) {
        try {
            return new String(b, offset, len, encoding);
        } catch (UnsupportedEncodingException e) {
            return new String(b, offset, len);
        }
    }
}

 

网上还有许多人在改进它,可以参照:

http://code.google.com/p/lumaqq4j/source/browse/trunk/lumaqq/src/edu/tsinghua/lumaqq/IPSeeker.java?r=4

 

http://kenai.com/projects/ipseeker/sources/subversion/show/IPSeeker

 

等,可以在google上输入ipseeker.java搜索它们来,改进上也没改进多少,可能就是一些小的地方。

分享到:
评论

相关推荐

    LumaQQ及IP查询一(转)

    标题 "LumaQQ及IP查询一(转)" 暗示了这个压缩包可能包含一个与QQ相关的IP查询工具或库,LumaQQ可能是一个定制或修改过的QQ客户端,而IP查询功能则可能是用于获取QQ用户所在地理位置的一种服务。在这个上下文中,...

    纯真IP地址查询(Java版源代码)

    开发者可能需要了解Java基础,IO流操作(用于读取QQWry.dat文件),可能还有正则表达式(处理IP地址格式),以及基本的数据结构和算法(如二分查找法,提高查询效率)。 总的来说,这个项目提供了一种使用Java实现...

    lumaQQ_jar包

    本文将围绕“lumaQQ_jar包”展开,探讨其中蕴含的技术细节与历史价值。 首先,我们需要理解“jar”文件是什么。Java Archive (JAR) 文件是Java平台上的一个特殊文件格式,它用于聚合多个Java类文件和其他资源,便于...

    LumaQQ.NET原代码

    1. **网络通信**:LumaQQ.NET 使用.NET Framework的网络编程接口,如Socket类,来实现TCP/IP通信。TCP确保了数据的可靠传输,而Socket则提供了低级别的网络连接控制。开发者可以从中学习到如何建立和管理网络连接,...

    lumaqq for android demo

    LumaQQ的核心在于实现即时通讯功能,这通常涉及到TCP/IP协议、Socket编程和消息序列化等技术。开发者需要理解腾讯的通讯协议,以便正确地建立和维护与服务器的连接,以及发送和接收数据。在Android环境下,考虑到...

    LumaQQ SRC+LIB.zip

    《LumaQQ源码与库解析》 LumaQQ,作为一个知名的即时通讯软件,其背后蕴含着丰富的技术知识。这份名为"LumaQQ SRC+LIB.zip"的压缩包,显然是包含了LumaQQ的源代码(SRC)和相关库(LIB)。对于任何对软件开发,尤其...

    LumaQQ.Net(VS2005).rar

    LumaQQ.Net的源码揭示了如何使用TCP/IP协议进行数据传输,以及如何实现心跳机制、断线重连等功能。 4. **XML序列化与反序列化**:在即时通讯中,消息通常以XML格式进行编码和解码。源码可能包含如何使用.NET ...

    lumaqq代码

    它使用了TCP/IP协议进行数据传输,这是所有网络应用程序的基础。在源码中,我们可以看到如何构建Socket连接,发送和接收数据包,以及如何处理网络异常。此外,对于QQ特有的消息协议,如TCP心跳包、数据加密解密等,...

    LumaQQ.NET

    1. **网络通信**:LumaQQ.NET需要实现用户间的实时消息传递,这涉及到网络编程,可能使用TCP/IP协议进行数据传输。为了实现可靠的消息传递,项目可能采用了长连接或者WebSocket技术。 2. **多线程处理**:为了确保...

    LumaQQ.rar_LumaQQ

    通过运行这些示例,开发者能够快速了解LumaQQ的工作原理,并基于此进行二次开发。 2. **开发库源码**:这部分包含了LumaQQ的核心功能模块,如网络通信模块、QQ协议解析模块、用户界面模块等。源码是用面向对象的...

    LumaQQ.rar_LumaQQ_LumaQQ-Android_PortGateFacto

    【LumaQQ.rar_LumaQQ_LumaQQ-Android_PortGateFacto】是一个关于LumaQQ的源代码压缩包,LumaQQ是一款针对Android平台开发的即时通讯应用。这个压缩包包含了一些关键文件,如`www.pudn.com.txt`可能是发布者在某个...

    lumaqq for android 源代码

    LumaQQ作为一个开源项目,允许开发者深入研究其内部机制,理解如何与腾讯的QQ服务器进行交互,以及如何在Android平台上实现即时通讯功能。 【描述】"重构过的源代码,现在可以看到分组和群,还不支持发送消息。"这...

    lumaqq.rar_LumaQQ_即时通_即时通讯_开源 java

    - **网络通信协议**:LumaQQ可能采用了如TCP/IP或UDP协议进行底层通信,以确保数据的可靠传输或高效传输。 - **消息队列**:为了处理用户之间的消息交换,LumaQQ可能使用了消息队列技术,如ActiveMQ或RabbitMQ,...

    Java读取纯真IP数据库定位IP地址(eclipse中直接使用)_项目源码

    4. **二分查找**:由于IP数据库通常按IP地址排序,为了提高查询效率,`IPSeeker`可能采用了二分查找算法。这是一种在有序数组中查找特定元素的搜索算法,时间复杂度为O(log n)。 5. **异常处理**:在读取文件和处理...

    lumaQQ

    在2006年的技术背景下,这可能包括TCP/IP协议的使用,以及数据包的封装和解析,以实现与腾讯QQ服务器的通信。 2. **lumaqq_tools_2006**:这可能是项目提供的工具集,包含了辅助开发或调试的工具。这些工具可能包括...

    java读取纯真ip数据库

    这通常涉及到IP地址的转换(如将IP地址转换为整型数值)以及二分查找或哈希映射等数据结构的高效查询。 标签“java”确认了我们的讨论重点是关于Java编程的技术细节。在处理这样的任务时,还需要考虑错误处理(如...

    IPSeeker.jar 用于ip查询

    IPSeeker\bin\com\lumaqq\IPEntry.class IPSeeker\bin\com\lumaqq\IPSeeker$IPLocation.class IPSeeker\bin\com\lumaqq\IPSeeker.class IPSeeker\bin\com\lumaqq\test\Test.class IPSeeker\bin\com\lumaqq\test ...

    LumaQQ 研究文档(收藏)

    《LumaQQ研究文档》是一份集合了对LumaQQ深度探索和技术解析的珍贵资料,适合对QQ客户端软件开发及QQ协议感兴趣的读者。LumaQQ是一个开源的QQ客户端项目,它允许开发者深入研究QQ的底层机制,并进行自定义扩展。 在...

    纯真IP数据库查询源代码

    用于查询纯真IP数据库(http://www.cz88.net) 的程序。从LumaQQ的Java程序段翻译过来。现在从地址反查到IP的速度还比较慢,又进一步优化的必要。原程序内含原Java代码供参考。用的是VS2005。VS2003无法打开项目,可以...

    LumaQQ.NET.rar

    LumaQQ利用System.Net命名空间中的Socket类实现了TCP/IP通信,这是即时通讯软件的基础。同时,利用System.IO命名空间处理文件读写,可能包括存储用户数据、聊天记录等。 其次,.NET的多线程机制在LumaQQ中发挥了...

Global site tag (gtag.js) - Google Analytics