init

Author: Drincann

.gitignore

@@ -0,0 +1,10 @@
+# Default ignored files
+/shelf/
+/.idea/workspace.xml
+# Datasource local storage ignored files
+/dataSources/
+/dataSources.local.xml
+# 基于编辑器的 HTTP 客户端请求
+/httpRequests/
+
+out

.idea/description.html

@@ -0,0 +1,15 @@
+import cool.gaolihai.Angie;
+
+public class app {
+    public static void main(String[] args) {
+        Angie app = new Angie();
+
+        app.use("/test", (req, res) -> {
+            res.setStatus(200)
+                    .setHeaders("Content-Type", "text/html")
+                    .send("<h1> Hello, web framework! </h1>");
+        });
+
+        app.listen(80);
+    }
+}

.idea/encodings.xml

@@ -0,0 +1,38 @@
+package cool.gaolihai;
+
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.util.HashMap;
+
+public class Angie {
+    private final HashMap<String, Processor> routeMap = new HashMap();
+
+    public void use(String route, Processor processor) {
+        routeMap.put(route, processor);
+    }
+
+    public void listen(int port) {
+        try {
+            ServerSocket serverSocket = new ServerSocket(port);
+            while (true) {
+                Socket client = serverSocket.accept();
+                new Thread(() -> {
+                    try {
+                        Request request = new Request(client.getInputStream());
+                        Response response = new Response(client.getOutputStream());
+                        if (routeMap.containsKey(request.getUrl())) {
+                            routeMap.get(request.getUrl()).callback(request, response);
+                        } else {
+                            response.setStatus(404).send(request.getUrl() + " not found");
+                        }
+                    } catch (IOException e) {
+                        e.printStackTrace();
+                    }
+                }).start();
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}

.idea/misc.xml

@@ -0,0 +1,6 @@
+package cool.gaolihai;
+
+@FunctionalInterface
+public interface Processor {
+    void callback(Request request, Response response);
+}

.idea/modules.xml

@@ -0,0 +1,43 @@
+package cool.gaolihai;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+
+public class Request {
+
+    private String url;
+    private String params;
+    private String method;
+
+    public Request(InputStream inputStream){
+        try {
+            String[] requestLine =  new BufferedReader(new InputStreamReader(inputStream)).readLine().split(" ");
+            if (requestLine.length == 3 && requestLine[2].equals("HTTP/1.1")) {
+                this.method = requestLine[0];
+                String allUrl = requestLine[1];
+                if (allUrl.contains("?")) {
+                    this.url = allUrl.substring(0, allUrl.indexOf("?"));
+                    this.params = allUrl.substring(allUrl.indexOf("?") + 1);
+                } else {
+                    this.url = allUrl;
+                }
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    public String getUrl() {
+        return url;
+    }
+
+    public String getParams() {
+        return params;
+    }
+
+    public String getMethod() {
+        return method;
+    }
+}

.idea/project-template.xml

@@ -0,0 +1,43 @@
+package cool.gaolihai;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.util.HashMap;
+
+public class Response {
+    private OutputStream outputStream;
+    private HashMap<String, String> headers = new HashMap<>();
+    private int status;
+
+    public Response(OutputStream outputStream) {
+        this.outputStream = outputStream;
+    }
+
+    public Response setHeaders(String key, String value) {
+        this.headers.put(key, value);
+        return this;
+    }
+
+    public Response setStatus(int statusCode) {
+        this.status = statusCode;
+        return this;
+    }
+
+    public void send(String data) {
+        try {
+            StringBuilder dataBuilder = new StringBuilder();
+            dataBuilder.append("HTTP/1.1 ").append(this.status).append("\n");
+            for (String key:
+                 this.headers.keySet()) {
+                dataBuilder.append(key).append(": ").append(this.headers.get(key)).append("\n");
+            }
+            dataBuilder.append("\n").append(data);
+
+            outputStream.write(dataBuilder.toString().getBytes());
+            outputStream.flush();
+            outputStream.close();
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+}

.idea/uiDesigner.xml

@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" inherit-compiler-output="true">
+    <exclude-output />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>
+