[WebFlux] flatMap과 map의 차이

Webflux를 사용할 때마다 flatMap과 map이 항상 헷갈리므로 정리.

 

두 메서드는 Reactive Stream API 일부로 Reactor 라이브러리의 Mono와 Flux에서 사용되며 비동기 스트림 처리 역할을 수행한다. 
단, flatMap이 비동기 작업에 더 적합 !

 

 

flatMap()

입력 스트림의 각 요소에 대해 비동기적으로 함수를 적용 👉 1:N 변환

• 원본 요소를 변환하여 새로운 Mono 또는 Flux 반환
• 반환된 스트림은 flatten(평탄화)되어 단일 Mono 또는 Flux로 합쳐짐

@GetMapping("/user/{id}")
public Mono<User> getUser(@PathVariable String id) {
    return userRepository.findById(id)  // returns Mono<User>
                         .flatMap(user -> {
                             return Mono.just(user)
                                        .map(User::getName)
                                        .flatMap(name -> someOtherService.process(name));
                         });
}

👉 비동기 작업을 수행하고 그 결과를 이어받아야할 때 유용

• userRespository.findById(id) 👉 비동기적으로 사용자 정보 가져옴
• someOtherService.process(name) 👉 비동기적으로 다른 작업 수행

 

 

map()

입력 스트림의 각 요소에 대해 동기적으로 함수를 적용 👉 1:1 변환

• 원본 요소 변환하여 새로운 Mono 또는 Flux 반환
• blocking 작업 없이 간단한 변환 시 사용 👉 단순 변환 작업 

@GetMapping("/hello")
public Mono<String> hello() {
    return Mono.just("hello")
               .map(value -> value.toUpperCase());
}

 

 

 

 

 

참고자료 

https://www.baeldung.com/java-reactor-map-flatmap

https://luvstudy.tistory.com/95