[Spring WebFlux] 1. Mono와 Flux에 대한 이해(1) : 작동 방식과 이해

 

 

🏝 0. 이전 글 (0. 리액티브 프로그래밍의 소개)

 

[Spring WebFlux] 0. 리액티브 프로그래밍의 소개

 

 

 

🤔 1. Mono와 Flux를 소개합니다.

1-1. Flux

 

Flux<T>는 Reactive Stream의 Publisher에 해당하는 객체입니다.

퍼블리셔가 무엇인지 모른다면, 지난 포스팅을 참고해주시기 바랍니다.

 

 

공식 레퍼런스의 Flux입니다. "All Implemented Interfaces"를 확인하면, 리액티브 스트림에서 정의한 Publisher<T>를 상속받고 있다는 것을 알 수 있습니다. 따라서 이 Flux가 Item들을 Produce(Emit)한다는 것을 알 수 있고, Subscriber가 subscribe하기 전까지는 아무런 반응이 없다는 것도 알 수 있습니다.

 

 

Flux는 0개부터 N개까지의 T타입의 원소를 방출하게 됩니다. onNext 이벤트가 발생하면 이때부터 방출하게 됩니다.

그리고 onComplete 이벤트가 발생하면 완료하고, onError 이벤트가 발생하면 에러를 발생시킵니다. 두 이벤트는 터미널 이벤트로 흐름을 종료시킵니다. 이러한 터미널 이벤트가 발생(트리거)하지 않으면, Flux는 무한히 유지됩니다.

 

 

Flux는 Operator가 많습니다. Flux 객체를 생성하는 Generate Operator, Flux를 변형하는 Transform Operator, 시퀀스를 조절/조작하는 Orchestrate Operator가 있습니다.

 

공식 레퍼런스의, "Static Method" 파트를 살펴보면, 정적 팩토리 메소드가 많습니다. 이를 사용해서 Flux 리소스를 만들 수 있습니다.

 

확인해보면 너무 많아서 모두 다 숙지하는 것은 어렵고, 자주 사용하는 메서드를 확인하거나 필요시 서칭해서 사용하는 방법이 적합합니다.

 

옆의 Instance Methods는 Operator로, 비동기 프로세싱 파이프라인을 빌드할 수 있고 비동기 시퀀스를 만들어 내게 됩니다. 그러므로, instance method 파트에 있는 메소드를 잘 활용하는 것이 곧 비동기 프로그래밍을 잘 설계할 수 있다는 것입니다.

 

Flux의 subscribe나, 멀티캐스팅 연산인 Flux의 publish, publishNext는 파이프라인의 전용 인스턴스를 구체화합니다. 그리고 데이터 플로우를 안에 넣는 트리거가 됩니다. 번역에 의한 설명이 굉장히 와닿지 않을 수 있지만, 쉽게 설명하면 얘들을 써야 Flux에 담긴 Item들이 흘러들어가고, lazily captured(ex. supplier에 의해 값이 생성되는 경우)의 경우엔 얘들이 없으면 데이터 생성이 되지 않는다는 의미입니다.

 

 

 

위 그림은 Flux를 설명하는 그림입니다. 

그림의 각 동그라미는 Flux로부터 빠져나온 데이터들을 의미합니다.

그리고 상단과 하단의 오른쪽으로 향하는 화살표는 Flux의 타임라인을 의미합니다. 오른쪽으로 향한다는 것은 시간의 흐름이 왼쪽에서 오른쪽으로 흐르는 것을 의미합니다.

중간의 점선과 operator 박스는, Flux에 적용되는 변환을 의미합니다.

그리고 상단 화살표의 가장 오른쪽의 수직선은 Flux의 종료를 의미하고, 하단의 X는 어떠한 이유에 의해 비정상적인 Flux 종료를 의미합니다.

 

 

 

1-2. Mono

 

  Mono 역시 크게 다르지 않습니다.

 

Mono 역시 Flux와 마찬가지로 Reactive Stream의 Publisher를 상속받은 것을 확인할 수 있습니다.

따라서 Mono도 아이템을 produce할 수 있고, subscriber가 subscribe하면 Emit을 할 수 있다는 것은 동일합니다.

 

Mono와 Flux의 차이는, 내부의 아이템의 수입니다.

Flux는 0개~N개의 아이템을 방출할 수 있는 객체였다면, Mono는 0개~1개의 아이템을 방출할 수 있는 객체입니다.

 

Mono 역시 동일하게 다양한 Operator를 가지고 있습니다.

Flux와 동일하게 생성할 수 있는 static method들이 있고, 비동기 파이프라인을 구축하고 시퀀스를 만들어내는 instance method들이 있습니다.

 

 

Mono를 설명하는 그림입니다. Flux와 크게 다른 점이 없습니다.

다만 Optional Item이 Mono로부터 방출된다는 것만 차이가 있습니다.

onNext 신호를 통해 최대 하나의 아이템을 방출하고, onComplete 신호를 통해 Mono가 온전히 종료되었다는 것을 표현하고, onError를 통해 Mono의 실패를 나타낼 수 있습니다.

 

 

🤔 2. Mono와 Flux의 사용법

Mono와 Flux의 Operator는 지나치게 많기 때문에, 공식 레퍼런스에서도 모든 메서드를 숙지하지 않고, Which operator do I need? 챕터의 메서드를 살펴보는 것을 권장하고 있습니다. 이를 보고 번역 및 학습한 포스트를 주기적으로 업로드 하도록 하겠습니다.

2023.01.06 - [🌱 백엔드 : Backend] - [Spring WebFlux] 1. Mono와 Flux에 대한 이해(2) : 자주 사용하는 operator (method)

 

 

[링크] https://projectreactor.io/docs/core/release/api/reactor/core/publisher/Flux.html (Flux reactor reference)
[링크] https://www.youtube.com/watch?v=v0BnqWLxYjQ&list=LL&index=7&t=77s (백기선님 유튜브)