[Spring] Spring WebFlux 란 무엇인가

Spring WebFlux 란?

• Spring 5 부터 도입된 비동기/논블로킹 웹 프레임워크
• Reactive Streams 기반, 적은 스레드로 많은 요청 처리

-> 기존 Spring MVC = Blocking I/O

-> WebFlux = Non-Blocking I/O + 이벤트 루프

 

 

WebFlux 의 등장 배경

1. Spring MVC의 구조적 한계
   • 요청 1건 = 스레드 1개
   • I/O 대기동안 스레드 점유
   • 트래픽 증가 -> 스레드 고갈 -> 응답 지연
2. WebFlux의 해결 방식
   • I/O 대기 중 스레드 반환
   • 이벤트가 오면 다시 이어서 처리
   • 적은 스레드로 동시성 처리

WebFlux = CPU가 아니라 I/O 대기 시간이 병목인 서비스를 위한 모델

 

 

WebFlux 핵심 개념

• Reactive Streams
  
  • Publisher : 데이터 발행
  • Subscriber : 데이터 구독
  • Backpressure : 처리 가능한 만큼만 요청
• Mono / Flux
  • Mono<T> : 0~1 건
  • Flux<T> : 0~N 건

Mono<User> findUser();
Flux<Order> findOrders();

 

-> return 값 자체가 미래에 도착할 데이터

 

• Non-Blocking I/O 
  • 요청 처리 스레드 ≠ I/O 처리 스레드
  • 대기 없음. 이벤트 기반 재개

 

Spring MVC vs WebFlux 비교

구분	Spring MVC	WebFlux
프로그래밍 모델	동기	비동기
I/O	Blocking	Non-Blocking
스레드 모델	요청당 1개	이벤트 루프
반환 타입	객체	Mono / Flux
학습 난이도	낮음	높음

 

 

WebFlux는 언제 쓸까?

• 외부 API 호출이 많은 서비스
• 스트리밍 (SSE, WebSocket)
• 대규모 트래픽, 고동시성
• MSA 환경의 API Gateway

 

간단 예제

• Controller

@GetMapping("/user/{id}")
public Mono<UserResponse> getUser(@PathVariable Long id){
	return userService.findById(id)
    		.map(UserResponse::from);
}

• Service

public Mono<User> findById(Long id) {
	return userRepository.findById(id);
}

• 에러 처리

return userService.findById(id)
	.switchIfEmpty(Mono.error(new NotFoundException()));