一个简单的web服务器

  1. 云栖社区>
  2. 博客>
  3. 正文

一个简单的web服务器

javahongxi 2016-04-10 17:17:53 浏览1144
展开阅读全文

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. }  

网友评论

登录后评论
0/500
评论
javahongxi
+ 关注