[Kotlin] 코틀린 Mono, Flux 란?

Intro

안녕하세요:) 이번 시간에는 코틀린 Mono, Flux 에 대해 알아보도록 하겠습니다. 요즘 다시 코틀린을 하고 있는데 그새 개념을 잊어먹어 다시 공부가 필요할 것 같아요! 😭

 

코틀린 Mono, Flux

kotlin에서 Mono, Flux는 Reactor 라이브러리에서 제공하는 비동기 스트림을 표현하는 타입입니다. 이들은 비동기 프로그래밍을 지원하기 위해 만들어졌으며, Reactive Streams 표준을 따릅니다.

 

Reactor 라이브러리는 자바 기반의 리액티브 프로그래밍(비동기 스트림 처리)를 위한 라이브러리입니다. Spring WebFlux와 같은 비동기 웹 애플리케이션에서 주로 사용됩니다. Spring WebFlux는 Spring Framework에서 제공하는 비동기 및 논블로킹 웹 애플리케이션 개발을 위한 모듈입니다. 기존의 Spring MVC가 동기식 방식에 기반한 웹 개발 모델이라면, Spring WebFlux는 리액티브 프로그래밍 모델을 기반으로 설계되어, 대규모의 동시 요청을 효율적으로 처리할 수 있도록 설계되었습니다.

 

Mono

• 0개 또는 1개의 데이터를 비동기적으로 반환
• 데이터가 하나만 필요하거나 없을 수도 있는 경우 사용
• 리소스 소비: 상대적으로 가벼움

 

Flux

• 0개 이상의 데이터 스트림을 비동기적으로 반환
• 여러 개의 데이터를 처리하거나 스트리밍할 때 적합
• 리소스 소비: 데이터가 많아질수록 부담 증가

 

Kotlin 사용 예시

import kotlinx.coroutines.reactor.awaitSingle
import kotlinx.coroutines.reactor.awaitSingleOrNull

suspend fun getData(): String {
    return Mono.just("Hello").awaitSingle()
}

 

reactor.kotlin 라이브러리를 통해 Mono와 Flux를 suspend 함수로 변환 가능