whatsmars-tomcat-web

pom.xml

@@ -16,6 +16,7 @@
         <module>whatsmars-mars001-web</module>
         <module>whatsmars-fs-web</module>
         <module>whatsmars-mars001-support-web</module>
+        <module>whatsmars-tomcat-web</module>
     </modules>
 
     <properties>

whatsmars-tomcat-web/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>whatsmars-tomcat-web</artifactId>
+    <groupId>com.whatsmars</groupId>
+    <version>1.0-SNAPSHOT</version>
+    <packaging>war</packaging>
+    <name>ixhong-tomcat-web</name>
+    <url>http://maven.apache.org</url>
+
+    <dependencies>
+        <dependency>
+            <groupId>javax.servlet</groupId>
+            <artifactId>javax.servlet-api</artifactId>
+            <version>3.0.1</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>redis.clients</groupId>
+            <artifactId>jedis</artifactId>
+            <version>2.8.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.struts</groupId>
+            <artifactId>struts2-core</artifactId>
+            <version>2.2.3.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.tomcat</groupId>
+            <artifactId>tomcat-catalina</artifactId>
+            <version>7.0.57</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.tomcat</groupId>
+            <artifactId>tomcat-coyote</artifactId>
+            <version>7.0.57</version>
+            <scope>provided</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <finalName>ROOT</finalName>
+        <outputDirectory>src/main/webapp/WEB-INF/classes</outputDirectory>
+        <resources>
+            <resource>
+                <directory>src/main/resources</directory>
+                <filtering>true</filtering>
+            </resource>
+        </resources>
+    </build>
+
+    <profiles>
+        <profile>
+            <id>development</id>
+            <activation>
+                <activeByDefault>true</activeByDefault>
+            </activation>
+            <build>
+                <filters>
+                    <filter>../profile/development.properties</filter>
+                </filters>
+            </build>
+        </profile>
+        <profile>
+            <id>test</id>
+            <build>
+                <filters>
+                    <filter>../profile/test.properties</filter>
+                </filters>
+            </build>
+        </profile>
+        <profile>
+            <id>production</id>
+            <build>
+                <filters>
+                    <filter>../profile/production.properties</filter>
+                </filters>
+            </build>
+        </profile>
+    </profiles>
+
+
+</project>
\ No newline at end of file

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

+package com.whatsmars.tomcat.web.server;
+
+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.
+ */
+public class HttpServer {
+
+    public static final String WEB_ROOT = System.getProperty("user.dir") + File.separator + "ixhong-tomcat-web/src/main/webapp";
+
+    private static final String SHUTDOWN_COMMAND = "SHUTDOWN";
+
+    private boolean shutdown = false;
+
+    public static void main(String[] args) {
+        HttpServer server = new HttpServer();
+        System.out.println(WEB_ROOT);
+        server.await();
+    }
+
+    private void await() {
+        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) {
+            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;
+            }
+        }
+    }
+}

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;
+    }
+}