'Spring/Spring WebFlux' 카테고리의 글 목록

[📕 Reactive] Operators 中

2025.01.02

Sequence 변환 Operator✳️ mapupstream에서 emit된 데이터를 mapper function을 사용해 변환한 후, downstream으로 emitmap() operator 내부에서 에러 발생 시 sequence가 종료되지 않고 계속 진행되도록 하는 기능 지원 Mono mono = Mono.just("Reactor") .map(String::toUpperCase);mono.subscribe(System.out::println); // 출력: REACTOR ✳️ flatMapupstream에서 emit된 데이터가 Inner Sequence에서 평탄화 작업을 거치면서 하나의 Sequence로 병합되어 downstream으로 emitpublic class Example { public..

Spring/Spring WebFlux

[📕 Reactive] Spring WebFlux

2024.12.26

Spring WebFlux 개요Spring 5.0부터 지원하는 리액티브 웹 프레임워크로, 적은 수의 스레드로 대량의 요청을 안정적으로 처리할 수 있는 비동기 Non-Blocking I/O 방식을 사용한다. Spring WebFlux 기술 스택 ✳️ Spring MVC와 Spring WebFlux 기술 스택 비교 🔷 서버Spring MVC서블릿 기반의 프레임워크Apache Tomcat같은 서블릿 컨테이너에서 Blocking I/O 방식으로 동작Spring WebFluxNon-Blocking I/O 방식으로 동작하는 Netty 등의 서버 엔진에서 동작 🔷 서버 APISpring MVC서블릿 API 사용Spring WebFlux Jetty나 Undertow 같은 서버 엔진에서 지원하는 리액티브 스..

Spring/Spring WebFlux

[📕 Reactive] Operators 上

2024.12.24

Operator란 ?Reactive Stream의 데이터 흐름을 처리하거나 변환하는 역할을 하는 메서드 🔷 특징 비동기 처리조합 가능성지연 실행 (구독이 호출되어야 처리)데이터 흐름을 단계적으로 처리 Sequence 생성을 위한 Operator✳️ justOrEmptyjust()의 확장 operator로서, emit할 데이터가 null인 경우 NullPooinException이 발생하지 않고, onComplete signal을 전송just()는 Reactor에서 간단하고 정적인 데이터를 Reactive Stream으로 변환할 때 유용- Hot Publisher이기 때문에 Subscriber의 구독 여부와는 상관없이 데이터를 emit.- 구독이 발생하면 emit된 데이터를 다시 replay해서 Sub..

Spring/Spring WebFlux

[📕 Reactive] 6. Sinks와 Scheduler

2024.12.23

Sinks 란 ?Reactor에서 제공하는 Sinks는 비동기 데이터를 안전하게 발행할 수 있는 유틸리티로, Publisher 및 Subscriber 역할을 지원한다. 일반적으로 generate() operator나 create() operator는 싱글스레드 기반에서 signal을 전송하는 데 사용하는 반면, Sinks는 멀티스레드 방식으로 signal을 전송해도 스레드 안전성을 보장하기 때문에 예기치 않은 동작으로 이어지는 것을 방지해준다. 💡스레드 안전성이란 ? 함수나 변수 같은 공유 자원에 동시 접근할 경우에도 프로그램의 실행에 문제가 없음을 의미한다.동시 접근을 감지하고, 동시 접근하는 스레드 중 하나가 빠르게 실패함으로써 스레드 안전성을 보장한다. Sinks 종류 및 특징 ✳️ Sink..

Spring/Spring WebFlux

[📕 Reactive] 5. Reactor

2024.12.19

Reactor란 ? 리액티브 프로그래밍을 위한 라이브러리 Spring Framework 팀에 의해 개발된 리액티브 스트림즈의 구현체로서 Spring WebFlux 기반의 리액티브 어플리케이션을 제작하기 위한 핵심 역할을 담당한다.✳️ Reactor의 특징 Reactive StreamsNon-BlockingJava's Functional APIFlux[N]Mono[0|1]MicroservicesBackpressure Mono 기본 예제public class Example { public static void main(String[] args) { Mono .empty() .subscribe( none -> System.out.println(..

Spring/Spring WebFlux

[📕 Reactive] 4. Reactive 프로그래밍을 위한 사전 지식

2024.12.18

1. 함수형 인터페이스단 하나의 추상 메서드만 있는 정의되어있는 인터페이스 (Java 8부터 지원 가능)함수를 값으로 취급하기 때문에 어떤 함수를 호출할 때 함수 자체를 파라미터로 전달 가능public class Example { public static void main(String[] args){ List cryptoCurrencies = SampleData.cryptoCurrencies; Collections.sort(cryptoCurrencies, new Comparator() { @Override public int compare(CryptoCurrency cc1, CryptoCurrency cc2) { r..

Spring/Spring WebFlux

[📕 Reactive] 3. Blocking I/O와 Non-Blocking I/O

2024.12.17

1. Blocking I/O하나의 스레드가 I/O에 의해서 차단되어 대기하는 것 멀티스레딩 기법으로 추가 스레드를 할당하여 차단된 그 시간을 효율적으로 사용할 수는 있으나, 여러 문제 발생 컨텍스트 스위칭으로 인한 스레드 전환 비용과다한 메모리 사용으로 오버헤드 발생 가능 새로운 스레드가 실행되면 JVM에서는 해당 스레드를 위한 스택 영역의 일부 할당하며, 새로운 스레드 정보는 스택 영역에 개별 프레임 형태로 저장됨 👉 각각의 스레드 내부에서 또 다른 작업을 처리하기 위해 추가로 할당하게 된다면 메모리 사용량 감당하기 힘들 정도로 늘어남스레드 풀에서 응답지연 발생일정 개수의 스레드를 미리 생성해서 풀에 저장해 두고 사용자의 요청이 들어오면 풀에서 꺼내 사용 가능하나, 유후 스레드가 없다면 사용 가능한..

Spring/Spring WebFlux

[📕 Reactive] 2. Reactive Streams

2024.12.16

1. 리액티브 스트림즈란 ? 데이터 스트림을 Non-Blocking이면서 비동기적인 방식으로 처리하기 위한 리액티브 라이브러리의 표준 사양 ✳️ publisher와 subscriber 간에 데이터 전달 동작 과정 subscriber는 전달받을 데이터 구독 (subscribe)publisher는 데이터 통지할 준비되었음을 subscriber에 알림 (onSubscribe)publisher가 데이터를 통지할 준비가 되었다는 알림을 받은 subscriber는 전달받기를 원하는 데이터의 개수를 publisher에게 요청 (Subscription.request)publisher는 subscriber로부터 요청받은 만큼의 데이터를 통지함 (onNext)publisher와 subscriber 간에 데이터 통지, 데이..

티스토리툴바