<?xml version="1.0" encoding="UTF-8"?>
<request_and_responses>
	<!-- & 需要使用轉(zhuǎn)義字符 &amp; -->
		
	<request_and_response>
		<request>
			<method>GET</method>
			<path>/</path>
		</request>
		<response>
			<content_type>application/json</content_type>
			<value>I love you yesterday and today!</value>
		</response>
	</request_and_response>
	
	<request_and_response>
		<request>
			<method>GET</method>
			<path>/login?account=123&amp;pwd=456</path>
		</request>
		
		<response>
			<content_type>application/json</content_type>
			<value>success</value>
		</response>
	</request_and_response>
	
	<request_and_response>
		<request>
			<method>GET</method>
			<path>/query/龍</path>
		</request>
		<response>
			<content_type>application/json</content_type>
			<value>龍是中國等東亞國家古代神話傳說生活于海中的神異生物。</value>
		</response>
	</request_and_response>
	
	<request_and_response>
		<request>
			<method>POST</method>
			<path>/login</path>
			<param>account=123&amp;pwd=456</param>
		</request>
		
		<response>
			<content_type>application/json</content_type>
			<value>{"result":success}</value>
		</response>
	</request_and_response>
	
	
	<request_and_response>
		<request>
			<method>POST</method>
			<path>/login</path>
			<param>workId=12345</param>
		</request>
		
		<response>
			<content_type>application/json</content_type>
			<value>{"result":"success", "data":{"name":"李工", "sex":"男", "age":35}}</value>
		</response> 
	</request_and_response>
	
	
	<request_and_response>
		<request>
			<method>GET</method>
			<path>/pictures/husky.jpeg</path>
		</request>
		
		<response>
			<content_type>image/jpeg</content_type>
			<value>D:/DB/husky.jpeg</value>
		</response> 
	</request_and_response>
	
	<!-- 瀏覽器訪問時(shí)的圖標(biāo) -->
	<request_and_response>
		<request>
			<method>GET</method>
			<path>/favicon.ico</path>
		</request>
		
		<response>
			<content_type>image/webp</content_type>
			<value>D:/DB/favicon.ico</value>
		</response> 
	</request_and_response>
	
</request_and_responses>

package com.dragon;

public class RequestAndResponse {
	private String method;
	private String path;
	private String param;
	private String content_type;
	private String value;
	
	public String getMethod() {
		return method;
	}
	public void setMethod(String method) {
		this.method = method;
	}
	public String getPath() {
		return path;
	}
	public void setPath(String path) {
		this.path = path;
	}
	public String getParam() {
		return param;
	}
	public void setParam(String param) {
		this.param = param;
	}
	public String getContent_type() {
		return content_type;
	}
	public void setContent_type(String content_type) {
		this.content_type = content_type;
	}
	public String getValue() {
		return value;
	}
	public void setValue(String value) {
		this.value = value;
	}
	
	@Override
	public String toString() {
		return "RequestAndResponse [method=" + method + ", path=" + path + ", param=" + param + ", content_type="
				+ content_type + ", value=" + value + "]";
	}
}

package com.dragon;

import java.io.File;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

import org.dom4j.Document;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;

/**
 * 解析 xml 文件中配置的用戶請(qǐng)求和響應(yīng)數(shù)據(jù)。
 * */
public class RequestAndResponseResolver {
	private static final String method = "method";
	private static final String path = "path";
	private static final String param = "param";
	private static final String content_type = "content_type";
	private static final String value = "value";
	
	public static List<RequestAndResponse> listRequestAndResponse(String filePath) throws DocumentException{
		File file = new File(filePath); 
		SAXReader reader = new SAXReader();
		Document doc = reader.read(file);
		
		Element root = doc.getRootElement();
		//獲取根元素下面所有的子元素，利用迭代器方式
		Iterator<?> it = root.elementIterator();
		
		List<RequestAndResponse> requestAndResponses = new ArrayList<>();
		while (it.hasNext()) {
			//取出元素request_and_response
			Element e = (Element)it.next();
			//依次遍歷每一個(gè) request_and_response，獲取相應(yīng)的信息
			Element request = e.element("request");
			Element response = e.element("response");
			
			RequestAndResponse requestAndResponse = new RequestAndResponse();
			requestAndResponse.setMethod(request.elementText(method));
			requestAndResponse.setPath(request.elementText(path));
			requestAndResponse.setParam(request.elementText(param));   //GET 方式，這個(gè)屬性為 null
			requestAndResponse.setContent_type(response.elementText(content_type));
			requestAndResponse.setValue(response.elementText(value));
			
			requestAndResponses.add(requestAndResponse);
		}
		
		return requestAndResponses;
	}
}

	public void receive() {
		//使用線程池處理請(qǐng)求
		ExecutorService pool = Executors.newFixedThreadPool(THREAD_NUMBER);
		
		while (true) {
			try {
				Socket connection = server.accept();
				pool.submit(new UserConnection(connection));
			} catch (IOException e) {
				System.out.println(this.getDate()+" 用戶連接斷開");
				e.printStackTrace();
			}
		}
	}

package com.dragon;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Server {
	private static final int THREAD_NUMBER = 10;
	private ServerSocket server;
	private int port;
	
	public Server(int port) {
		this.port = port;
	}
	
	//啟動(dòng)服務(wù)。
	public void start() {
		try {
			server = new ServerSocket(port);
			System.out.println(this.getDate()+" 服務(wù)啟動(dòng)！");
			this.receive();
		} catch (IOException e) {
			System.out.println(this.getDate()+" 服務(wù)啟動(dòng)失敗！");
			e.printStackTrace();
		}
	}
	
	public void receive() {
		//使用線程池處理請(qǐng)求
		ExecutorService pool = Executors.newFixedThreadPool(THREAD_NUMBER);
		
		while (true) {
			try {
				Socket connection = server.accept();
				pool.submit(new UserConnection(connection));
			} catch (IOException e) {
				System.out.println(this.getDate()+" 用戶連接斷開");
				e.printStackTrace();
			}
		}
	}
	
	
	
	private String getDate() {
		String format = "yyyy-MM-dd HH:mm:ss";
		Date now = new Date();
		SimpleDateFormat dateFormat = new SimpleDateFormat(format);
		return dateFormat.format(now);
	}
}

in = connection.getInputStream();
out = connection.getOutputStream();
			
//這個(gè)數(shù)字是隨便設(shè)置的，因?yàn)橐淮涡宰x取整個(gè)請(qǐng)求報(bào)文，不能太小。（但是其實(shí)這個(gè)也很大了）
byte[] b = new byte[5*1024];
BufferedInputStream input = new BufferedInputStream(in);
int count = input.read(b);
String requestMessage = new String(b, 0, count);
System.out.println("====================報(bào)文分隔符上界===================");
System.out.println(requestMessage);
System.out.println("====================報(bào)文分隔符下界===================");

// 初始化配置好的信息
	static {
		try {
			requestAndResponses = RequestAndResponseResolver.listRequestAndResponse("./src/com/dragon/request_and_response.xml");
		} catch (DocumentException e) {
			e.printStackTrace();
		}
	}

if ("GET".compareTo(method) == 0) {
	for (RequestAndResponse r : requestAndResponses) {
		//這里需要對(duì) get 方式時(shí)的請(qǐng)求進(jìn)行解碼，因?yàn)橐恍┓?ASCII 碼字符會(huì)被編碼，比如漢字。
		path = URLDecoder.decode(path, ENCODE);
		if (r.getMethod().equals(method) && r.getPath().equals(path)) {
			content_type = r.getContent_type();
			value = r.getValue();
			break;
		}
	}
} else {
	//POST 方式，請(qǐng)求參數(shù)是在請(qǐng)求體中的，請(qǐng)求頭和請(qǐng)求體中間有一個(gè)換行符。
	String param = requestMessage.substring(requestMessage.lastIndexOf(CRLF) + 2); //這里是不包括 CRLF 的兩個(gè)字符的。
	for (RequestAndResponse r : requestAndResponses) {                 //因?yàn)檫@個(gè)get方式的 參數(shù)為空，所以這里必須是 param 在前。
		if (r.getMethod().equals(method) && r.getPath().equals(path) && param.equals(r.getParam())) {
			content_type = r.getContent_type();
			value = r.getValue();
			break;
		}
	}
}

String str = "我愛你";
String en_str = java.net.URLEncoder.encode(str, "UTF-8");
String de_str = java.net.URLDecoder.decode(en_str, "UTF-8");
System.out.println("編碼字符：" + en_str);
System.out.println("解碼字符：" + de_str);

	//這里我只處理字符串類和文件類兩種響應(yīng)體
	//響應(yīng)體
	int len = 0;
	String responseBody = null;   //響應(yīng)值是 json 數(shù)據(jù)
	File file = null; //響應(yīng)值是 文件
	if (content_type.equals("application/json")) {  //如果是 json 數(shù)據(jù)，否則就是 文件類數(shù)據(jù)（圖片、文檔或其它文件）
		 responseBody = value;
		 len = responseBody.getBytes().length;   //響應(yīng)體的字節(jié)數(shù)，注意是字節(jié)數(shù)！
	} else {
		 file = new File(value);
		 len = (int) file.length();
	}

	//響應(yīng)頭
	responseHeader.append("HTTP/1.1").append(BLANK);
	responseHeader.append(200).append(BLANK);
	responseHeader.append("OK").append(CRLF);
	responseHeader.append("Server:"+"CrazyDragon").append(CRLF);
	responseHeader.append("Date:").append(BLANK).append(date).append(CRLF);
	responseHeader.append("Content-Type:").append(BLANK).append(content_type).append(CRLF);
	responseHeader.append("Content-Length:").append(BLANK).append(len).append(CRLF);
	responseHeader.append(CRLF);
	
	//如果 字符串變量 responseBody 不為空，則說明返回值是 json 數(shù)據(jù)（字符串）
	//否則就是文件類的流了。
	if (responseBody != null) {
		String response = responseHeader.toString() + responseBody;
		out.write(response.getBytes("UTF-8"));    
	} else {
		out.write(responseHeader.toString().getBytes("UTF-8"));  
		
		int hasRead = 0;
		byte[] data = new byte[4*1024];
		try (BufferedInputStream inputStream = new BufferedInputStream(new FileInputStream(file))) {
			while ((hasRead = inputStream.read(data)) != -1) {
				out.write(data, 0, hasRead);
			}
		}
	}
	out.flush();   //必要的刷新流操作。

package com.dragon;

import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.URLDecoder;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Locale;
import java.util.TimeZone;

import org.dom4j.DocumentException;

public class UserConnection implements Runnable{
	private static final String BLANK = " ";
	private static final String CRLF = "\r\n"; //換行符，不能寫反了！
	private static final String ENCODE = "UTF-8";
	private static final String default_content_type = "application/json";   //當(dāng)任何匹配路徑都沒有時(shí)。
	private static final String default_value = "404 NOT FOUND！\n沒有找到你配置的請(qǐng)求！";
	
	
	private static List<RequestAndResponse> requestAndResponses;
	private Socket connection;
	
	
	// 初始化配置好的信息
	static {
		try {
			requestAndResponses = RequestAndResponseResolver.listRequestAndResponse("./src/com/dragon/request_and_response.xml");
		} catch (DocumentException e) {
			e.printStackTrace();
		}
	}
	
	
	
	public UserConnection(Socket connection) {
		this.connection = connection;
	}
	
	@Override
	public void run() {
		InputStream in = null;
		OutputStream out = null;
		try {
			in = connection.getInputStream();
			out = connection.getOutputStream();
			
			//這個(gè)數(shù)字是隨便設(shè)置的，因?yàn)橐淮涡宰x取整個(gè)請(qǐng)求報(bào)文，不能太小。（但是其實(shí)這個(gè)也很大了）
			byte[] b = new byte[5*1024];
			BufferedInputStream input = new BufferedInputStream(in);
			int count = input.read(b);
			String requestMessage = new String(b, 0, count);
			System.out.println("====================報(bào)文分隔符上界===================");
			System.out.println(requestMessage);
			System.out.println("====================報(bào)文分隔符下界===================");

			//以第一個(gè) 換行符 CRLF 為界限取出 請(qǐng)求路徑和請(qǐng)求參數(shù)
			String requestLine = requestMessage.substring(0, requestMessage.indexOf(CRLF));
			String[] line = requestLine.split("\\s");
			String method = line[0];  //考慮大小寫。
			String path = line[1];  
			//這個(gè)數(shù)組是有三個(gè)元素，最后一個(gè)是 協(xié)議的版本，這里不需要，就不處理了。
			String content_type = default_content_type;
			String value = default_value;
			if ("GET".compareTo(method) == 0) {
			//	System.out.println("請(qǐng)求方式：" + method + " 請(qǐng)求路徑（含參數(shù)）：" + path);
				for (RequestAndResponse r : requestAndResponses) {
					//這里需要對(duì) get 方式時(shí)的請(qǐng)求進(jìn)行解碼，因?yàn)橐恍┓?ASCII 碼字符會(huì)被編碼，比如漢字。
					path = URLDecoder.decode(path, ENCODE);
					if (r.getMethod().equals(method) && r.getPath().equals(path)) {
						content_type = r.getContent_type();
						value = r.getValue();
						break;
					}
				}
			} else {
				//POST 方式，請(qǐng)求參數(shù)是在請(qǐng)求體中的，請(qǐng)求頭和請(qǐng)求體中間有一個(gè)換行符。
				String param = requestMessage.substring(requestMessage.lastIndexOf(CRLF) + 2); //這里是不包括 CRLF 的兩個(gè)字符的。
				for (RequestAndResponse r : requestAndResponses) {                 //因?yàn)檫@個(gè)get方式的 參數(shù)為空，所以這里必須是 param 在前。
					if (r.getMethod().equals(method) && r.getPath().equals(path) && param.equals(r.getParam())) {
						content_type = r.getContent_type();
						value = r.getValue();
						System.out.println(content_type+" "+value);
						break;
					}
				}
			}
		
			StringBuilder responseHeader = new StringBuilder();
			String date = this.getDate();
			
			
			//這里我只處理字符串類和文件類兩種響應(yīng)體
			//響應(yīng)體
			int len = 0;
			String responseBody = null;   //響應(yīng)值是 json 數(shù)據(jù)
			File file = null; //響應(yīng)值是 文件
			if (content_type.equals("application/json")) {  //如果是 json 數(shù)據(jù)，否則就是 文件類數(shù)據(jù)（圖片、文檔或其它文件）
				 responseBody = value;
				 len = responseBody.getBytes().length;   //響應(yīng)體的字節(jié)數(shù)，注意是字節(jié)數(shù)！
			} else {
				 file = new File(value);
				 len = (int) file.length();
			}
			
			//響應(yīng)頭
			responseHeader.append("HTTP/1.1").append(BLANK);
			responseHeader.append(200).append(BLANK);
			responseHeader.append("OK").append(CRLF);
			responseHeader.append("Server:"+"CrazyDragon").append(CRLF);
			responseHeader.append("Date:").append(BLANK).append(date).append(CRLF);
			responseHeader.append("Content-Type:").append(BLANK).append(content_type).append(CRLF);
			responseHeader.append("Content-Length:").append(BLANK).append(len).append(CRLF);
			responseHeader.append(CRLF);
			
			//如果 字符串變量 responseBody 不為空，則說明返回值是 json 數(shù)據(jù)（字符串）
			//否則就是文件類的流了。
			if (responseBody != null) {
				String response = responseHeader.toString() + responseBody;
				out.write(response.getBytes("UTF-8"));    
			} else {
				out.write(responseHeader.toString().getBytes("UTF-8"));  
				
				int hasRead = 0;
				byte[] data = new byte[4*1024];
				try (BufferedInputStream inputStream = new BufferedInputStream(new FileInputStream(file))) {
					while ((hasRead = inputStream.read(data)) != -1) {
						out.write(data, 0, hasRead);
					}
				}
			}
			out.flush();   //必要的刷新流操作。
		} catch (IOException e) {
			e.printStackTrace();
		} finally {
			try {
				if (in != null)
					in.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
	
	private String getDate() {
		Date date = new Date();
		SimpleDateFormat format = new SimpleDateFormat("EEE, d MMM yyyy HH:mm:ss 'GMT'", Locale.CHINA);
		format.setTimeZone(TimeZone.getTimeZone("GMT")); // 設(shè)置時(shí)區(qū)為GMT  
		return format.format(date);
	}
}

package com.dragon;

public class Main {
	public static void main(String[] args) {
		Server server = new Server(9000);
		server.start();		
	}
}