Java Reactor 라이브러리 Mono, Flux개념

Reactor란?

 

Reactor란?

https://projectreactor.io/에서 만든 Java라이브러리로 JVM기반의 non-blocking(논 블록킹) 어플리 케이션을 만들기 위한 라이브러리입니다.

 

 

1.Flux(플럭스)

flux를 사전에서 찾아보면 '유동', '흐름'이라는 뜻입니다.

Flux는 완료된 요청이나 오류가 발생해서 종료된 요청을 비동기 순서로 처리하는 표준 퍼블리셔입니다. 그래서 Flux의 값이 될 수 있는 것은 특정 값, 완료 시그널, 에러 이렇게 3가지 입니다. 리액티브 스트림 스펙에서 앞에 3가지 신호 타입은 각각 onNext, onComplete, onError 메소드로 처리합니다.

 

예제는 아래와 같습니다.

Flux<String> seq1 = Flux.just("foo", "bar", "foobar");

List<String> iterable = Arrays.asList("foo", "bar", "foobar");
Flux<String> seq2 = Flux.fromIterable(iterable);

flux는 값을 뽑아주는 Iterator(이터레이터)입니다.

 

 

2.Mono(모노)

Mono는 0 또는 1, 없음 또는 있음 등의 둘중 하나를 퍼블리셔 입니다.

 

Mono<String> noData = Mono.empty(); 

Mono<String> data = Mono.just("foo");

Flux<Integer> numbersFromFiveToSeven = Flux.range(5, 3); 

 

 

 

end.