[톰캣 구현하기 3, 4단계] 블랙캣(송우석) 미션 제출합니다. (#477)

* test: 쓰레드 및 톰캣 설정 테스트 코드 작성

* refactor: AbstractController 추상클래스, Controller 인터페이스 적용

* feat: 최대 요청 처리 가능 개수 250개 및 요청 대기 수 100개 설정

* refactor: 멀티 쓰레드를 고려한 ConcurrentHashMap 적용

* docs: 변경 사항 반영

* refactor: 메서드 분리

* refactor: 에러 코드 - 메시지 순서 변경

* feat: 테스트 분리 및 서블릿 매핑 테스트 추가

* feat: 500 에러 페이지 반환 기능 구현

* refactor: 지원하는 컨트롤러가 없을 시 404 페이지 반환

* refactor: 코드 정렬

* refactor: 사용하지 않는 코드 삭제

* fix: Request에 Content-Length 가 0일 때 body 파싱시 NPE 문제 해결

* feat: 지원하지 않는 메서드에 대해서 405 에러 반환 구현

* refactor: code smell 제거

* refactor: code smell 제거

Author: Songusika

README.md

@@ -14,16 +14,16 @@
 - `POST /login`
   - 요청 바디: `account`, `password`
   - 로그인 성공 이후 `/index.html` 리다이렉트
-  - 로그인 실패 이후 `/401.html` 리다이렉트 
+  - 로그인 실패 이후 `401 Unauthorized`-`/401.html` 반환 
 
 ### ✔ 회원가입 요청 페이지
 - `GET /register`
 
 ### ✔ 회원가입 요청
 - `POST /register`
   - 요청 바디: `account`, `email`, `password`
-  - 회원 가입 성공 이후 `/index.html`
-  - 아이디 중복인 경우 `400 Bad Request` 반환
+  - 회원 가입 성공 이후 `/login` 리다이렉트
+  - 아이디 중복인 경우 `400 Bad Request` - `/400.html` 반환
 
 ### ✔ 존재하지 않는 경로
 - `404.html` 반환

study/src/main/java/cache/com/example/cachecontrol/CacheWebConfig.java

@@ -1,5 +1,6 @@
 package cache.com.example.cachecontrol;
 
+import java.io.File;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
@@ -9,5 +10,6 @@ public class CacheWebConfig implements WebMvcConfigurer {
 
     @Override
     public void addInterceptors(final InterceptorRegistry registry) {
+        registry.addInterceptor(new NoCacheInterceptor());
     }
 }

study/src/main/java/cache/com/example/cachecontrol/NoCacheInterceptor.java

@@ -0,0 +1,22 @@
+package cache.com.example.cachecontrol;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import org.springframework.http.HttpHeaders;
+import org.springframework.web.servlet.HandlerInterceptor;
+import org.springframework.web.servlet.ModelAndView;
+
+public class NoCacheInterceptor implements HandlerInterceptor {
+
+    @Override
+    public void postHandle(
+            final HttpServletRequest request,
+            final HttpServletResponse response,
+            final Object handler,
+            final ModelAndView modelAndView
+    ) throws Exception {
+
+        response.addHeader(HttpHeaders.CACHE_CONTROL, "no-cache, private");
+        HandlerInterceptor.super.postHandle(request, response, handler, modelAndView);
+    }
+}

study/src/main/resources/application.yml

@@ -3,7 +3,7 @@ handlebars:
 
 server:
   tomcat:
-    accept-count: 1
-    max-connections: 1
+    accept-count: 0
+    max-connections: 2
     threads:
       max: 2

study/src/test/java/thread/stage0/SynchronizationTest.java

@@ -41,7 +41,7 @@ private static final class SynchronizedMethods {
 
         private int sum = 0;
 
-        public void calculate() {
+        public synchronized void calculate() {
             setSum(getSum() + 1);
         }
 

study/src/test/java/thread/stage0/ThreadPoolsTest.java

@@ -1,56 +1,61 @@
 package thread.stage0;
 
-import org.junit.jupiter.api.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.assertj.core.api.SoftAssertions.assertSoftly;
 
 import java.util.concurrent.Executors;
 import java.util.concurrent.ThreadPoolExecutor;
-
-import static org.assertj.core.api.Assertions.assertThat;
+import org.junit.jupiter.api.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
- * 스레드 풀은 무엇이고 어떻게 동작할까?
- * 테스트를 통과시키고 왜 해당 결과가 나왔는지 생각해보자.
- *
- * Thread Pools
- * https://docs.oracle.com/javase/tutorial/essential/concurrency/pools.html
- *
- * Introduction to Thread Pools in Java
- * https://www.baeldung.com/thread-pool-java-and-guava
+ * 스레드 풀은 무엇이고 어떻게 동작할까? 테스트를 통과시키고 왜 해당 결과가 나왔는지 생각해보자.
+ * <p>
+ * Thread Pools https://docs.oracle.com/javase/tutorial/essential/concurrency/pools.html
+ * <p>
+ * Introduction to Thread Pools in Java https://www.baeldung.com/thread-pool-java-and-guava
  */
 class ThreadPoolsTest {
 
     private static final Logger log = LoggerFactory.getLogger(ThreadPoolsTest.class);
 
     @Test
     void testNewFixedThreadPool() {
+        // 코어 쓰레드와 최대 쓰레드가 2이다.
         final var executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(2);
         executor.submit(logWithSleep("hello fixed thread pools"));
         executor.submit(logWithSleep("hello fixed thread pools"));
         executor.submit(logWithSleep("hello fixed thread pools"));
+        executor.submit(logWithSleep("hello fixed thread pools"));
 
         // 올바른 값으로 바꿔서 테스트를 통과시키자.
-        final int expectedPoolSize = 0;
-        final int expectedQueueSize = 0;
+        final int expectedPoolSize = 2;
+        // 2개의 작업이 쓰레드에 할당되어서 실행되고 있기 때문에 남은 4-2
+        final int expectedQueueSize = 2;
 
-        assertThat(expectedPoolSize).isEqualTo(executor.getPoolSize());
-        assertThat(expectedQueueSize).isEqualTo(executor.getQueue().size());
+        assertSoftly(softly -> {
+            softly.assertThat(executor.getPoolSize()).isEqualTo(expectedPoolSize);
+            softly.assertThat(executor.getQueue().size()).isEqualTo(expectedQueueSize);
+        });
     }
 
     @Test
     void testNewCachedThreadPool() {
+        // 코어 쓰레드와 최대 쓰레드가 최대 int 값 까지이다.
         final var executor = (ThreadPoolExecutor) Executors.newCachedThreadPool();
         executor.submit(logWithSleep("hello cached thread pools"));
         executor.submit(logWithSleep("hello cached thread pools"));
         executor.submit(logWithSleep("hello cached thread pools"));
 
         // 올바른 값으로 바꿔서 테스트를 통과시키자.
-        final int expectedPoolSize = 0;
+        final int expectedPoolSize = 3;
         final int expectedQueueSize = 0;
 
-        assertThat(expectedPoolSize).isEqualTo(executor.getPoolSize());
-        assertThat(expectedQueueSize).isEqualTo(executor.getQueue().size());
+        assertSoftly(softly -> {
+            softly.assertThat(executor.getPoolSize()).isEqualTo(expectedPoolSize);
+            softly.assertThat(executor.getQueue().size()).isEqualTo(expectedQueueSize);
+        });
     }
 
     private Runnable logWithSleep(final String message) {

study/src/test/java/thread/stage2/AppTest.java

@@ -20,6 +20,9 @@ class AppTest {
      * - 스레드명(nio-8080-exec-x)으로 생성된 스레드 갯수를 파악
      * - http call count
      * - 테스트 결과값
+     accept count: backlog 크기 만큼 생성된 운영체제 단의 accept 큐 사이즈 3-way 핸드셰이크가 끝난 커넥션이 대기
+     max-connections: socket.accept() 로 받을 수 있는 커넥션 수 accept큐에서 대기 중인 커넥션을 꺼내서 accpet() 받을 수 있는 최대 커넥션 수
+     threads: 한번에 처리할 수 있는 최대 요청 개수 (즉 실제 생성되는 스레드 개수)
      */
     @Test
     void test() throws Exception {

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

@@ -0,0 +1,30 @@
+package nextstep.jwp.handler;
+
+import java.util.List;
+import org.apache.catalina.exception.NotSupportedRequestException;
+import org.apache.catalina.servlet.Controller;
+import org.apache.coyote.http.vo.HttpRequest;
+
+public class ControllerMapping {
+
+    private static final List<Controller> controllers = List.of(
+            new DefaultPageController(),
+            new LoginController(),
+            new RegisterController()
+    );
+
+    private ControllerMapping() {
+    }
+
+    public static boolean hasSupportedController(final HttpRequest request) {
+        return controllers.stream()
+                .anyMatch(it -> it.isSupported(request));
+    }
+
+    public static Controller getSupportedController(final HttpRequest request) {
+        return controllers.stream()
+                .filter(it -> it.isSupported(request))
+                .findFirst()
+                .orElseThrow(NotSupportedRequestException::new);
+    }
+}

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

@@ -0,0 +1,26 @@
+package nextstep.jwp.handler;
+
+import org.apache.catalina.servlet.AbstractController;
+import org.apache.coyote.http.HttpHeader;
+import org.apache.coyote.http.HttpMethod;
+import org.apache.coyote.http.HttpStatus;
+import org.apache.coyote.http.SupportFile;
+import org.apache.coyote.http.vo.HttpRequest;
+import org.apache.coyote.http.vo.HttpResponse;
+import org.apache.coyote.http.vo.Url;
+
+public class DefaultPageController extends AbstractController {
+    
+    @Override
+    protected void doGet(final HttpRequest request, final HttpResponse response) {
+        response.setStatus(HttpStatus.OK)
+                .setHeader(HttpHeader.CONTENT_TYPE, SupportFile.HTML.getContentType())
+                .setBody("Hello world!");
+    }
+
+    @Override
+    public boolean isSupported(final HttpRequest request) {
+        return request.isRequestMethodOf(HttpMethod.GET) &&
+                request.isUrl(Url.from("/"));
+    }
+}