WebFlux

핵심 개념

Reactive Streams

비동기 스트림 처리를 위한 표준 명세로, Publisher·Subscriber·Subscription·Processor 인터페이스를 정의합니다. WebFlux는 이 표준을 구현한 Reactor 라이브러리를 기반으로 동작합니다.

Mono / Flux

Reactor가 제공하는 두 가지 핵심 타입입니다. Mono는 0개 또는 1개의 결과를, Flux는 0개 이상의 여러 결과를 비동기로 발행하는 Publisher입니다.

WebClient

WebFlux와 함께 제공되는 논블로킹 HTTP 클라이언트로, 외부 API 호출 시 스레드를 블로킹하지 않고 비동기로 응답을 처리할 수 있습니다.

Backpressure

데이터를 생산하는 속도가 소비 속도보다 빠를 때, 소비자가 생산자에게 흐름 제어를 요청하는 메커니즘입니다. Reactive Streams의 핵심 기능 중 하나입니다.

Router Function

어노테이션 기반 컨트롤러 대신 함수형 스타일로 라우팅과 핸들러를 정의하는 방식입니다. WebFlux는 두 가지 프로그래밍 모델을 모두 지원합니다.

WebClient로 외부 API 호출

WebClient를 사용해 외부 API를 논블로킹 방식으로 호출하고, 결과를 Mono로 받아 반환하는 예시입니다.

@Service
public class UserService {
    private final WebClient webClient;

    public UserService(WebClient.Builder builder) {
        this.webClient = builder.baseUrl("https://api.example.com").build();
    }

    public Mono<User> getUser(String id) {
        return webClient.get()
                .uri("/users/{id}", id)
                .retrieve()
                .bodyToMono(User.class);
    }
}