반응형

mono 2

[WebFlux] 리액티브 스트림즈 Sinks: 핵심 개념과 활용 가이드

Reactor의 Sinks는 리액티브 스트림즈에서 프로그래밍 방식으로 Signal을 전송하는 표준 메커니즘입니다. 기존 Processor의 한계를 극복하고, 멀티스레드 환경에서 안정적인 데이터 방출을 보장합니다.(Reactor 3.4.0+부터 도입, Processor는 3.5.0+에서 deprecated) 1. Sinks의 주요 특징Signal 수동 방출: onNext, onComplete, onError를 코드로 직접 제어 가능스레드 안전성(Thread Safety): 동시 접근 시 경쟁 조건 방지 (예: FAIL_FAST 전략)다중 구독자 지원: unicast, multicast, replay 등 다양한 전략 제공백프레셔 관리: 구독자의 요청에 따른 자동 흐름 제어 2. Sinks 종류 및 사용법..

Reactor: Spring WebFlux의 리액티브 스트림즈 구현체

Reactor는 Spring WebFlux의 핵심 라이브러리로, 비동기 데이터 스트림을 처리하기 위한 리액티브 스트림즈 구현체입니다. Spring Framework 5부터 공식적으로 채택되어 사용되고 있으며, 비동기 프로그래밍 모델을 통해 효율적인 리소스 사용과 확장성을 제공합니다. Reactor의 핵심 특징리액티브 스트림즈 구현Reactor는 리액티브 스트림즈 사양을 준수하는 라이브러리로, 비동기 데이터 처리를 위한 표준 인터페이스를 구현합니다. 이를 통해 Publisher, Subscriber, Subscription, Processor와 같은 리액티브 스트림즈의 핵심 인터페이스를 제공합니다. 비동기 논블로킹 처리Reactor는 비동기 논블로킹 방식으로 작동하여 적은 수의 스레드로 많은 요청을 처리할..

반응형