httprequest.java

基于java nio实现的http服务器

package org.sse.http;

import java.io.*;
import java.util.*;
import java.util.HashMap;

/**
 * @author Taylor Cowan
 */
public class HttpRequest {

	private String rawUrl;
	private HashMap headerValues=new HashMap();
	private ServletContext servletContext;
	
	public HttpRequest(InputStream is, ServletContext ctx) throws IOException {		
		parseHeader(new InputStreamReader(is, "UTF-8"));
		servletContext = ctx;
	}

	public void parseHeader(Reader reader) throws IOException {
		BufferedReader br = new BufferedReader(reader);
		String line = br.readLine();
		String[] tokens = line.split(" ");
		rawUrl = tokens[1];
		while ( (line = br.readLine()) != null && !line.equals("")) {
			tokens = line.split(": ");
			headerValues.put(tokens[0].toLowerCase(), tokens[1].toLowerCase());
		}
	}

	public String getRequestedResource() {
		return (rawUrl.indexOf('?') > 0) ? rawUrl.split("?")[0] : rawUrl;
	}

	public String getHeader(String key) {
		return (String)headerValues.get(key);
	}

	public boolean closeAfterResponse() {
		return getHeader("connection").charAt(0) == 'c';
	}

	public int getContentLength() {
		String lengthStr = (String) headerValues.get("content-length");
		return (lengthStr != null) ? Integer.parseInt(lengthStr) : 0;
	}

	public long getModifiedSince() {
		String tmp = (String) headerValues.get("if-modified-since");
		return (tmp == null) ? 0:Date.parse(tmp);
	}

	public ServletContext getServletContext() {
		return servletContext;
	}
}