스프링 Webflux

 프로젝트 리액터

• 프로젝트 리액터는 리액티브 스트림의 구현체 중 하나로, 스프링의 에코시스템 범주에 포함된 프레임워크이다.
• 리액티브 스트림 사양을 구현하고 있으므로 리액티브 스트림에서 사용하는 용어와 규칙을 그대로 사용한다.
• 리액터를 사용하면, 애플리케이션에 리액티브 프로그래밍을 적용할 수 있고, 비동기-논블로킹을 적용할 수 있다.
• 함수형 프로그래밍의 접근 방식을 사용해서 비동기-논블로킹 코드의 난해함을 어느 정도 해결한다.
• 백 프레셔를 사용해 시스템의 부하를 효율적으로 조절할 수 있다.

Mono/ Flux

• 리액터는 리액티브 스트림의 Publisher 인터페이스를 구현하는 Mono와 Flux라는 핵심 타입을 제공한다.
• Mono는 0..1개의 단일 요소 스트림을 통지하는 발행자이다.
• Flux는 0..N개로 이루어진 다수 요소 스트림을 통지하는 발행자이다.
• 두 타입 모두 리액티브 스트림 데이터 처리 프로토콜대로 onComplte, onError 시그널이 발생할 때까지 onNext를 사용해 구독자에게 데이터를 통지한다

Mono

fun main(){
    val mono = Mono.just("Hello Reactive World")
    mono.subscribe(::println) //해당 함수가 호출되기 전에 Hello Reactive World가 출력되지 않는다
}

• Mono와 Flux 연산자는 모두 Lazy로 동작하여 subscribe를 호출하지 않으면 리액티브 스트림 사양대로 동작하지 않는다.
  • subscribe는 최종연산자이다.
• Java8 스트림도 이와 유사하며, map, flatMap, filter와 같은 중간 연산자가 아닌 collect, findFirst와 같은 최종 연산자를 실행해야 코드가 실행된다.

Flux

data class CellPhone(
    val name: String,
    val price: Int,
    val currency: Currency,
)

enum class Currency {
    KRW, USD
}

fun main() {
    val iphone = CellPhone(name = "iphone", price = 100, currency = KRW)
    val galaxy = CellPhone(name = "galaxy", price = 90, currency = KRW)
    val flux = Flux.just(iphone, galaxy)
    flux.subscribe(::println)
}

• 다수의 요소를 통지할 수 있다.

스프링 WebFlux와 스프링 MVC 비교

Spring MVC/ Spring WebFlux

스프링 MVC

• 스프링으로 개발된 대부분의 웹 애플리케이션은 서블릿 기반의 스프링 MVC이다.
• 스프링 MVC는 동시성 처리를 전통적 웹 방식인 하나의 스레드가 하나의 요청을 처리하는 Thread per Request Model 사용한다
• Thread per Request Model은 DB, Network IO 등이 발생할 경우 결과를 받기까지, 스레드가 블로킹된다.
  • 이러한 문제를 해결하기 위해 스레드 풀을 사용해 동시성을 제어한다
• 명령형 코드 작성은 코드의 흐름을 쉽게 이해할 수 있고 디버깅하기 쉽다
• 대부분의 스프링 웹 애플리케이션이 스프링 MVC 기반이므로 안정성과 풍부한 라이브러리를 지원한다.
• JPA, JDBC와 같은 블로킹 API를 사용하는 경우에는 스프링 MVC를 사용하는 것이 낫다

스프링 WebFlux

• 스프링 WebFlux는 리액티브 기반의 웹 스택 프레임워크이다.
• 기본적으로 프로젝트 리액터 기반이며, 리액티브 스트림의 다른 구현체인 RxJava나 코틀린 코루틴으로도 개발이 가능하다.
• 스프링 WebFlux는 비동기-논블로킹으로 동작하므로 적은 수의 스레드로도 대량의 동시성을 제어할 수 있다.
• 함수형 엔드포인트와 애노테이션 컨트롤러 방식을 모두 지원한다(@Controller, Router)
• 이벤트 루프 동시성 모델
• 스프링 MVC에 비해 러닝 커브가 많이 높지만 전 구간 비동기-논 블로킹인 경우 최적의 성능을 보여준다.
• 스프링 MVC에서도 리액터와 WebFlux 의존성을 추가하여 리액티브 코드와 논블로킹 라이브러리를 사용할 수 있다.

구현

프로젝트 생성

Router

@Configuration
class Router {

    @Bean
    fun helloRouter(handler: HelloHandler): RouterFunction<ServerResponse> =
        route()
            .GET("/", handler::sayHello)
            .build()
}

• Router에서 직접 메서드를 매핑하여 사용한다.
• @Controller를 사용할 수도 있다.

HelloHandler

@Component
class HelloHandler {

    fun sayHello(req: ServerRequest): Mono<ServerResponse> {
        return ServerResponse.ok().bodyValue("Hello WebFlux")
    }
}

• @Controller로 만드는 것이 아닌 Router의 핸들러를 사용하여, 함수형 프로그래밍으로 작성할 수 있다.