Merge pull request #4 from mjj111/feat/#2_web_server

웹 서버 main에 병합

build.gradle

@@ -34,6 +34,9 @@ javafx {
 }
 
 dependencies {
+    //Log
+    implementation 'ch.qos.logback:logback-classic:1.4.1'
+    implementation 'org.slf4j:slf4j-api:2.0.3'
 
     testImplementation("org.junit.jupiter:junit-jupiter-api:${junitVersion}")
     testRuntimeOnly("org.junit.jupiter:junit-jupiter-engine:${junitVersion}")

src/main/java/RequestHandler.java

@@ -0,0 +1,52 @@
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.*;
+import java.net.Socket;
+import java.nio.charset.StandardCharsets;
+
+public class RequestHandler extends Thread{
+    private static final Logger log = LoggerFactory.getLogger(RequestHandler.class);
+    private Socket connect;
+
+    public RequestHandler(Socket connect) {
+        this.connect = connect;
+    }
+
+    public void run() {
+        log.debug("사용자가 연결되었습니다. Connected IP : {}, Port : {}", connect.getInetAddress(), connect.getPort());
+
+        try(InputStream in = connect.getInputStream();
+            OutputStream out = connect.getOutputStream()) {
+            DataOutputStream dos = new DataOutputStream(out);
+            byte[] body = "안녕하세요!".getBytes(StandardCharsets.UTF_8);
+            response200Header(dos, body.length);
+            responseBody(dos, body);
+        } catch (IOException e) {
+            log.error(e.getMessage());
+        }
+
+
+    }
+
+    private void responseBody(final DataOutputStream dos, final byte[] body) {
+        try {
+            dos.write(body, 0, body.length);
+            dos.writeBytes("\r\n");
+            dos.flush();
+        } catch (IOException e) {
+            log.error(e.getMessage());
+        }
+    }
+
+    private void response200Header(final DataOutputStream dos, final int length) {
+        try {
+            dos.writeBytes("HTTP/1.1 200 OK \r\n");
+            dos.writeBytes("Content-Type : text/html; charset=utf-8\r\n");
+            dos.writeBytes("Content-Length" + length + "\r\n");
+            dos.writeBytes("\r\n");
+        } catch (IOException e) {
+            log.error(e.getMessage());
+        }
+    }
+}

src/main/java/WebServer.java

@@ -0,0 +1,24 @@
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+
+public class WebServer {
+    private static final int DEFAULT_PORT = 8080;
+    public static void main(String[] args) throws IOException {
+        int port;
+
+        if(args == null || args.length == 0) {
+            port = DEFAULT_PORT;
+        } else {
+            port = Integer.parseInt(args[0]);
+        }
+
+        try(ServerSocket listenSocket = new ServerSocket(port)) {
+            Socket connection;
+            while((connection = listenSocket.accept()) != null) {
+                RequestHandler requestHandler = new RequestHandler(connection);
+                requestHandler.start();
+            };
+        }
+    }
+}