httpinputstream.java

《Java TCP/IP应用开发详解》的部分源程序,开发环境为ECLIPSE3.1

package section18;

import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

public class HTTPInputStream extends FilterInputStream {

	public HTTPInputStream(InputStream in) {
		super(in);
		// TODO Auto-generated constructor stub
	}
    
	public String readLine()throws IOException
	{
		StringBuffer result=new StringBuffer();
		boolean finished=false;
		boolean cr=false;
		do{
			int ch=-1;
			ch=read();
			if(ch==-1)return result.toString();
			result.append((char)ch);
			if(cr&&ch==10)
			{
				result.setLength(result.length()-2);
				return result.toString();
			}
			if(ch==13)cr=true;
			else cr=false;
		}while(!finished);
		return result.toString();
	}

	public HTTPRequest getRequest()throws IOException
	{
		HTTPRequest request=new HTTPRequest();
		String line;
		do{
			line=readLine();
			if(line.length()>0)request.addLine(line);
			else break;
		}while(true);
		return request;
	}

}