본격적으로 Reactive Stream 에 대해 알아보겠다. (by java.util.concurrent.Flow) Publisher Reactive Stream 의 Publisher 이다. - publisher 는 데이터 혹은 이벤트(메시지)를 제공한다. subscribe - publisher 에 subscriber 를 등록할 수 있다. (다수를 등록할 수 도 있다.) Subscriber Reactive Stream 의 Subscriber 이다. Subscriber 는 Publisher 로 부터 다양한 이벤트가 들어오는 채널을 구현해야한다. 참고 publisher 에서 subscriber 에게 데이터 혹은 이벤트를 전달하는 방식은 push 방식이다. onSubscribe - publisher 에서 호출..

Marble Diagram 이란.. projectreactor 의 Reactor 를 사용하면 자주 보이는 다이어그램이다. Marble Diagram 은 Mono 와 Flux 의 연산자 동작을 시각적으로 보여주기 위함이며, javadoc 전체에서 쉽게 볼 수 있을 것이다. Marble Diagram 읽는 법 위의 화살표는 시간의 흐름을 나타낸다. 왼쪽에서 오른쪽 방향으로 시간 순서이다. 위 다이어그램에서 도형은 파이프라인을 지나는 하나의 element 라 보면된다. 세로 선은 onComplete 이벤트를 뜻한다. C 다이어그램에서는 타임라인에 "X" 표시가 있는데 이는 onError 이벤트가 발생되었음을 나타낸다. D 다이어그램에서는 타임라인에 element 만 존재하고, 이벤트는 발생하지 않아서 종료 되..

개념이 헷갈려 간단하게 정리해보겠다.. 두 개념 모두 분산 환경에서 메시지 교환 방식을 효과적으로 관리하는데 사용되는 패턴이다. Event-Driven Architecture (EDA) 시스템이 특정 이벤트에 반응하여 동작하는 방식이다. 이벤트는 시스템의 상태가 변경되었음을 나타내고, 해당 이벤트는 다른 구성 요소가 구독하거나 반응할 수 있다. 이벤트의 생성, 감지, 소비를 중심으로 하는 아키텍처인 것이다.. 따라서 비동기성, 느슨한 결합 등의 특징이 있다. Pub/Sub Model Event-Driven Architecture 에 속하는 특정 유형이라 볼 수 있다. Publisher 는 이벤트 또는 메시지를 생성하고.. Subscriber 는 해당 메시지를 수신한다. Publisher 와 Subscri..