Netty에서부터 Spring WebFlux의 요청 처리 흐름을 알아보겠습니다.

1. 클라이언트 요청 수신 - Netty 서버

WebFlux는 기본적으로 Reactor Netty(Netty 위에 Reactor 프로그래밍 모델을 입힌 HTTP/TCP 클라이언트 & 서버 구현체)를 HTTP 서버로 사용합니다. Netty는 Java NIO 기반의 비동기 이벤트 기반 네트워크 프레임워크입니다.

1-1. Netty의 부트스트랩 과정

Spring Boot를 통해 WebFlux 애플리케이션이 시작되면:

protected void onRefresh() {
      super.onRefresh();

      try {
          this.createWebServer();
      } catch (Throwable ex) {
          throw new ApplicationContextException("Unable to start reactive web server", ex);
      }
  }

스프링 애플리케이션 컨텍스트 초기화 완료를 위해 super.onRefresh( ) 가 실행된 후 this.createWebServer( ) 로 Netty 웹 서버 생성 및 실행합니다.

this.createWebServer( ) 의 내부에서 아래 실행 로직이 실행됩니다:

HttpServer.create()
          .port(8080)
          .handle(new ReactorHttpHandlerAdapter(webHandler))
          .bindNow();

• ReactorHttpHandlerAdapter 가 생성됩니다.
  • Netty는 낮은 수준의 네트워크 처리 담당(TCP, HTTP 디코딩 등), Spring WebFlux는 사용자 요청을 해석하고, 매핑하고, 비즈니스 로직을 실행하는 고수준 웹 프레임워크로 이 둘은 다른 수준의 API 입니다. WebFlux를 Netty 위에서 실행하려면 중간에 둘을 연결해주는 어댑터가 필요합니다.
  • 이걸 해주는 게 ReactorHttpHandlerAdapter 입니다.
• 이것을 기반으로 HttpServer.create().handle(...)로 Netty 서버가 시작됩니다
• 실제 실행은 Netty의 EventLoopGroup이 ServerSocketChannel 에 바인딩되어 클라이언트 요청을 수신합니다.
• webHandler 는 결국 Spring WebFlux의 진입점인 DispatcherHandler 입니다.
  • 정확히 말하면 webHandler 는 WebHandler 인터페이스입니다. 그리고 이것을 구현한 클래스가 DispatcherHandler 입니다.

<aside> 💡

HttpHandler와 WebHandler는 무엇인가요?

배경

Spring WebFlux는 다음과 같이 다양한 서버 엔진과 함께 사용할 수 있습니다:

• Netty (기본값)
• Undertow
• Tomcat
• Jetty
• Servlet 3.1+ Container

각 서버는 자체적인 HTTP 처리 방식과 API를 가지고 있습니다. 예를 들어 Netty는 ChannelHandler , Servelet 기반 서버는 HttpServlet 방식으로 HTTP 요청을 처리합니다.

HttpHandler란?

HttpHandler 는 WebFlux에서 HTTP 요청과 응답을 처리하는 가장 핵심적인 추상화 인터페이스입니다.

public interface HttpHandler {
    Mono<Void> handle(ServerHttpRequest request, ServerHttpResponse response);
}

이 인터페이스는 다음에 활용됩니다:

• 어떤 서버 엔진이든 간에 동일한 방식으로 요청을 처리하게 해줌
• 즉, 서버 엔진 종속적인 로직을 숨기고, 요청 처리 흐름을 통일 시켜 줌
• 요청을 처리하는 실제 구현체(예: DispatcherHandler )로 전달하는 통합 처리 진입점으로 활용

WebHandler란?

Spring WebFlux에서의 WebHandler는 다음과 같은 인터페이스입니다:

public interface WebHandler {
    Mono<Void> handle(ServerWebExchange exchange);
}

즉, HTTP 요청을 처리하는 핵심 WebFlux 컴포넌트입니다.

좀 더 쉽게 말하면:

HttpHandler가 서버 추상화라면,

WebHandler는 WebFlux 애플리케이션 로직을 처리하는 실질적인 핸들러입니다.

<aside> 💡

ReactorHttpHandlerAdapter 생성자 파라미터 타입은 HttpHandler인데 어떻게 WebHandler 인터페이스 구현체인 DispatcherHandler가 들어갈 수 있나요?

Spring WebFlux는 DispatcherHandler 를 HttpHandler 로 감싸서 넘깁니다. 보통 다음과 같은 빌더를 사용합니다.

WebHandler webHandler = new DispatcherHandler();

HttpHandler httpHandler = WebHttpHandlerBuilder
                            .webHandler(webHandler)
                            .build();

ReactorHttpHandlerAdapter adapter = new ReactorHttpHandlerAdapter(httpHandler);

즉, DispatcherHandler 는 WebHandler 지만, WebHttpHandlerBuilder.build( ) 는 이걸 내부에서 HttpHandler 로 감싸는 작업을 합니다.

</aside>

2. Netty에서 요청 수신

클라이언트가 HTTP 요청을 보내면: