package com.sample.http;
import java.util.Map;
 // http協(xié)議的請(qǐng)求
public interface HttpRequest {
 //獲得請(qǐng)求的協(xié)議
 public String getProtocol();
 //獲得請(qǐng)求的方法
 public String getRequestMethod();
 //獲得請(qǐng)求的路徑
 public String getRequestPath();
 //獲得請(qǐng)求的消息報(bào)頭
 public Map<String,String> getRequestHeader();
 //根據(jù)參數(shù)的名字獲得請(qǐng)求帶過(guò)來(lái)的參數(shù)值
 public String getParameter(String parameterName);
 //判斷當(dāng)前請(qǐng)求的否是靜態(tài)資源
 public boolean isStaticResource();
 //判斷當(dāng)前請(qǐng)求的否是動(dòng)態(tài)資源
 public boolean isDynamicResource();
 //判斷當(dāng)前請(qǐng)求的否是為空請(qǐng)求(有些瀏覽器會(huì)自動(dòng)發(fā)送空請(qǐng)求)
 public boolean isNullRequest();
}

package com.sample.http;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.Socket;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
public class HttpRequestImpl implements HttpRequest{
	//客戶(hù)端的Socket
	private Socket s;
	private InputStream is=null;//輸入流
	private BufferedReader br=null;
	private HashMap<String,String> hmHeader=new HashMap<String,String>();//消息報(bào)頭
	private HashMap<String,String> hmparameters=new HashMap<String, String>();//參數(shù)集合
	private boolean isNullRequest=false;//是否為空請(qǐng)求，默認(rèn)false
	private String protocol=null;//請(qǐng)求協(xié)議
	private String requestMethod=null;//請(qǐng)求方法
	private String requestPath=null;//請(qǐng)求路徑
	public HttpRequestImpl(Socket s) {
		this.s=s;
		getInfos();//調(diào)用方法
	 }
	private void getInfos()//定義一個(gè)方法，用于處理獲取的客戶(hù)端信息
	{
		try {
			is=s.getInputStream();
			br=new BufferedReader(new InputStreamReader(is));
			//解析第一行
			String str;
			str=br.readLine();//readLine使用回車(chē)換行判斷一行是否結(jié)束
			if(str==null)
			{
				isNullRequest=true;
				return;
			}
			parseRequestMethodPathProtocol(str);//調(diào)用自己創(chuàng)建在本類(lèi)里邊的方法處理第一行信息，方法在后面
		//解析第二行---第八行
			String header=null;  
  //判斷是否結(jié)束，如果結(jié)束就退出，這里的判斷按較為饒人
  //首先應(yīng)該明確br.readLine()的內(nèi)容，當(dāng)為true是對(duì)應(yīng)的情況
  //也就是說(shuō)當(dāng)“”（中間沒(méi)有空格）與br.readLine()相等時(shí)，就進(jìn)入到while中
  while(!"".equals((header=br.readLine()))){
			parseRequestHeader(header);
			}
		//post和get
		if(br.ready())//post//POST提交方式判斷，如果還有下一行就繼續(xù)讀取信息
		{
			char[] buf=new char[1024];
			int len=br.read(buf);//使用字節(jié)進(jìn)行讀取，因?yàn)檫@一行沒(méi)有回車(chē)換行，readLine無(wú)法判斷是否結(jié)束
			String parameter=new String(buf,0,len);
			parseRequestParamByPost(parameter);//調(diào)用自己創(chuàng)建在本類(lèi)里邊的方法處理POST方式提交的正文信息	
		}
		else
		{//get,get參數(shù)的位置在第一行連接處
			parseRequestParamByGet(requestPath);//調(diào)用自己創(chuàng)建在本類(lèi)里邊的方法處理GET方式提交的正文信息	
		}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
 //GET方法處理
 private void parseRequestParamByGet(String requestPath2) {
		String []str1=requestPath2.split("[?]");//使用“？”分割字符串
		if(str1.length==2)
		{
				parseRequestParamByPost(str1[1]);
		}
		this.requestPath=str1[0];
	}
 //POST方法處理
 private void parseRequestParamByPost(String parameter) {
		 String[] strs=parameter.split("&");
		 if(strs.length>=1)
		 {
			 for(String str:strs)
			 {
				 String [] sp=str.split("=");
  hmparameters.put(sp[0],sp[1]); 
			 }
		 }
	}
	//解析第二行到第八行
	private void parseRequestHeader(String header) throws Exception{
		String[] headHost=header.split(": ");
		 if(headHost.length!=2)
	 {
			 throw new Exception("消息報(bào)頭異常，請(qǐng)重新提交");		 
		 }
		 hmHeader.put(headHost[0],headHost[1]);
	}
	//解析第一行
	private void parseRequestMethodPathProtocol(String str) throws Exception {
		 String[] protocolMethodPath=new String[3];//由于第一行含有三個(gè)內(nèi)容，分割后需要三個(gè)String存儲(chǔ)
		 protocolMethodPath=str.split(" ");//使用空格分割
		 if(protocolMethodPath.length==3)
		 {
		 requestMethod=protocolMethodPath[0];
		 requestPath=protocolMethodPath[1];
		 protocol=protocolMethodPath[2];
		 }
		 else
		 {
			 throw new Exception("首行參數(shù)不合適，請(qǐng)重新提交");
		 }
	}
	//獲得請(qǐng)求的協(xié)議
	public String getProtocol()
	{
		return protocol;
	}
	//獲得請(qǐng)求的方法
	public String getRequestMethod(){
		return requestMethod;
	}
	//獲得請(qǐng)求的路徑
	public String getRequestPath(){
		return requestPath;
	}
	//獲得請(qǐng)求的消息報(bào)頭
	public Map<String,String> getRequestHeader(){
		return this.hmHeader;
	}
	//根據(jù)參數(shù)的名字獲得請(qǐng)求帶過(guò)來(lái)的參數(shù)值
	public String getParameter(String parameterName){
		return hmparameters.get(parameterName);
	}
	//判斷當(dāng)前請(qǐng)求的否是靜態(tài)資源
	public boolean isStaticResource(){
		return true;
	}
	//判斷當(dāng)前請(qǐng)求的否是動(dòng)態(tài)資源
	public boolean isDynamicResource(){
		return true;
	}
	//判斷當(dāng)前請(qǐng)求的否是為空請(qǐng)求(有些瀏覽器會(huì)自動(dòng)發(fā)送空請(qǐng)求)
	public boolean isNullRequest(){
 return isNullRequest;
	}
}

package com.sample.http;
import java.io.OutputStream;
import java.io.PrintWriter;
//http協(xié)議的響應(yīng)
public interface HttpResponse {
	//獲得一個(gè)指向客戶(hù)端的字節(jié)流
	public OutputStream getOutputStream()throws Exception;
	//獲得一個(gè)指向客戶(hù)端的字符流
	public PrintWriter getPrintWriter()throws Exception;
	//設(shè)置響應(yīng)的狀態(tài)行 參數(shù)為String類(lèi)型
	public void setStatusLine(String statusCode);
	//設(shè)置響應(yīng)的狀態(tài)行 參數(shù)為int類(lèi)型
	public void setStatusLine(int statusCode);
	//設(shè)置響應(yīng)消息報(bào)頭
	public void setResponseHeader(String hName,String hValue);
	//設(shè)置響應(yīng)消息報(bào)頭中Content-Type屬性
	public void setContentType(String contentType);
	//設(shè)置響應(yīng)消息報(bào)頭中Content-Type屬性 并且同時(shí)設(shè)置編碼
	public void setContentType(String contentType,String charsetName);
	//設(shè)置CRLF 回車(chē)換行 \r\n
	public void setCRLF();
	//把設(shè)置好的響應(yīng)狀態(tài)行、響應(yīng)消息報(bào)頭、固定空行這三部分寫(xiě)給瀏覽器
	public void printResponseHeader();
	//把響應(yīng)正文寫(xiě)給瀏覽器
	public void printResponseContent(String requestPath);		
}

package com.sample.http;
<pre name="code" class="java">import java.io.BufferedWriter;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
 
import com.sample.utils.ConfigUtils;
import com.sample.utils.StatusCodeUtils;
//http協(xié)議的響應(yīng)
public class HttpResponseImpl implements HttpResponse {
	 //聲明初始變量
	Socket s;//客戶(hù)端socket
	OutputStream os;//輸出端字節(jié)流
	BufferedWriter bw;//輸出端字符流
	PrintWriter pw;
	StringBuffer sbuffer;//放狀態(tài)行，\r\n ,
	FileInputStream fis;
	File file;
	//構(gòu)造器
	public HttpResponseImpl(Socket s) {
  this.s=s;
  System.out.println("HttpRequestImpl(Socket s)");
  os=null;
  bw=null;
  pw=null;
  sbuffer=new StringBuffer();//初始化，記得，否則以下的操作會(huì)遇見(jiàn)空指針異常
  fis=null;
  file=null; 			
  getInfos();
	}
	 
	private void getInfos() {
			try {
				os=s.getOutputStream();
				bw=new BufferedWriter(new OutputStreamWriter(os,"GBK"));
				pw=new PrintWriter(bw);
			} catch (Exception e) {
				e.printStackTrace();
			}
	}
	//獲得一個(gè)指向客戶(hù)端的字節(jié)流
	public OutputStream getOutputStream()throws Exception
	{
		return os;
	}
	//獲得一個(gè)指向客戶(hù)端的字符流
	public PrintWriter getPrintWriter()throws Exception
	{
		return pw;
	}
	//設(shè)置響應(yīng)的狀態(tài)行 參數(shù)為String類(lèi)型
	public void setStatusLine(String statusCode)
	{
		String str=StatusCodeUtils.getStatusCodeValue(statusCode);
		//System.out.println(str+"------"+str.length());
		sbuffer.append("HTTP/1.1 "+statusCode+" "+str);
		setCRLF();
	}
	//設(shè)置響應(yīng)的狀態(tài)行 參數(shù)為int類(lèi)型
	public void setStatusLine(int statusCode)
	{
		setStatusLine(statusCode+"");//將int類(lèi)型轉(zhuǎn)化為String類(lèi)型
	}
	//設(shè)置響應(yīng)消息報(bào)頭
	public void setResponseHeader(String hName,String hValue)
	{
		sbuffer.append(hName+": "+hValue);
		setCRLF();
	}
	//設(shè)置響應(yīng)消息報(bào)頭中Content-Type屬性
	public void setContentType(String contentType)
	{
		setResponseHeader("Content-Type",contentType);
	}
	//設(shè)置響應(yīng)消息報(bào)頭中Content-Type屬性 并且同時(shí)設(shè)置編碼
	public void setContentType(String contentType,String charsetName)
	{//text/html;charset=utf-8
		setContentType(";charset= "+charsetName);
	}
	//設(shè)置CRLF 回車(chē)換行 \r\n
	public void setCRLF()
	{
		sbuffer.append("\r\n");
	}
	//把設(shè)置好的響應(yīng)狀態(tài)行、響應(yīng)消息報(bào)頭、固定空行這三部分寫(xiě)給瀏覽器
	public void printResponseHeader()
	{
		//設(shè)置setResponseLine,setResponseHeader,setResponseType
		String res=sbuffer.toString();
		pw.print(res);
		pw.flush();
	}
	//把響應(yīng)正文寫(xiě)給瀏覽器
	public void printResponseContent(String requestPath)
	{
		//響應(yīng)正文
		String getPath= requestPath;//客戶(hù)請(qǐng)求的地址
		String webHome=(new ConfigUtils()).getConfigValue("rootPath");	
		System.out.println("配置文件中目錄:"+webHome);//輸出從配置文件中獲取的地址
		file=new File(webHome+getPath);
		if(file.exists())//如果文件存在就執(zhí)行
		{
		try {
			fis=new FileInputStream(file);
			byte[] buf=new byte[1024];
			int len=-1;
			while((len=fis.read(buf))!=-1)
			{
				//String str=buf.toString();
				//bw.write(str);//字符流寫(xiě)過(guò)去是一個(gè)地址，因?yàn)閷?xiě)過(guò)去之后需要瀏覽器解析,如果是圖片或者其他(圖片或視頻是字節(jié)流)的該怎么解析呢？
				//System.out.println(str);
				os.write(buf, 0, len);
			}
			bw.flush();
			os.flush();//os要不要關(guān)？？？
		} catch (IOException e) {
			e.printStackTrace();
		}finally
		{
			try {
				if(bw!=null)
				bw.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		}
	}
}

//設(shè)置響應(yīng)的狀態(tài)行 參數(shù)為String類(lèi)型
	public void setStatusLine(String statusCode)
	{
		String str=StatusCodeUtils.getStatusCodeValue(statusCode);
		//System.out.println(str+"------"+str.length());
		sbuffer.append("HTTP/1.1 "+statusCode+" "+str);
		setCRLF();
	}

package com.sample.utils;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;
public class StatusCodeUtils {
	private static Properties p;
	static 
	{
		InputStream in=null;
		p=new Properties();
		try {
			//讀了xx.properties文件
			in=StatusCodeUtils.class.getResourceAsStream("status_code.properties");
			//放置到p中，即放properties文件中的key,value
			p.load(in);
		} catch (IOException e) {
			e.printStackTrace();
		}
		finally
		{
			if(in!=null)
				try {
					in.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
		}
	}
	public static String getStatusCodeValue(String status)
	{ 
		return p.getProperty(status);
	}
	public static String getStatusCodeValue(int status)
	{ 
		return getStatusCodeValue(status+"");//沒(méi)有空格
	}
	/*public static void main(String[] args) {//輸出測(cè)試
	//Properties p=new Properties();
	// p.setProperty("rootPath","ddd");
	//System.out.println(p.get("rootPath"));
		System.out.println(getStatusCodeValue("304"));
		System.out.println(getStatusCodeValue("200"));
	}*/
}

//響應(yīng)正文
		String getPath= requestPath;//客戶(hù)請(qǐng)求的地址
		String webHome=(new ConfigUtils()).getConfigValue("rootPath");	
		System.out.println("配置文件中目錄:"+webHome);//輸出從配置文件中獲取的地址
		file=new File(webHome+getPath);

package com.sample.utils;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Properties;
public class ConfigUtils {
	private static Properties p;
	static 
	{
		InputStream in=null;
		OutputStream on=null;
		p=new Properties();
		try {
			//讀了xx.properties文件
			in=ConfigUtils.class.getResourceAsStream("config.properties");
			//放置到p中，即放properties文件中的key,value
			p.load(in);
		} catch (IOException e) {
			e.printStackTrace();
		}
		finally
		{
			if(in!=null)
				try {
					in.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
		}
	}
	public static String getConfigValue(String config)
	{ 
		return p.getProperty(config);
	}
	public static void main(String[] args) {//輸出測(cè)試
	//	Properties p=new Properties();
	//	p.setProperty("rootPath","ddd");
	//	System.out.println(p.get("rootPath"));
		System.out.println(getConfigValue("rootPath"));
	}
}

package com.sample.http;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
public class ServerTest {
	public static void main(String[] args) {
		//聲明變量
 ServerSocket ss=null;
 Socket s=null;
 boolean flag=true;
 try {
 	int port=10002;
 	System.out.println("Server Port:"+port);
					ss=new ServerSocket(port);
					//while(flag)
					{
						//接受客戶(hù)端發(fā)送過(guò)來(lái)的Socket
						s=ss.accept();
						HttpRequestImpl request=new HttpRequestImpl(s);							
						//	用于測(cè)試收到的信息
						System.out.println("獲取的路徑："+request.getRequestPath());
						System.out.println("獲取的："+request.getProtocol());
						System.out.println("獲取的："+request.getRequestMethod());
						System.out.println(request.getParameter("name"));
						System.out.println(request.getParameter("id"));					
						Map<String,String> m=request.getRequestHeader();
						Set<Entry<String,String>> set=m.entrySet();
						Iterator it=set.iterator();
						while(it.hasNext())
						{
							Entry entry=(Entry<String, String> )it.next();
							System.out.println(entry.getKey()+"----"+entry.getValue());
						}
					 //寫(xiě)響應(yīng)給瀏覽器
						/*
						 * 封裝：
						 * */
						//輸出流
						HttpResponseImpl response=new HttpResponseImpl(s);												
						response.setStatusLine(200);
						response.setContentType("text/html");
						response.printResponseHeader();
						response.setCRLF();
						response.printResponseHeader();
						response.printResponseContent(request.getRequestPath());
						//用于輸出信息
					}
				} catch (IOException e) {
					e.printStackTrace();
				}
	}
}