[톰캣 구현하기 - 3, 4단계] 땡칠(박성철) 미션 제출합니다.

tomcat/src/main/java/nextstep/jwp/handler/HelloController.java

@@ -0,0 +1,23 @@
+package nextstep.jwp.handler;
+
+import org.apache.coyote.http11.HttpRequest;
+import org.apache.coyote.http11.HttpResponse;
+import org.apache.coyote.http11.TargetPath;
+import org.apache.coyote.http11.controller.Controller;
+import org.apache.coyote.http11.header.ContentType;
+
+public class HelloController implements Controller {
+
+    private static final TargetPath SUPPORTED_PATH = new TargetPath("/");
+
+    @Override
+    public boolean supports(HttpRequest httpRequest) {
+        return httpRequest.getTarget().getPath().equals(SUPPORTED_PATH) && httpRequest.getMethod().isGet();
+    }
+
+    @Override
+    public void handle(HttpRequest httpRequest, HttpResponse httpResponse) {
+        httpResponse.setContentType(new ContentType("text/html"));
+        httpResponse.setBody("Hello world!");
+    }
+}

tomcat/src/main/java/nextstep/jwp/handler/LoginController.java

@@ -0,0 +1,78 @@
+package nextstep.jwp.handler;
+
+import nextstep.jwp.db.InMemoryUserRepository;
+import nextstep.jwp.model.User;
+import org.apache.coyote.http11.HttpRequest;
+import org.apache.coyote.http11.HttpResponse;
+import org.apache.coyote.http11.TargetPath;
+import org.apache.coyote.http11.body.FormData;
+import org.apache.coyote.http11.controller.FileController;
+import org.apache.coyote.http11.controller.GetAndPostController;
+import org.apache.coyote.http11.header.Cookies;
+import org.apache.coyote.http11.session.Session;
+import org.apache.coyote.http11.session.SessionManager;
+
+import java.util.Optional;
+
+public class LoginController extends GetAndPostController {
+
+    private static final String SESSION_KEY = "JSESSIONID";
+    private static final String SESSION_USER_KEY = "user";
+
+    private static final String UNAUTHORIZED_LOCATION = "/401";
+    private static final String MAIN_LOCATION = "/index";
+
+    private static final TargetPath SUPPORTED_PATH = new TargetPath("/login").autoComplete();
+
+    private final FileController fileHandler = new FileController();
+
+    @Override
+    public boolean supports(HttpRequest httpRequest) {
+        if (httpRequest.getMethod().isGet() || httpRequest.getMethod().isPost()) {
+            return httpRequest.getTarget().getPath().autoComplete().equals(SUPPORTED_PATH);
+        }
+        return false;
+    }
+
+    @Override
+    protected void doGet(final HttpRequest httpRequest, final HttpResponse httpResponse) {
+        boolean isSignedIn = httpRequest.getSession(SESSION_KEY)
+                .map(session -> session.hasAttribute(SESSION_USER_KEY))
+                .isPresent();
+        if (isSignedIn) {
+            httpResponse.redirectTo(MAIN_LOCATION);
+        }
+        fileHandler.handle(httpRequest, httpResponse);
+    }
+
+    @Override
+    protected void doPost(final HttpRequest httpRequest, final HttpResponse httpResponse) {
+        FormData formData = FormData.of(httpRequest.getBody());
+        String account = formData.get("account");
+        String password = formData.get("password");
+
+        Optional<User> found = InMemoryUserRepository.findByAccount(account);
+        if (found.isPresent()) {
+            User user = found.get();
+            signIn(httpResponse, user, password);
+            return;
+        }
+        httpResponse.redirectTo(UNAUTHORIZED_LOCATION);
+    }
+
+    private void signIn(final HttpResponse httpResponse, final User user, final String password) {
+        if (user.checkPassword(password)) {
+            Session session = new Session();
+            session.addAttribute(SESSION_USER_KEY, user);
+            SessionManager.add(session);
+
+            Cookies cookies = new Cookies();
+            cookies.add(SESSION_KEY, session.getId());
+
+            httpResponse.redirectTo(MAIN_LOCATION);
+            httpResponse.setCookies(cookies);
+            return;
+        }
+        httpResponse.redirectTo(UNAUTHORIZED_LOCATION);
+    }
+}

tomcat/src/main/java/nextstep/jwp/handler/RegisterController.java

@@ -0,0 +1,43 @@
+package nextstep.jwp.handler;
+
+import nextstep.jwp.db.InMemoryUserRepository;
+import nextstep.jwp.model.User;
+import org.apache.coyote.http11.HttpRequest;
+import org.apache.coyote.http11.HttpResponse;
+import org.apache.coyote.http11.TargetPath;
+import org.apache.coyote.http11.body.FormData;
+import org.apache.coyote.http11.controller.FileController;
+import org.apache.coyote.http11.controller.GetAndPostController;
+
+public class RegisterController extends GetAndPostController {
+
+    private static final String MAIN_LOCATION = "/index";
+    private static final TargetPath SUPPORTED_PATH = new TargetPath("/register").autoComplete();
+
+    private final FileController fileHandler = new FileController();
+
+    @Override
+    public boolean supports(HttpRequest httpRequest) {
+        if (httpRequest.getMethod().isGet() || httpRequest.getMethod().isPost()) {
+            return httpRequest.getTarget().getPath().autoComplete().equals(SUPPORTED_PATH);
+        }
+        return false;
+    }
+
+    @Override
+    protected void doGet(final HttpRequest httpRequest, final HttpResponse httpResponse) {
+        fileHandler.handle(httpRequest, httpResponse);
+    }
+
+    @Override
+    protected void doPost(final HttpRequest httpRequest, final HttpResponse httpResponse) {
+        FormData formData = FormData.of(httpRequest.getBody());
+
+        String account = formData.get("account");
+        String password = formData.get("password");
+        String email = formData.get("email");
+
+        InMemoryUserRepository.save(new User(account, password, email));
+        httpResponse.redirectTo(MAIN_LOCATION);
+    }
+}

tomcat/src/main/java/org/apache/catalina/connector/Connector.java

@@ -1,31 +1,38 @@
 package org.apache.catalina.connector;
 
-import java.net.SocketException;
-import org.apache.coyote.http11.Http11Processor;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import java.io.IOException;
 import java.io.UncheckedIOException;
 import java.net.ServerSocket;
 import java.net.Socket;
+import java.net.SocketException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import org.apache.coyote.http11.Http11Processor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 public class Connector implements Runnable {
 
     private static final Logger log = LoggerFactory.getLogger(Connector.class);
 
     private static final int DEFAULT_PORT = 8080;
-    private static final int DEFAULT_ACCEPT_COUNT = 100;
+    private static final int DEFAULT_ACCEPT_COUNT = 100; // 모든 쓰레드가 사용중일 때 들어오는 연결에 대한 대기열의 길이
+    private static final int MAX_THREADS = 250; // 동시에 연결 후 처리 가능한 요청의 최대 개수
+    // 최대 ThradPool의 크기는 250, 모든 Thread가 사용 중인(Busy) 상태이면 100명까지 대기 상태로 만들려면 어떻게 할까?
+    // acceptCount를 100으로 한다
+    // 처리중인 연결이 250개 이므로 나머지는 OS 큐에서 대기하게 된다.
     private static final int SOCKET_TIMEOUT_SECONDS = 10;
 
     private final ServerSocket serverSocket;
     private boolean stopped;
+    private final ExecutorService pool;
 
     public Connector() {
-        this(DEFAULT_PORT, DEFAULT_ACCEPT_COUNT);
+        this(DEFAULT_PORT, DEFAULT_ACCEPT_COUNT, MAX_THREADS);
     }
 
-    public Connector(final int port, final int acceptCount) {
+    public Connector(final int port, final int acceptCount, final int maxThreads) {
+        this.pool = Executors.newFixedThreadPool(maxThreads);
         this.serverSocket = createServerSocket(port, acceptCount);
         this.stopped = false;
     }
@@ -60,6 +67,7 @@ private void connect() {
         try {
             process(serverSocket.accept());
         } catch (IOException e) {
+            pool.shutdown();
             log.error(e.getMessage(), e);
         }
     }
@@ -70,7 +78,7 @@ private void process(final Socket connection) throws SocketException {
         }
         connection.setSoTimeout(SOCKET_TIMEOUT_SECONDS * 1000);
         var processor = new Http11Processor(connection);
-        new Thread(processor).start();
+        pool.execute(processor);
     }
 
     public void stop() {