用java socket實(shí)現(xiàn)了一個(gè)簡(jiǎn)單的httpserver， 能夠處理GET, POST,以及帶一個(gè)附件的multipart類型的POST。盡管中途遇到了非常多問題， 只是通過在論壇和幾個(gè)高手交流了一下，問題都攻克了。假設(shè)你認(rèn)為程序有些地方看不明確,能夠參看這個(gè)帖子:http://topic.csdn.net/u/20090625/22/59a5bfc8-a6b6-445d-9829-ea6d462a4fe6.html .

盡管解析http頭不是非常規(guī)范，本來(lái)應(yīng)該用原始的字節(jié)流， 我採(cǎi)用了一個(gè)折衷的方案，用DataInputStream.

本代碼的有用性==0，可是能夠幫助非常好地了解http協(xié)議，然后其它的應(yīng)用層協(xié)議大都如此。

假設(shè)你從來(lái)都沒有了解過http協(xié)議，建議先搜索閱讀一下，或者你還能夠用以下的代碼來(lái)簡(jiǎn)單的看一看究竟瀏覽器和server之間都相互發(fā)送了什么數(shù)據(jù)。

MyHttpClient.java: 模擬瀏覽器的行為， 向server發(fā)送get/post請(qǐng)求，然后打印出server返回的消息。這樣就能夠查看當(dāng)一個(gè)請(qǐng)求到來(lái)之后， server究竟都給瀏覽器發(fā)送了哪些消息。

package socket; import java.io.*; import java.net.*; public class MyHttpClient { public static void main(String[] args) throws Exception{ InetAddress inet = InetAddress.getByName("www.baidu.com"); System.out.println(inet.getHostAddress()); Socket socket = new Socket(inet.getHostAddress(),80); InputStream in = socket.getInputStream(); OutputStream out = socket.getOutputStream(); BufferedReader reader = new BufferedReader(new InputStreamReader(in)); PrintWriter writer = new PrintWriter(out); writer.println("GET /home.html HTTP/1.1");//home.html是關(guān)于百度的頁(yè)面 writer.println("Accept: image/gif, image/x-xbitmap, image/jpeg, image/pjpeg, application/x-shockwave-flash, application/xaml+xml, application/vnd.ms-xpsdocument, application/x-ms-xbap, application/x-ms-application, application/msword, application/vnd.ms-excel, application/vnd.ms-powerpoint, */*"); writer.println("Accept-Language: en-us,zh-cn;q=0.5"); writer.println("Accept-Encoding: gzip, deflate"); writer.println("Host: www.baidu.com"); writer.println("User-Agent: Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1; SV1; .NET CLR 1.1.4322; .NET CLR 2.0.50727; .NET CLR 3.0.04506.30; .NET CLR 3.0.4506.2152; .NET CLR 3.5.30729)"); writer.println("Connection: Keep-Alive"); writer.println(); writer.flush(); String line = reader.readLine(); while(line!=null){ System.out.println(line); line = reader.readLine(); } reader.close(); writer.close(); } }

MyServer.java: 模擬server端接收瀏覽器的請(qǐng)求，然后把整個(gè)請(qǐng)求的報(bào)文打印出來(lái)。程序執(zhí)行之后直接用瀏覽器測(cè)試。

package socket; import java.io.*; import java.net.*; public class MyServer { public static void main(String[] args) throws IOException{ ServerSocket svrSocket = new ServerSocket(8080); while(true){ Socket socket = svrSocket.accept(); //足夠大的一個(gè)緩沖區(qū) byte[] buf = new byte[1024*1024]; InputStream in = socket.getInputStream(); int byteRead = in.read(buf, 0, 1024*1024); String dataString = new String(buf, 0, byteRead); System.out.println(dataString); in.close(); socket.close(); } } }

主程序MyHttpServer.

package socket; import java.io.*; import java.net.*; /** * MyHttpServer 實(shí)現(xiàn)一個(gè)簡(jiǎn)單的HTTPserver端，能夠獲取用戶提交的內(nèi)容 * 并給用戶一個(gè)response * 由于時(shí)間的關(guān)系，對(duì)http頭的處理顯得不規(guī)范 * 對(duì)于上傳附件，臨時(shí)僅僅能解析僅僅上傳一個(gè)附件并且附件位置在第一個(gè)的情況 * 轉(zhuǎn)載請(qǐng)注明來(lái)自http://blog.csdn.net/sunxing007 * **/ public class MyHttpServer { //server根文件夾，post.html, upload.html都放在該位置 public static String WEB_ROOT = "c:/root"; //port private int port; //用戶請(qǐng)求的文件的url private String requestPath; //mltipart/form-data方式提交post的分隔符, private String boundary = null; //post提交請(qǐng)求的正文的長(zhǎng)度 private int contentLength = 0; public MyHttpServer(String root, int port) { WEB_ROOT = root; this.port = port; requestPath = null; } //處理GET請(qǐng)求 private void doGet(DataInputStream reader, OutputStream out) throws Exception { if (new File(WEB_ROOT + this.requestPath).exists()) { //從server根文件夾下找到用戶請(qǐng)求的文件并發(fā)送回瀏覽器 InputStream fileIn = new FileInputStream(WEB_ROOT + this.requestPath); byte[] buf = new byte[fileIn.available()]; fileIn.read(buf); out.write(buf); out.close(); fileIn.close(); reader.close(); System.out.println("request complete."); } } //處理post請(qǐng)求 private void doPost(DataInputStream reader, OutputStream out) throws Exception { String line = reader.readLine(); while (line != null) { System.out.println(line); line = reader.readLine(); if ("".equals(line)) { break; } else if (line.indexOf("Content-Length") != -1) { this.contentLength = Integer.parseInt(line.substring(line.indexOf("Content-Length") + 16)); } //表明要上傳附件， 跳轉(zhuǎn)到doMultiPart方法。 else if(line.indexOf("multipart/form-data")!= -1){ //得multiltipart的分隔符 this.boundary = line.substring(line.indexOf("boundary") + 9); this.doMultiPart(reader, out); return; } } //繼續(xù)讀取普通post（沒有附件）提交的數(shù)據(jù) System.out.println("begin reading posted data......"); String dataLine = null; //用戶發(fā)送的post數(shù)據(jù)正文 byte[] buf = {}; int size = 0; if (this.contentLength != 0) { buf = new byte[this.contentLength]; while(size<this.contentLength){ int c = reader.read(); buf[size++] = (byte)c; } System.out.println("The data user posted: " + new String(buf, 0, size)); } //發(fā)送回瀏覽器的內(nèi)容 String response = ""; response += "HTTP/1.1 200 OK/n"; response += "Server: Sunpache 1.0/n"; response += "Content-Type: text/html/n"; response += "Last-Modified: Mon, 11 Jan 1998 13:23:42 GMT/n"; response += "Accept-ranges: bytes"; response += "/n"; String body = "<html><head><title>test server</title></head><body><p>post ok:</p>" + new String(buf, 0, size) + "</body></html>"; System.out.println(body); out.write(response.getBytes()); out.write(body.getBytes()); out.flush(); reader.close(); out.close(); System.out.println("request complete."); } //處理附件 private void doMultiPart(DataInputStream reader, OutputStream out) throws Exception { System.out.println("doMultiPart ......"); String line = reader.readLine(); while (line != null) { System.out.println(line); line = reader.readLine(); if ("".equals(line)) { break; } else if (line.indexOf("Content-Length") != -1) { this.contentLength = Integer.parseInt(line.substring(line.indexOf("Content-Length") + 16)); System.out.println("contentLength: " + this.contentLength); } else if (line.indexOf("boundary") != -1) { //獲取multipart分隔符 this.boundary = line.substring(line.indexOf("boundary") + 9); } } System.out.println("begin get data......"); /*以下的凝視是一個(gè)瀏覽器發(fā)送帶附件的請(qǐng)求的全文，全部中文都是說明性的文字***** <HTTP頭部?jī)?nèi)容略> ............ Cache-Control: no-cache <這里有一個(gè)空行，表明接下來(lái)的內(nèi)容都是要提交的正文> -----------------------------7d925134501f6<這是multipart分隔符> Content-Disposition: form-data; name="myfile"; filename="mywork.doc" Content-Type: text/plain <附件正文>........................................ ................................................. -----------------------------7d925134501f6<這是multipart分隔符> Content-Disposition: form-data; name="myname"<其它字段或附件> <這里有一個(gè)空行> <其它字段或附件的內(nèi)容> -----------------------------7d925134501f6--<這是multipart分隔符，最后一個(gè)分隔符多兩個(gè)-> ****************************************************************/ /** * 上面的凝視是一個(gè)帶附件的multipart類型的POST的全文模型， * 要把附件去出來(lái)，就是要找到附件正文的起始位置和結(jié)束位置 * **/ if (this.contentLength != 0) { //把全部的提交的正文，包含附件和其它字段都先讀到buf. byte[] buf = new byte[this.contentLength]; int totalRead = 0; int size = 0; while (totalRead < this.contentLength) { size = reader.read(buf, totalRead, this.contentLength - totalRead); totalRead += size; } //用buf構(gòu)造一個(gè)字符串，能夠用字符串方便的計(jì)算出附件所在的位置 String dataString = new String(buf, 0, totalRead); System.out.println("the data user posted:/n" + dataString); int pos = dataString.indexOf(boundary); //下面略過4行就是第一個(gè)附件的位置 pos = dataString.indexOf("/n", pos) + 1; pos = dataString.indexOf("/n", pos) + 1; pos = dataString.indexOf("/n", pos) + 1; pos = dataString.indexOf("/n", pos) + 1; //附件開始位置 int start = dataString.substring(0, pos).getBytes().length; pos = dataString.indexOf(boundary, pos) - 4; //附件結(jié)束位置 int end = dataString.substring(0, pos).getBytes().length; //下面找出filename int fileNameBegin = dataString.indexOf("filename") + 10; int fileNameEnd = dataString.indexOf("/n", fileNameBegin); String fileName = dataString.substring(fileNameBegin, fileNameEnd); /** * 有時(shí)候上傳的文件顯示完整的文件名稱路徑,比方c:/my file/somedir/project.doc * 但有時(shí)候僅僅顯示文件的名字，比方myphoto.jpg. * 所以須要做一個(gè)推斷。 */ if(fileName.lastIndexOf("//")!=-1){ fileName = fileName.substring(fileName.lastIndexOf("//") + 1); } fileName = fileName.substring(0, fileName.length()-2); OutputStream fileOut = new FileOutputStream("c://" + fileName); fileOut.write(buf, start, end-start); fileOut.close(); fileOut.close(); } String response = ""; response += "HTTP/1.1 200 OK/n"; response += "Server: Sunpache 1.0/n"; response += "Content-Type: text/html/n"; response += "Last-Modified: Mon, 11 Jan 1998 13:23:42 GMT/n"; response += "Accept-ranges: bytes"; response += "/n"; out.write("<html><head><title>test server</title></head><body><p>Post is ok</p></body></html>".getBytes()); out.flush(); reader.close(); System.out.println("request complete."); } public void service() throws Exception { ServerSocket serverSocket = new ServerSocket(this.port); System.out.println("server is ok."); //開啟serverSocket等待用戶請(qǐng)求到來(lái)，然后依據(jù)請(qǐng)求的類別作處理 //在這里我僅僅針對(duì)GET和POST作了處理 //當(dāng)中POST具有解析單個(gè)附件的能力 while (true) { Socket socket = serverSocket.accept(); System.out.println("new request coming."); DataInputStream reader = new DataInputStream((socket.getInputStream())); String line = reader.readLine(); String method = line.substring(0, 4).trim(); OutputStream out = socket.getOutputStream(); this.requestPath = line.split(" ")[1]; System.out.println(method); if ("GET".equalsIgnoreCase(method)) { System.out.println("do get......"); this.doGet(reader, out); } else if ("POST".equalsIgnoreCase(method)) { System.out.println("do post......"); this.doPost(reader, out); } socket.close(); System.out.println("socket closed."); } } public static void main(String args[]) throws Exception { MyHttpServer server = new MyHttpServer("c:/root", 8080); server.service(); } }

測(cè)試文件post.html, upload.html都放在上面程序定義的WEB_ROOT以下。

post.html:處理普通的post請(qǐng)求

<html> <head> <title>test my server</title> <meta http-equiv="Content-Type" content="text/html; charset=utf-8"> </head> <body> <p>upload</p> 來(lái)自http://blog.csdn.net/sunxing007<br> <form name="UploadForm" method="post" action="http://localhost:8080/"> <input type="text" name="myname" /><br> <select name="myage"> <option value="18">18</option> <option value="20">20</option> <option value="22">22</option> </select><br> <input type="submit"value="Sutmit"> </form> </body> </html>

upload.html:測(cè)試帶附件的post請(qǐng)求

<head> <title>my page</title> <style> table{ border-collapse: collapse; } </style> </head> <body> 來(lái)自http://blog.csdn.net/sunxing007<br> <form action='http://localhost:8080/' method='post' enctype='multipart/form-data'> file: <input type='file' name='myfile' /><br> <input type='submit' /> </form> </body> </html>

一切準(zhǔn)備妥當(dāng),而且MyHttpServer執(zhí)行之后, 在瀏覽器輸入http://localhost:8080/post.html和http://localhost:8080/upload.html就可以進(jìn)行測(cè)試.

轉(zhuǎn)載請(qǐng)注明來(lái)自http://blog.csdn.net/sunxing007

總結(jié)

以上是生活随笔為你收集整理的JAVA实现HTTPserver端的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。