在tapestry中取Servlet的ServletContext

Filed under: JAVA | No Comments »
Posted on

@InjectObject(”service:tapestry.globals.ServletContext”)
 public abstract ServletContext getServletContext();

Java学习:一个压缩文件的例子

Filed under: JAVA | No Comments »
Posted on

Java学习:一个压缩文件的例子
* 关于ZIP压缩文件的问题,在该类中主要演示在ZIP压缩中可以不把文件路径压缩进去
  *
  * @author O.D.T
  * @version 1.0 04/08/27
  */
  public class ZipFile
  {
  public static void main(String[] args)
  {
  ArrayList fileNames = new ArrayList(); // 存放文件名,并非含有路径的名字
  ArrayList files = new ArrayList(); // 存放文件对象
  
  try
  {
  FileOutputStream fileOut = new FileOutputStream(”E:/ZipOutOfPath.zip”);
  ZipOutputStream outputStream = new ZipOutputStream(fileOut);
  
  File rootFile = new File(”E:/temp”);
  listFile(rootFile, fileNames, files);     

 

  for (int loop=0; loop<files.size(); loop++)
  {
  FileInputStream fileIn = new FileInputStream((File)files.get(loop));
  outputStream.putNextEntry(new ZipEntry((String)fileNames.get(loop)));
  byte[] buffer = new byte[1024];
  while (fileIn.read(buffer) != -1)
  {
  outputStream.write(buffer);
  }
  
  outputStream.closeEntry();
  fileIn.close();
  }
  
  outputStream.close();
  }
  catch (IOException ioe)
  {
  ioe.printStackTrace();
  }
  }
  
  static void  listFile(File parentFile, List nameList, List fileList)
  {
  if (parentFile.isDirectory())
  {
  File[] files = parentFile.listFiles();
  for (int loop=0; loop<files.length; loop++)
  {
  listFile(files[loop], nameList, fileList);
  }
  }
  else
  {
  fileList.add(parentFile);
  nameList.add(parentFile.getName());
  }
  }
  }

利用Java实现zip压缩/解压缩

Filed under: JAVA | No Comments »
Posted on

 Java 1.1实现了I/O数据流与网络数据流的单一接口,因此数据的压缩、网络传输和解

压缩的实现比较容易,下面介绍利用ZipEntry、ZipInputStream和ZipOutputStream三个Java

类实现zip数据压缩方式的编程方法。

  zip压缩文件结构:一个zip文件由多个entry组成,每个entry有一个唯一的名称,entry的

数据项存储压缩数据。

  与zip文件有关的几个Java类

  ·类ZipEntry

  public ZipEntry(String name);

  name为指定的数据项名。

  ·类ZipOutputStream

  ZipOutputStream实现了zip压缩文件的写输出流,支持压缩和非压缩entry。下面是它的

几个函数:

  public ZipOutputStream(OutputStream out);

  ∥利用输出流out构造一个ZIP输出流。

  public void setMethod(int method);

  ∥设置entry压缩方法,缺省值为DEFLATED。

  public void putNextEntry(ZipEntry newe);

  ∥如果当前的entry存在且处于激活状态时,关闭它,在zip文件中写入新的entry-newe

并将数据流定位于entry数据项的起始位置,压缩方法为setMethod指定的方法。

  ·类ZipInputStream

  ZipInputStream实现了zip压缩文件的读输入流,支持压缩和非压缩entry。下面是它的

几个函数:

  public ZipInputStream(InputStream in);

  ∥利用输入流in构造一个ZIP输出流。

  public ZipEntry getNextEntry();

  ∥返回ZIP文件中的下一个entry,并将输出流定位在此entry数据项的起始位置。

  public void closeEntry();

  ∥关闭当前的zip entry,并将数据流定位于下一个entry的起始位置。

  程序代码及其注释

  下列的程序实现了数据文件zip方式的压缩和解压缩方法。randomData()函数随机生成

50个double数据,并放在doc字符串变量中;openFile()函数读取ZIP压缩文件;saveFile()函数

将随机生成的数据存到ZIP格式的压缩文件中。

  import java.util.zip.*;

  import java.awt.event.*;

  import java.awt.*;

  import java.lang.Math;

  import java.io.*;

  public class TestZip extends Frame implements ActionListener {

  TextArea textarea; ∥显示数据文件的多行文本显示域

  TextField infotip; ∥显示数据文件未压缩大小及压缩大小单行文本显示域

  String doc; ∥存储随机生成的数据

  long doczipsize = 0;∥压缩数据文件的大小

  public TestZip(){

  ∥生成菜单

  MenuBar menubar = new MenuBar();

  setMenuBar(menubar);

  Menu file = new Menu(”File”,true);

  menubar.add(file);

  MenuItem neww= new MenuItem(”New”);

  neww.addActionListener(this);

  file.add(neww);

  MenuItem open=new MenuItem(”Open”);

  open.addActionListener(this);

  file.add(open);

  MenuItem save=new MenuItem(”Save”);

  save.addActionListener(this);

  file.add(save);

  MenuItem exit=new MenuItem(”Exit”);

  exit.addActionListener(this);

  file.add(exit);

  ∥随机生成的数据文件的多行文本显示域

  add(”Center”,textarea = new TextArea());

  ∥提示文本原始大小、压缩大小的单行文本显示域

  add(”South”,infotip = new TextField());

  }

  public static void main(String args[]){

  TestZip ok=new TestZip();

  ok.setTitle(”zip sample”);

  ok.setSize(600,300);

  ok.show();

  }

  private void randomData(){

  ∥随机生成50个double数据,并放在doc字符串变量中。

  doc=”";

  for(int i=1;i<51;i++){

   double rdm=Math.random()*10;

   doc=doc+new Double(rdm).toString();

   if(i%5 == 0) doc=doc+”n”;

   else doc=doc+” “;

  }

  doczipsize = 0;

  showTextandInfo();

  }

  private void openFile(){

  ∥打开zip文件,将文件内容读入doc字符串变量中。

  FileDialog dlg=new FileDialog(this,”Open”,FileDialog.LOA D);

  dlg.show();

  String filename=dlg.getDirectory()+dlg.getFile();

  try{

  ∥创建一个文件实例

  File f=new File(filename);

  if(!f.exists()) return; ∥文件不存在,则返回

  ∥用文件输入流构建ZIP压缩输入流

  ZipInputStream zipis=new ZipInputStream(new FileInputStream(f));

  zipis.getNextEntry();

  ∥将输入流定位在当前entry数据项位置

  DataInputStream dis=new DataInputStream(zipis);

  ∥用ZIP输入流构建DataInputStream

  doc=dis.readUTF();∥读取文件内容

  dis.close();∥关闭文件

  doczipsize = f.length();∥获取ZIP文件长度

  showTextandInfo();∥显示数据

  }

  catch(IOException ioe){

  System.out.println(ioe);

  }

  }

  private void saveFile(){

  ∥打开zip文件,将doc字符串变量写入zip文件中。

  FileDialog dlg=new FileDialog(this,”Save”,FileDialog.SAVE);

  dlg.show();

  String filename=dlg.getDirectory()+dlg.getFile();

  try{

  ∥创建一个文件实例

  File f=new File(filename);

  if(!f.exists()) return; ∥文件不存在,则返回

  ∥用文件输出流构建ZIP压缩输出流

  ZipOutputStream zipos=new ZipOutputStream(new FileOutputStream(f));

  zipos.setMethod(ZipOutputStream.DEFLATED); ∥设置压缩方法

  zipos.putNextEntry(new ZipEntry(”zip”));

  ∥生成一个ZIP entry,写入文件输出流中,并将输出流定位于entry起始处。

  DataOutputStream os=new DataOutputStream(zipos);

  ∥用ZIP输出流构建DataOutputStream;

  os.writeUTF(doc);∥将随机生成的数据写入文件中

  os.close();∥关闭数据流

  doczipsize = f.length();

  ∥获取压缩文件的长度

  showTextandInfo();∥显示数据

  }

  catch(IOException ioe){

  System.out.println(ioe);

  }

  }

  private void showTextandInfo(){

  ∥显示数据文件和压缩信息

  textarea.replaceRange(doc,0,textarea.getText().length());

  infotip.setText(”uncompressed size: “+doc.length()+”compressed size: “+dc zipsize);

  }

  public void actionPerformed(ActionEvent e){

  String arg = e.getActionCommand();

  if (”New”.equals(arg)) randomData();

  else if (”Open”.equals(arg)) openFile();

  else if (”Save”.equals(arg)) saveFile();

  else if (”Exit”.equals(arg)){

   dispose();∥关闭窗口

   System.exit(0);∥关闭程序

  }

  else {

   System.out.println(”no this command!”);

  }

  }

  }

用来读取QQwry.dat的java代码

Filed under: JAVA | No Comments »
Posted on

从lumaQQ中抄来的。:)

Utils.java

代码:[code]
/*
* Created on 2004-8-4
*
*/
package com.bupticet.ip;

import java.io.UnsupportedEncodingException;

/**
* @author LJ-silver
*/
public class Utils {
/**
* 从ip的字符串形式得到字节数组形式
* @param ip 字符串形式的ip
* @return 字节数组形式的ip
*/
public static byte[] getIpByteArrayFromString(String ip) {
byte[] ret = new byte[4];
java.util.StringTokenizer st = new java.util.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) {
System.out.println(e.getMessage());
}
return ret;
}

/**
* 对原始字符串进行编码转换,如果失败,返回原始的字符串
* @param s 原始字符串
* @param srcEncoding 源编码方式
* @param destEncoding 目标编码方式
* @return 转换编码后的字符串,失败返回原始字符串
*/
public static String getString(String s, String srcEncoding, String destEncoding) {
try {
return new String(s.getBytes(srcEncoding), destEncoding);
} catch (UnsupportedEncodingException e) {
return s;
}
}

/**
* 根据某种编码方式将字节数组转换成字符串
* @param b 字节数组
* @param encoding 编码方式
* @return 如果encoding不支持,返回一个缺省编码的字符串
*/
public static String getString(byte[] b, String encoding) {
try {
return new String(b, encoding);
} catch (UnsupportedEncodingException e) {
return new String(b);
}
}

/**
* 根据某种编码方式将字节数组转换成字符串
* @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);
}
}

/**
* @param ip ip的字节数组形式
* @return 字符串形式的ip
*/
public static String getIpStringFromBytes(byte[] ip) {
StringBuffer sb = new StringBuffer();
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();
}

}

/*
* LumaQQ - Java QQ Client
*
* Copyright (C) 2004 luma
*
* 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.bupticet.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;

/**
*

 * 用来读取QQwry.dat文件,以根据ip获得好友位置,QQwry.dat的格式是
* 一. 文件头,共8字节
* 	   1. 第一个起始IP的绝对偏移, 4字节
*     2. 最后一个起始IP的绝对偏移, 4字节
* 二. "结束地址/国家/区域"记录区
*     四字节ip地址后跟的每一条记录分成两个部分
*     1. 国家记录
*     2. 地区记录
*     但是地区记录是不一定有的。而且国家记录和地区记录都有两种形式
*     1. 以0结束的字符串
*     2. 4个字节,一个字节可能为0x1或0x2
* 		  a. 为0x1时,表示在绝对偏移后还跟着一个区域的记录,注意是绝对偏移之后,而不是这四个字节之后
*        b. 为0x2时,表示在绝对偏移后没有区域记录
*        不管为0x1还是0x2,后三个字节都是实际国家名的文件内绝对偏移
* 		  如果是地区记录,0x1和0x2的含义不明,但是如果出现这两个字节,也肯定是跟着3个字节偏移,如果不是
*        则为0结尾字符串
* 三. "起始地址/结束地址偏移"记录区
*     1. 每条记录7字节,按照起始地址从小到大排列
*        a. 起始IP地址,4字节
*        b. 结束ip地址的绝对偏移,3字节
*
* 注意,这个文件里的ip地址和所有的偏移量均采用little-endian格式,而java是采用
* big-endian格式的,要注意转换
* 

*
* @author 马若劼
*/
public class IPSeeker {
/**
*

	 * 用来封装ip相关信息,目前只有两个字段,ip所在的国家和地区
* 

*
* @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 = 0×01;
private static final byte NO_AREA = 0×2;

// 用来做为cache,查询一个ip时首先查看cache,以减少不必要的重复查找
private Hashtable ipCache;
// 随机文件访问类
private RandomAccessFile ipFile;
// 内存映射文件
private MappedByteBuffer mbb;
// 单一模式实例
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 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 = Utils.getIpStringFromBytes(b4);
// 得到结束IP
readIP(temp, b4);
entry.endIp = Utils.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 = Utils.getIpStringFromBytes(b4);
// 得到结束IP
readIP(temp, b4);
entry.endIp = Utils.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() & 0×00FFFFFF;
}

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

/**
* 根据IP得到国家名
* @param ip ip的字节数组形式
* @return 国家名字符串
*/
public String getCountry(byte[] ip) {
// 检查ip地址文件是否正常
if(ipFile == null) return “错误的IP数据库文件”;
// 保存ip,转换ip字节数组为字符串形式
String ipStr = Utils.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(Utils.getIpByteArrayFromString(ip));
}

/**
* 根据IP得到地区名
* @param ip ip的字节数组形式
* @return 地区名字符串
*/
public String getArea(byte[] ip) {
// 检查ip地址文件是否正常
if(ipFile == null) return “错误的IP数据库文件”;
// 保存ip,转换ip字节数组为字符串形式
String ipStr = Utils.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(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 = “未知国家”;
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 == 0×01 || b == 0×02) {
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 == 0×01 || b == 0×02) {
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());
if(i != 0)
return Utils.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());
if(i != 0)
return Utils.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();
}
}
[/code]
[code]
/*
* LumaQQ - Java QQ Client
*
* Copyright (C) 2004 luma
*
* 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.bupticet.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;

/**
*

 * 用来读取QQwry.dat文件,以根据ip获得好友位置,QQwry.dat的格式是
* 一. 文件头,共8字节
* 	   1. 第一个起始IP的绝对偏移, 4字节
*     2. 最后一个起始IP的绝对偏移, 4字节
* 二. "结束地址/国家/区域"记录区
*     四字节ip地址后跟的每一条记录分成两个部分
*     1. 国家记录
*     2. 地区记录
*     但是地区记录是不一定有的。而且国家记录和地区记录都有两种形式
*     1. 以0结束的字符串
*     2. 4个字节,一个字节可能为0x1或0x2
* 		  a. 为0x1时,表示在绝对偏移后还跟着一个区域的记录,注意是绝对偏移之后,而不是这四个字节之后
*        b. 为0x2时,表示在绝对偏移后没有区域记录
*        不管为0x1还是0x2,后三个字节都是实际国家名的文件内绝对偏移
* 		  如果是地区记录,0x1和0x2的含义不明,但是如果出现这两个字节,也肯定是跟着3个字节偏移,如果不是
*        则为0结尾字符串
* 三. "起始地址/结束地址偏移"记录区
*     1. 每条记录7字节,按照起始地址从小到大排列
*        a. 起始IP地址,4字节
*        b. 结束ip地址的绝对偏移,3字节
*
* 注意,这个文件里的ip地址和所有的偏移量均采用little-endian格式,而java是采用
* big-endian格式的,要注意转换
* 

*
* @author 马若劼
*/
public class IPSeeker {
/**
*

	 * 用来封装ip相关信息,目前只有两个字段,ip所在的国家和地区
* 

*
* @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 = 0×01;
private static final byte NO_AREA = 0×2;

// 用来做为cache,查询一个ip时首先查看cache,以减少不必要的重复查找
private Hashtable ipCache;
// 随机文件访问类
private RandomAccessFile ipFile;
// 内存映射文件
private MappedByteBuffer mbb;
// 单一模式实例
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 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 = Utils.getIpStringFromBytes(b4);
// 得到结束IP
readIP(temp, b4);
entry.endIp = Utils.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 = Utils.getIpStringFromBytes(b4);
// 得到结束IP
readIP(temp, b4);
entry.endIp = Utils.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() & 0×00FFFFFF;
}

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

/**
* 根据IP得到国家名
* @param ip ip的字节数组形式
* @return 国家名字符串
*/
public String getCountry(byte[] ip) {
// 检查ip地址文件是否正常
if(ipFile == null) return “错误的IP数据库文件”;
// 保存ip,转换ip字节数组为字符串形式
String ipStr = Utils.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(Utils.getIpByteArrayFromString(ip));
}

/**
* 根据IP得到地区名
* @param ip ip的字节数组形式
* @return 地区名字符串
*/
public String getArea(byte[] ip) {
// 检查ip地址文件是否正常
if(ipFile == null) return “错误的IP数据库文件”;
// 保存ip,转换ip字节数组为字符串形式
String ipStr = Utils.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(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 = “未知国家”;
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 == 0×01 || b == 0×02) {
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 == 0×01 || b == 0×02) {
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());
if(i != 0)
return Utils.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());
if(i != 0)
return Utils.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();
}
}
[/code]

[注意:这个class和上面的3个class的package不同,请对应修改。]
[code]
/**
* @author LJ-silver
*/
public class Test {

public static void main(String[] args) {
com.ljsilver.ip2address.IPSeeker seeker = com.ljsilver.ip2address.IPSeeker.getInstance();

if(args.length==2){
if(”ip”.equals(args[0])){
System.out.println(args[0]+”的所在地址是:”+seeker.getAddress(args[1]));
}else if(”address”.equals(args[0])){
List a = seeker.getIPEntries(args[1]);
                      System.out.println(args[0]+”:”); 
for(int i=0;i

[color=#008000]#include [color=#0000ff]<stdio[color=#0000ff].h[color=#0000ff]>
[color=#008000]#include [color=#0000ff]<stdlib[color=#0000ff].h[color=#0000ff]>
[color=#008000]#include [color=#0000ff]<string[color=#0000ff].h[color=#0000ff]>

[color=#ff8000]unsigned [color=#ff8000]long ip_str2dec[color=#0000ff]([color=#ff8000]char [color=#0000ff]*ip_in[color=#0000ff]) [color=#0000ff]{
[color=#ff8000]char [color=#0000ff]*ip [color=#0000ff]= strdup[color=#0000ff](ip_in[color=#0000ff])[color=#0000ff];
[color=#ff8000]unsigned [color=#ff8000]long ip_dec [color=#0000ff]= 0[color=#0000ff];

[color=#ff8000]char [color=#0000ff]*p[color=#0000ff];
[color=#ff8000]int i[color=#0000ff];
[color=#800000]for[color=#0000ff](i[color=#0000ff]=0[color=#0000ff];
i[color=#0000ff]<3[color=#0000ff];
i[color=#0000ff]+[color=#0000ff]+[color=#0000ff]) [color=#0000ff]{
p [color=#0000ff]= strrchr[color=#0000ff](ip[color=#0000ff],
‘[color=#0000ff].’[color=#0000ff])[color=#0000ff];
ip_dec [color=#0000ff]|[color=#0000ff]=
atoi[color=#0000ff](p[color=#0000ff]+1[color=#0000ff])
[color=#0000ff]< [color=#0000ff]<
[color=#0000ff](8[color=#0000ff]*i[color=#0000ff])[color=#0000ff];
[color=#0000ff]*p [color=#0000ff]= [color=#4080ff]‘\0′[color=#0000ff];
[color=#0000ff]}
ip_dec [color=#0000ff]|[color=#0000ff]=
atoi[color=#0000ff](ip[color=#0000ff])
[color=#0000ff]<[color=#0000ff]<
[color=#0000ff](8[color=#0000ff]*i[color=#0000ff])[color=#0000ff];
free[color=#0000ff](ip[color=#0000ff])[color=#0000ff];
[color=#800000]return ip_dec[color=#0000ff];
[color=#0000ff]}

[color=#ff8000]unsigned [color=#ff8000]long ip_arr2dec[color=#0000ff]([color=#ff8000]char [color=#0000ff]*[color=#0000ff]*ip_arr[color=#0000ff]) [color=#0000ff]{
[color=#ff8000]unsigned [color=#ff8000]long ip_dec [color=#0000ff]= 0[color=#0000ff];
[color=#ff8000]int i[color=#0000ff];
[color=#800000]for[color=#0000ff](i[color=#0000ff]=0[color=#0000ff];
i[color=#0000ff]<4[color=#0000ff];
i[color=#0000ff]+[color=#0000ff]+[color=#0000ff]) [color=#0000ff]{
ip_dec [color=#0000ff]|[color=#0000ff]=
atoi[color=#0000ff](ip_arr[color=#0000ff][i[color=#0000ff]][color=#0000ff])
[color=#0000ff]<[color=#0000ff]<
[color=#0000ff](8[color=#0000ff]*[color=#0000ff](3[color=#0000ff]-i[color=#0000ff])[color=#0000ff])[color=#0000ff];
[color=#0000ff]}
[color=#800000]return ip_dec[color=#0000ff];
[color=#0000ff]}

[color=#ff8000]unsigned [color=#ff8000]long ip_arr2dec_r[color=#0000ff]([color=#ff8000]unsigned [color=#ff8000]char [color=#0000ff]*ip_arr[color=#0000ff]) [color=#0000ff]{
[color=#ff8000]unsigned [color=#ff8000]long ip_dec [color=#0000ff]= 0[color=#0000ff];
[color=#ff8000]int i[color=#0000ff];
[color=#800000]for[color=#0000ff](i[color=#0000ff]=0[color=#0000ff];
i[color=#0000ff]<4[color=#0000ff];
i[color=#0000ff]+[color=#0000ff]+[color=#0000ff]) [color=#0000ff]{
ip_dec [color=#0000ff]|[color=#0000ff]=
ip_arr[color=#0000ff][i[color=#0000ff]]
[color=#0000ff]<[color=#0000ff]<
[color=#0000ff](8[color=#0000ff]*i[color=#0000ff])[color=#0000ff];
[color=#0000ff]}
[color=#800000]return ip_dec[color=#0000ff];
[color=#0000ff]}

[color=#008080]/**********************************************************/

[color=#800000]typedef [color=#ff8000]struct ip_info [color=#0000ff]{
[color=#ff8000]char ip[color=#0000ff][16[color=#0000ff]][color=#0000ff];
[color=#ff8000]char [color=#0000ff]*country[color=#0000ff];
[color=#ff8000]char [color=#0000ff]*area[color=#0000ff];
[color=#ff8000]char start_ip[color=#0000ff][16[color=#0000ff]][color=#0000ff]; [color=#008080]// For debug
[color=#ff8000]char end_ip[color=#0000ff][16[color=#0000ff]][color=#0000ff]; [color=#008080]// For debug
[color=#ff8000]char [color=#0000ff]*mode[color=#0000ff]; [color=#008080]// For debug
[color=#0000ff]} IP_INFO[color=#0000ff];

[color=#ff8000]unsigned [color=#ff8000]long get_long_addr3[color=#0000ff]([color=#ff8000]unsigned [color=#ff8000]char [color=#0000ff]*buf[color=#0000ff])[color=#0000ff];
[color=#ff8000]char[color=#0000ff]* get_string_by_addr[color=#0000ff]([color=#ff8000]long addr[color=#0000ff], FILE [color=#0000ff]*fp[color=#0000ff])[color=#0000ff];
IP_INFO [color=#0000ff]*get_ip_by_index[color=#0000ff]([color=#ff8000]unsigned [color=#ff8000]long index_addr[color=#0000ff], FILE [color=#0000ff]*fp[color=#0000ff])[color=#0000ff];
[color=#ff8000]char[color=#0000ff]* get_area[color=#0000ff]([color=#ff8000]unsigned [color=#ff8000]char[color=#0000ff]* buffer[color=#0000ff], FILE [color=#0000ff]*fp[color=#0000ff])[color=#0000ff];
[color=#ff8000]void print_iptable[color=#0000ff](FILE [color=#0000ff]*fp[color=#0000ff])[color=#0000ff];
[color=#ff8000]unsigned [color=#ff8000]long search_ip[color=#0000ff]([color=#ff8000]char [color=#0000ff]*ip_in[color=#0000ff], FILE [color=#0000ff]*fp[color=#0000ff])[color=#0000ff];

[color=#ff8000]unsigned [color=#ff8000]long get_long_addr3[color=#0000ff]([color=#ff8000]unsigned [color=#ff8000]char [color=#0000ff]*buf[color=#0000ff]) [color=#0000ff]{
[color=#ff8000]unsigned [color=#ff8000]long
addr [color=#0000ff]= 0[color=#0000ff];
[color=#008080]/* addr = buf[0] + buf[1]*256 + buf[2]*65536; */
addr [color=#0000ff]= buf[color=#0000ff][0[color=#0000ff]]
[color=#0000ff]| buf[color=#0000ff][1[color=#0000ff]]
[color=#0000ff]<[color=#0000ff]< 8 [color=#0000ff]|
buf[color=#0000ff][2[color=#0000ff]]
[color=#0000ff]<[color=#0000ff]< 16[color=#0000ff];
[color=#800000]return addr[color=#0000ff];
[color=#0000ff]}

[color=#ff8000]char[color=#0000ff]* get_string_by_addr[color=#0000ff]([color=#ff8000]long addr[color=#0000ff], FILE [color=#0000ff]*fp[color=#0000ff]) [color=#0000ff]{
[color=#ff8000]unsigned [color=#ff8000]char buffer[color=#0000ff][1024[color=#0000ff]][color=#0000ff];
fseek[color=#0000ff](fp[color=#0000ff], addr[color=#0000ff], SEEK_SET[color=#0000ff])[color=#0000ff];
fread[color=#0000ff](buffer[color=#0000ff], 1024[color=#0000ff], 1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
[color=#800000]return strdup[color=#0000ff](buffer[color=#0000ff])[color=#0000ff];
[color=#0000ff]}

IP_INFO [color=#0000ff]*get_ip_by_index[color=#0000ff]([color=#ff8000]unsigned [color=#ff8000]long
index_addr[color=#0000ff], FILE [color=#0000ff]*fp[color=#0000ff])
[color=#0000ff]{
IP_INFO [color=#0000ff]*ipinfo [color=#0000ff]= [color=#0000ff](IP_INFO
[color=#0000ff]*[color=#0000ff])malloc[color=#0000ff]([color=#800000]sizeof[color=#0000ff](IP_INFO[color=#0000ff])[color=#0000ff])[color=#0000ff];

[color=#ff8000]unsigned [color=#ff8000]char ip[color=#0000ff][4[color=#0000ff]][color=#0000ff];
[color=#ff8000]unsigned [color=#ff8000]char addr[color=#0000ff][3[color=#0000ff]][color=#0000ff];
[color=#ff8000]unsigned [color=#ff8000]long
record_addr [color=#0000ff]= 0[color=#0000ff];
fseek[color=#0000ff](fp[color=#0000ff], index_addr[color=#0000ff],
SEEK_SET[color=#0000ff])[color=#0000ff];
fread[color=#0000ff](ip[color=#0000ff], 4[color=#0000ff],
1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
fread[color=#0000ff](addr[color=#0000ff], 3[color=#0000ff],
1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
record_addr [color=#0000ff]=
get_long_addr3[color=#0000ff](addr[color=#0000ff])[color=#0000ff];
sprintf[color=#0000ff](ipinfo[color=#0000ff]-[color=#0000ff]>start_ip[color=#0000ff],
“[color=#0000ff]%u[color=#0000ff].[color=#0000ff]%u[color=#0000ff].[color=#0000ff]%u[color=#0000ff].[color=#0000ff]%u”[color=#0000ff],
ip[color=#0000ff][3[color=#0000ff]][color=#0000ff],
ip[color=#0000ff][2[color=#0000ff]][color=#0000ff],
ip[color=#0000ff][1[color=#0000ff]][color=#0000ff],
ip[color=#0000ff][0[color=#0000ff]][color=#0000ff])[color=#0000ff];
[color=#ff8000]unsigned [color=#ff8000]char buffer[color=#0000ff][1024[color=#0000ff]][color=#0000ff];
[color=#ff8000]unsigned [color=#ff8000]long
country_addr[color=#0000ff];
fseek[color=#0000ff](fp[color=#0000ff], record_addr[color=#0000ff],
SEEK_SET[color=#0000ff])[color=#0000ff];
fread[color=#0000ff](ip[color=#0000ff], 4[color=#0000ff],
1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
fread[color=#0000ff](buffer[color=#0000ff], 1024[color=#0000ff],
1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
sprintf[color=#0000ff](ipinfo[color=#0000ff]-[color=#0000ff]>end_ip[color=#0000ff],
“[color=#0000ff]%u[color=#0000ff].[color=#0000ff]%u[color=#0000ff].[color=#0000ff]%u[color=#0000ff].[color=#0000ff]%u”[color=#0000ff],
ip[color=#0000ff][3[color=#0000ff]][color=#0000ff],
ip[color=#0000ff][2[color=#0000ff]][color=#0000ff],
ip[color=#0000ff][1[color=#0000ff]][color=#0000ff],
ip[color=#0000ff][0[color=#0000ff]][color=#0000ff])[color=#0000ff];
[color=#800000]if [color=#0000ff](buffer[color=#0000ff][0[color=#0000ff]] [color=#0000ff]=[color=#0000ff]= 1[color=#0000ff]) [color=#0000ff]{
country_addr [color=#0000ff]= get_long_addr3[color=#0000ff](buffer [color=#0000ff]+ 1[color=#0000ff])[color=#0000ff];
fseek[color=#0000ff](fp[color=#0000ff], country_addr[color=#0000ff], SEEK_SET[color=#0000ff])[color=#0000ff];
fread[color=#0000ff](buffer[color=#0000ff], 1024[color=#0000ff], 1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];

[color=#800000]if
[color=#0000ff](buffer[color=#0000ff][0[color=#0000ff]]
[color=#0000ff]=[color=#0000ff]= 2[color=#0000ff]) [color=#0000ff]{
ipinfo[color=#0000ff]-[color=#0000ff]>country [color=#0000ff]=
get_string_by_addr[color=#0000ff](get_long_addr3[color=#0000ff](buffer
[color=#0000ff]+ 1[color=#0000ff])[color=#0000ff],
fp[color=#0000ff])[color=#0000ff];
ipinfo[color=#0000ff]-[color=#0000ff]>area [color=#0000ff]=
get_area[color=#0000ff](buffer [color=#0000ff]+ 4[color=#0000ff],
fp[color=#0000ff])[color=#0000ff];
ipinfo[color=#0000ff]-[color=#0000ff]>mode [color=#0000ff]= “1
[color=#0000ff]+ 2″[color=#0000ff];
[color=#0000ff]} [color=#800000]else [color=#0000ff]{
ipinfo[color=#0000ff]-[color=#0000ff]>country [color=#0000ff]=
get_string_by_addr[color=#0000ff](country_addr[color=#0000ff],
fp[color=#0000ff])[color=#0000ff];
ipinfo[color=#0000ff]-[color=#0000ff]>area [color=#0000ff]=
get_area[color=#0000ff](buffer [color=#0000ff]+
strlen[color=#0000ff](ipinfo[color=#0000ff]-[color=#0000ff]>country[color=#0000ff])
[color=#0000ff]+ 1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
ipinfo[color=#0000ff]-[color=#0000ff]>mode [color=#0000ff]= “1
[color=#0000ff]+ D”[color=#0000ff];
[color=#0000ff]}
[color=#0000ff]} [color=#800000]else [color=#800000]if
[color=#0000ff](buffer[color=#0000ff][0[color=#0000ff]]
[color=#0000ff]=[color=#0000ff]= 2[color=#0000ff]) [color=#0000ff]{
ipinfo[color=#0000ff]-[color=#0000ff]>country [color=#0000ff]=
get_string_by_addr[color=#0000ff](get_long_addr3[color=#0000ff](buffer
[color=#0000ff]+ 1[color=#0000ff])[color=#0000ff],
fp[color=#0000ff])[color=#0000ff];
ipinfo[color=#0000ff]-[color=#0000ff]>area [color=#0000ff]=
get_area[color=#0000ff](buffer [color=#0000ff]+ 4[color=#0000ff],
fp[color=#0000ff])[color=#0000ff];
ipinfo[color=#0000ff]-[color=#0000ff]>mode [color=#0000ff]= “2
[color=#0000ff]+ D”[color=#0000ff];
[color=#0000ff]} [color=#800000]else [color=#0000ff]{
ipinfo[color=#0000ff]-[color=#0000ff]>country [color=#0000ff]=
strdup[color=#0000ff](buffer[color=#0000ff])[color=#0000ff];
ipinfo[color=#0000ff]-[color=#0000ff]>area [color=#0000ff]=
get_area[color=#0000ff](buffer [color=#0000ff]+
strlen[color=#0000ff](ipinfo[color=#0000ff]-[color=#0000ff]>country[color=#0000ff])
[color=#0000ff]+ 1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
ipinfo[color=#0000ff]-[color=#0000ff]>mode [color=#0000ff]= “D
[color=#0000ff]+ D”[color=#0000ff];
[color=#0000ff]}
[color=#800000]return ipinfo[color=#0000ff];
[color=#0000ff]}

[color=#ff8000]char[color=#0000ff]* get_area[color=#0000ff]([color=#ff8000]unsigned [color=#ff8000]char[color=#0000ff]* buffer[color=#0000ff], FILE [color=#0000ff]*fp[color=#0000ff]) [color=#0000ff]{
[color=#800000]if
[color=#0000ff](buffer[color=#0000ff][0[color=#0000ff]]
[color=#0000ff]=[color=#0000ff]= 1 [color=#0000ff]|[color=#0000ff]|
buffer[color=#0000ff][0[color=#0000ff]]
[color=#0000ff]=[color=#0000ff]= 2[color=#0000ff]) [color=#0000ff]{
[color=#800000]return
get_string_by_addr[color=#0000ff](get_long_addr3[color=#0000ff](buffer
[color=#0000ff]+ 1[color=#0000ff])[color=#0000ff],
fp[color=#0000ff])[color=#0000ff];
[color=#0000ff]} [color=#800000]else [color=#0000ff]{
[color=#800000]return strdup[color=#0000ff](buffer[color=#0000ff])[color=#0000ff];
[color=#0000ff]}
[color=#0000ff]}

[color=#ff8000]void print_iptable[color=#0000ff](FILE [color=#0000ff]*fp[color=#0000ff]) [color=#0000ff]{
[color=#ff8000]unsigned [color=#ff8000]long
index_start[color=#0000ff], index_end[color=#0000ff];
fseek[color=#0000ff](fp[color=#0000ff], 0[color=#0000ff],
SEEK_SET[color=#0000ff])[color=#0000ff];
fread[color=#0000ff]([color=#0000ff]&index_start[color=#0000ff],
4[color=#0000ff], 1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
fread[color=#0000ff]([color=#0000ff]&index_end[color=#0000ff],
4[color=#0000ff], 1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
[color=#008080]/* printf(”%lu %lu\n”, index_start, index_end); */
[color=#ff8000]unsigned [color=#ff8000]long i[color=#0000ff];
IP_INFO [color=#0000ff]*ipinfo[color=#0000ff];

[color=#800000]for[color=#0000ff](i[color=#0000ff]=index_start[color=#0000ff];
i[color=#0000ff]< [color=#0000ff]=index_end[color=#0000ff];
i[color=#0000ff]+[color=#0000ff]=7[color=#0000ff]) [color=#0000ff]{
ipinfo [color=#0000ff]=
get_ip_by_index[color=#0000ff](i[color=#0000ff],
fp[color=#0000ff])[color=#0000ff];
printf[color=#0000ff]([color=#ff00ff]“%s - %s\n%s,
%s\n”[color=#0000ff],
ipinfo[color=#0000ff]-[color=#0000ff]>start_ip[color=#0000ff],
ipinfo[color=#0000ff]-[color=#0000ff]>end_ip[color=#0000ff],
ipinfo[color=#0000ff]-[color=#0000ff]>country[color=#0000ff],
ipinfo[color=#0000ff]-[color=#0000ff]>area[color=#0000ff])[color=#0000ff];
free[color=#0000ff](ipinfo[color=#0000ff])[color=#0000ff];
[color=#0000ff]}
[color=#0000ff]}
[color=#ff8000]unsigned [color=#ff8000]long search_ip[color=#0000ff]([color=#ff8000]char [color=#0000ff]*ip_in[color=#0000ff], FILE [color=#0000ff]*fp[color=#0000ff]) [color=#0000ff]{
[color=#ff8000]unsigned [color=#ff8000]long
index_start[color=#0000ff], index_end[color=#0000ff],
lo[color=#0000ff], hi[color=#0000ff], i[color=#0000ff],
ip_i[color=#0000ff], ip_dest[color=#0000ff];
[color=#ff8000]unsigned [color=#ff8000]char
ip_arr[color=#0000ff][4[color=#0000ff]][color=#0000ff];
fseek[color=#0000ff](fp[color=#0000ff], 0[color=#0000ff],
SEEK_SET[color=#0000ff])[color=#0000ff];
fread[color=#0000ff]([color=#0000ff]&index_start[color=#0000ff],
4[color=#0000ff], 1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
fread[color=#0000ff]([color=#0000ff]&index_end[color=#0000ff],
4[color=#0000ff], 1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
lo [color=#0000ff]= 0[color=#0000ff];
hi [color=#0000ff]= [color=#0000ff](index_end [color=#0000ff]-
index_start[color=#0000ff]) [color=#0000ff]/ 7[color=#0000ff];
ip_dest [color=#0000ff]=
ip_str2dec[color=#0000ff](ip_in[color=#0000ff])[color=#0000ff];
[color=#800000]while[color=#0000ff](lo
[color=#0000ff]< [color=#0000ff]= hi[color=#0000ff])
[color=#0000ff]{
i [color=#0000ff]= [color=#0000ff](lo [color=#0000ff]+
hi[color=#0000ff]) [color=#0000ff]/ 2[color=#0000ff];
fseek[color=#0000ff](fp[color=#0000ff], index_start [color=#0000ff]+ i
[color=#0000ff]* 7[color=#0000ff],
SEEK_SET[color=#0000ff])[color=#0000ff];
fread[color=#0000ff](ip_arr[color=#0000ff], 4[color=#0000ff],
1[color=#0000ff], fp[color=#0000ff])[color=#0000ff];
ip_i [color=#0000ff]=
ip_arr2dec_r[color=#0000ff](ip_arr[color=#0000ff])[color=#0000ff];
[color=#800000]if [color=#0000ff](ip_i [color=#0000ff]=[color=#0000ff]= ip_dest[color=#0000ff])
[color=#800000]return index_start [color=#0000ff]+ i [color=#0000ff]* 7[color=#0000ff];
[color=#800000]else [color=#800000]if [color=#0000ff](ip_i [color=#0000ff]< ip_dest[color=#0000ff])
lo [color=#0000ff]= i [color=#0000ff]+ 1[color=#0000ff];
[color=#800000]else
hi [color=#0000ff]= i [color=#0000ff]- 1[color=#0000ff];
[color=#0000ff]}
[color=#008080]/* hi return index_start + hi * 7;
}

int main(int argc, char **argv) {
FILE *fp;
fp = fopen(”QQWry.Dat”, “r”);

IP_INFO *ipinfo = get_ip_by_index(search_ip(argv[1], fp), fp);
printf(”%s, %s\n”, ipinfo->country, ipinfo->area);
free(ipinfo);

/* print_iptable(fp); */

fclose[color=#0000ff](fp[color=#0000ff])[color=#0000ff];
[color=#800000]return EXIT_SUCCESS[color=#0000ff];
[color=#0000ff]}

[/code]

Lucene 关于日期类型的索引及搜索

Filed under: JAVA | No Comments »
Posted on

索引:

1.4.3

doc.add(Field.Keyword(”Publishdate”, util.checkNull(gq.getAddDate())));

2.0
[code]doc.add(new Field(”Publishdate”, util.checkNull(gq.getAddDate()),
Field.Store.YES,Field.Index.UN_TOKENIZED));
[/code]
checkNull 方法
[code] public String checkNull(Date date) { java.text.DateFormat df =
new java.text.SimpleDateFormat(”yyyy-MM-dd”); return df.format((Date)
ObjectUtils.defaultIfNull(date, new Date())); }
[/code]
搜索:
[code]
BooleanQuery query = new BooleanQuery();
RangeQuery rquery = new RangeQuery(new Term(”Publishdate”,
util.checkNull(startdate)), new Term(”Publishdate”,
util.checkNull(enddate)), true);
BooleanClause timegoryclause = new
BooleanClause(rquery,BooleanClause.Occur.MUST);
query.add(timegoryclause);
[/code]