반응형

RxJava 2

리액티브 스트림즈(Reactive Streams) 핵심 정리

리액티브 스트림즈는 비동기·논블로킹 환경에서 데이터 스트림을 처리하기 위한 표준 사양으로, 대규모 트래픽 처리와 시스템 효율성 향상에 기여합니다.1. 주요 용어▷ SignalPublisher와 Subscriber 간 주고받는 상호작용 메시지 (예: onNext, onComplete).데이터 상태/이벤트를 전달하는 신호.▷ DemandSubscriber가 요청했으나 아직 처리되지 않은 데이터의 양.▷ EmitPublisher가 onNext를 통해 데이터를 발행하는 행위.▷ Upstream/DownstreamUpstream: 현재 메서드보다 상위의 데이터 소스 (예: just → filter에서 just는 Upstream).Downstream: 하위 처리 단계 (예: filter → map에서 map은 Do..

[WebFlux 심층 분석] 리액티브 스트림즈의 핵심 개념과 구현 전략

리액티브 스트림즈(Reactive Streams)는 비동기적이고 Non-Blocking 방식으로 데이터 스트림을 처리하기 위한 표준입니다. 이 표준은 데이터 전송의 효율성을 높이고, 시스템 간의 느슨한 결합을 유지하면서 데이터 흐름을 관리할 수 있도록 설계되었습니다. 리액티브 스트림즈의 주요 구성 요소Publisher (발행자)데이터를 생성하고 제공하는 역할Subscriber에게 데이터를 전달Subscriber (구독자)Publisher로부터 데이터를 받아 처리하는 역할데이터를 수신하고 필요한 작업 수행SubscriptionPublisher와 Subscriber 간의 연결 관리데이터 요청 개수 지정 및 구독 취소 기능 제공ProcessorPublisher와 Subscriber의 기능을 모두 가진 중간 처..

반응형