https://github.com/javahongxi

 https://coding.net/u/javahongxi/p/whatsmars-mars001/git

 https://code.csdn.net/javahongxi/whatsmars-mars001/tree/master 

HttpServer, Request, Response

Java代码  

1. package com.iteye.wely.server;  
2.   
3. import java.io.File;  
4. import java.io.IOException;  
5. import java.io.InputStream;  
6. import java.io.OutputStream;  
7. import java.net.InetAddress;  
8. import java.net.ServerSocket;  
9. import java.net.Socket;  
10.   
11. /** 
12.  * Created by shenhongxi on 16/3/21. 
13.  */  
14. public class HttpServer {  
15.   
16.     public static final String WEB_ROOT = System.getProperty("user.dir") + File.separator + "ixhong-tomcat-web/src/main/webapp";  
17.   
18.     private static final String SHUTDOWN_COMMAND = "SHUTDOWN";  
19.   
20.     private boolean shutdown = false;  
21.   
22.     public static void main(String[] args) {  
23.         HttpServer server = new HttpServer();  
24.         System.out.println(WEB_ROOT);  
25.         server.await();  
26.     }  
27.   
28.     private void await() {  
29.         ServerSocket serverSocket = null;  
30.         int port = 8080;  
31.         try {  
32.             serverSocket = new ServerSocket(port, 1, InetAddress.getByName("127.0.0.1"));  
33.             System.out.println("Server started!");  
34.         } catch (IOException e) {  
35.             e.printStackTrace();  
36.             System.exit(1);  
37.         }  
38.   
39.         while (!shutdown) {  
40.             Socket socket = null;  
41.             InputStream input = null;  
42.             OutputStream output = null;  
43.   
44.             try {  
45.                 socket = serverSocket.accept();  
46.                 input = socket.getInputStream();  
47.                 output = socket.getOutputStream();  
48.                 Request request = new Request(input);  
49.                 request.parse();  
50.   
51.                 Response response = new Response(output);  
52.                 response.setRequest(request);  
53.                 response.sendStaticResource();  
54.   
55.                 socket.close();  
56.   
57.                 shutdown = request.getUri().equals(SHUTDOWN_COMMAND);  
58.             } catch (Exception e) {  
59.                 e.printStackTrace();  
60.                 continue;  
61.             }  
62.         }  
63.     }  
64. }  

Java代码  

1. package com.iteye.wely.server;  
2.   
3. import java.io.IOException;  
4. import java.io.InputStream;  
5.   
6. /** 
7.  * Created by shenhongxi on 16/3/21. 
8.  */  
9. public class Request {  
10.   
11.     private InputStream input;  
12.   
13.     private String uri; // 性能考虑，用byte[]  
14.   
15.     public Request(InputStream input) {  
16.         this.input = input;  
17.     }  
18.   
19.     public void parse() {  
20.         StringBuffer request = new StringBuffer(2048);  
21.         int i;  
22.         byte[] buffer = new byte[2048];  
23.         try {  
24.             i = input.read(buffer);  
25.         } catch (IOException e) {  
26.             e.printStackTrace();  
27.             i = -1;  
28.         }  
29.         for (int j = 0; j < i; j++) {  
30.             request.append((char) buffer[j]);  
31.         }  
32.         System.out.println(request.toString());  
33.         uri = parseUri(request.toString());  
34.     }  
35.   
36.     private String parseUri(String requestStr) {  
37.         // GET /index.html HTTP/1.1  
38.         // Accept: text/plain; text/html  
39.         // ...  
40.         int index1 = requestStr.indexOf(' ');  
41.         int index2;  
42.         if (index1 != -1) {  
43.             index2 = requestStr.indexOf(' ', index1 + 1);  
44.             if (index2 > index1) {  
45.                 return requestStr.substring(index1 + 1, index2);  
46.             }  
47.         }  
48.         return null;  
49.     }  
50.   
51.     public String getUri() {  
52.         return uri;  
53.     }  
54. }  

Java代码  

1. package com.iteye.wely.server;  
2.   
3. import java.io.File;  
4. import java.io.FileInputStream;  
5. import java.io.IOException;  
6. import java.io.OutputStream;  
7.   
8. /** 
9.  * Created by shenhongxi on 16/3/21. 
10.  */  
11. public class Response {  
12.   
13.     private static final int BUFFER_SIZE = 1024;  
14.   
15.     Request request;  
16.   
17.     OutputStream output;  
18.   
19.     public void sendStaticResource() throws IOException {  
20.         byte[] bytes = new byte[BUFFER_SIZE];  
21.         FileInputStream fis = null;  
22.         try {  
23.             File file = new File(HttpServer.WEB_ROOT, request.getUri());  
24.             if (file.exists()) {  
25.                 fis = new FileInputStream(file);  
26.                 int ch = fis.read(bytes, 0, BUFFER_SIZE);  
27.                 while (ch != -1) {  
28.                     output.write(bytes, 0, ch);  
29.                     ch = fis.read(bytes, 0, BUFFER_SIZE);  
30.                 }  
31.             } else {  
32.                 String errorMsg = "HTTP/1.1 404 File Not Found\r\n" +  
33.                         "Content-Type: text/html\r\n" +  
34.                         "Content-Length: 23\r\n" +  
35.                         "\r\n" +  
36.                         "<h1>File Not Found</h1>";  
37.                 output.write(errorMsg.getBytes());  
38.             }  
39.         } catch (Exception e) {  
40.             e.printStackTrace();  
41.         } finally {  
42.             if (fis != null) {  
43.                 fis.close();  
44.             }  
45.         }  
46.     }  
47.   
48.     public Response(OutputStream output) {  
49.         this.output = output;  
50.     }  
51.   
52.     public void setRequest(Request request) {  
53.         this.request = request;  
54.     }  
55. }