tomcat.connector

whatsmars-tomcat-web/src/main/java/com/whatsmars/tomcat/web/server/Request.java

-package com.whatsmars.tomcat.web.server;
-
-import java.io.IOException;
-import java.io.InputStream;
-
-/**
- * Created by shenhongxi on 16/3/21.
- */
-public class Request {
-
-    private InputStream input;
-
-    private String uri; // 性能考虑，用byte[]
-
-    public Request(InputStream input) {
-        this.input = input;
-    }
-
-    public void parse() {
-        StringBuffer request = new StringBuffer(2048);
-        int i;
-        byte[] buffer = new byte[2048];
-        try {
-            i = input.read(buffer);
-        } catch (IOException e) {
-            e.printStackTrace();
-            i = -1;
-        }
-        for (int j = 0; j < i; j++) {
-            request.append((char) buffer[j]);
-        }
-        System.out.println(request.toString());
-        uri = parseUri(request.toString());
-    }
-
-    private String parseUri(String requestStr) {
-        // GET /index.html HTTP/1.1
-        // Accept: text/plain; text/html
-        // ...
-        int index1 = requestStr.indexOf(' ');
-        int index2;
-        if (index1 != -1) {
-            index2 = requestStr.indexOf(' ', index1 + 1);
-            if (index2 > index1) {
-                return requestStr.substring(index1 + 1, index2);
-            }
-        }
-        return null;
-    }
-
-    public String getUri() {
-        return uri;
-    }
-}

whatsmars-tomcat-web/src/main/java/com/whatsmars/tomcat/web/server/Response.java

-package com.whatsmars.tomcat.web.server;
-
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.IOException;
-import java.io.OutputStream;
-
-/**
- * Created by shenhongxi on 16/3/21.
- */
-public class Response {
-
-    private static final int BUFFER_SIZE = 1024;
-
-    Request request;
-
-    OutputStream output;
-
-    public void sendStaticResource() throws IOException {
-        byte[] bytes = new byte[BUFFER_SIZE];
-        FileInputStream fis = null;
-        try {
-            File file = new File(HttpServer.WEB_ROOT, request.getUri());
-            if (file.exists()) {
-                fis = new FileInputStream(file);
-                int ch = fis.read(bytes, 0, BUFFER_SIZE);
-                while (ch != -1) {
-                    output.write(bytes, 0, ch);
-                    ch = fis.read(bytes, 0, BUFFER_SIZE);
-                }
-            } else {
-                String errorMsg = "HTTP/1.1 404 File Not Found\r\n" +
-                        "Content-Type: text/html\r\n" +
-                        "Content-Length: 23\r\n" +
-                        "\r\n" +
-                        "<h1>File Not Found</h1>";
-                output.write(errorMsg.getBytes());
-            }
-        } catch (Exception e) {
-            e.printStackTrace();
-        } finally {
-            if (fis != null) {
-                fis.close();
-            }
-        }
-    }
-
-    public Response(OutputStream output) {
-        this.output = output;
-    }
-
-    public void setRequest(Request request) {
-        this.request = request;
-    }
-}

whatsmars-tomcat/src/main/java/com/whatsmars/tomcat/connector/Bootstrap.java

+package com.whatsmars.tomcat.connector;
+
+/**
+ * Created by shenhongxi on 16/4/11.
+ */
+public final class Bootstrap {
+
+    public static void main(String[] args) {
+        HttpConnector connector = new HttpConnector();
+        connector.start();
+    }
+}

whatsmars-tomcat-web/src/main/java/com/whatsmars/tomcat/web/server/HttpServer.java → whatsmars-tomcat/src/main/java/com/whatsmars/tomcat/connector/HttpConnector.java

-package com.whatsmars.tomcat.web.server;
+package com.whatsmars.tomcat.connector;
 
-import java.io.File;
 import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
 import java.net.InetAddress;
 import java.net.ServerSocket;
 import java.net.Socket;
 
 /**
- * Created by shenhongxi on 16/3/21.
+ * Created by shenhongxi on 16/4/11.
  */
-public class HttpServer {
+public class HttpConnector implements Runnable {
 
-    public static final String WEB_ROOT = System.getProperty("user.dir") + File.separator + "ixhong-tomcat-web/src/main/webapp";
+    boolean stopped;
 
-    private static final String SHUTDOWN_COMMAND = "SHUTDOWN";
+    private String scheme = "http";
 
-    private boolean shutdown = false;
-
-    public static void main(String[] args) {
-        HttpServer server = new HttpServer();
-        System.out.println(WEB_ROOT);
-        server.await();
-    }
-
-    private void await() {
+    public void run() {
         ServerSocket serverSocket = null;
         int port = 8080;
         try {
             serverSocket = new ServerSocket(port, 1, InetAddress.getByName("127.0.0.1"));
-            System.out.println("Server started!");
         } catch (IOException e) {
             e.printStackTrace();
             System.exit(1);
         }
-
-        while (!shutdown) {
+        while (!stopped) {
+            // Accept the next incoming connection from the server socket
             Socket socket = null;
-            InputStream input = null;
-            OutputStream output = null;
-
             try {
                 socket = serverSocket.accept();
-                input = socket.getInputStream();
-                output = socket.getOutputStream();
-                Request request = new Request(input);
-                request.parse();
-
-                Response response = new Response(output);
-                response.setRequest(request);
-                response.sendStaticResource();
-
-                socket.close();
-
-                shutdown = request.getUri().equals(SHUTDOWN_COMMAND);
             } catch (Exception e) {
-                e.printStackTrace();
                 continue;
             }
+            // Hand this socket off to an HttpProcessor
+            HttpProcessor processor = new HttpProcessor(this);
+            processor.process(socket);
         }
     }
+
+    public void start() {
+        new Thread(this).start();
+    }
+
+    public String getScheme() {
+        return scheme;
+    }
 }

whatsmars-tomcat/src/main/java/com/whatsmars/tomcat/connector/HttpProcessor.java

+package com.whatsmars.tomcat.connector;
+
+import java.io.OutputStream;
+import java.net.Socket;
+
+/**
+ * Created by shenhongxi on 16/4/11.
+ */
+public class HttpProcessor {
+
+    private HttpConnector connector;
+
+    public HttpProcessor(HttpConnector connector) {
+        this.connector = connector;
+    }
+
+    public void process(Socket socket) {
+        SocketInputStream input = null;
+        OutputStream output = null;
+        try {
+            input = new SocketInputStream(socket.getInputStream(), 2048);
+            output = socket.getOutputStream();
+
+            // create HttpRequest object and parse
+
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+}

whatsmars-tomcat/src/main/java/com/whatsmars/tomcat/connector/HttpRequest.java

+package com.whatsmars.tomcat.connector;
+
+/**
+ * Created by shenhongxi on 16/4/11.
+ */
+public class HttpRequest {
+}

whatsmars-tomcat/src/main/java/com/whatsmars/tomcat/connector/HttpResponse.java

+package com.whatsmars.tomcat.connector;
+
+/**
+ * Created by shenhongxi on 16/4/11.
+ */
+public class HttpResponse {
+}

whatsmars-tomcat/src/main/java/com/whatsmars/tomcat/connector/SocketInputStream.java

+package com.whatsmars.tomcat.connector;
+
+import java.io.InputStream;
+
+/**
+ * Created by shenhongxi on 16/4/11.
+ */
+public class SocketInputStream {
+
+    private InputStream input;
+
+    private int size;
+
+    public SocketInputStream(InputStream input, int size) {
+        this.input = input;
+        this.size = size;
+    }
+}