📘 Backend/Spring
Spring - Reactive Streams
신건우
2023. 4. 4. 13:15
📘 Reactive System & Reactive Programming
- 선언형 프로그래밍(Lambda 표현식, Stream API), 순차 실행 X
- Reactive System은 Requst Thread의 응답 대기시간을 최소화 할 수 있게 Non-Bloking 통신 지원함
- Reactive Programming 에서의 반응은 Thread의 Non-Blocking과 관련이 있다.
Reactive System 설계 원칙
Means - 리액티브 시스템의 커뮤니케이션을 담당
- Message Driven
- 리액티브 시스템은 메세지 기반 통신을 통한 시스템 간 느슨한 결합 유지
Form - 메세지 기반 통신을 통한 구조 형성
- Elastic
- 트래픽량에 관계없이 일정한 응답성 유지
- Resiilient
- 시스템 장애 발생 시, 응답성 유지
Value - 리액티브 시스템의 핵심 가치 표현
- Responsive
- 즉각 응답
- Maintainable
- 즉각 응답의 지속
- Extensible
- 요청 처리의 오토스케일링
Reactive Programing 특징
Declarative Programming Paradigm
- 선언형 프로그래밍 방식 사용
Data Streams and The Propagation of Change
- 지속적인 데이터의 요청이 있음을 의미하며, 요청 = 변경이벤트로 간주해 이벤트 발생시 마다 데이터 전달
- Automatic Propagation of the Changed Data Flow
- 위와 동일
- Reactive Streams
- Reactive Programming을 사용하기 위한 Specification
📘 Components of Reactive Streams
**Publisher<T>**- 소스로부터 데이터 emit
subscribe(Subscriber<? super T>)- Subscriber가 Publisher가 내보낸 데이터 소비
**Subscriber<T>**- Publisher가 내보낸 데이터 소비
- onSubscribe(Subscription)
- 구독 시작 시 호출, Publisher에게 요청할 데이터의 개수 지정 & 구독 해지 처리
- onNext(T)
- 데이터 emit 시 호출, emit된 데이터 소비
- onError(Throwable)
- emit 데이터 -> Subscriber 전달 시 오류 발생되면 호출
- onComplete()
- 데이터 emit 종료 시 호출, emit후 처리할 작업이 있으면 여기서 수행
**Subscription**- 구독상태를 표현한 인터페이스
- request(long)
- emit 개수 요청
- cancle()
- 구독 해지, 해지시 더 이상 데이터 emit X
`Processor<T, R>`` extends Subscriber
, Publisher
- Publisher, Subscriber 의 역할을 동시에 처리
📘 Implementation Reactive Streams
Project Reactor
- Spring Reactive Application 구현의 대표적인 구현체, Spring 5의 Reactive Stack에 포함
RxJava
- .NET 기반 Reactive Library를 Netflex에서 Java 언어로 포팅한 JVM 기반 Reactive 확장 라이브러리
Java Flow API
- Java9 부터 지원
- Reactive Streams의 구현체들의 SPI역할
- Reactive Streams의 Specification을 Java안에 포함 시킨 구조
Signal
- Publisher가 발생시키는 이벤트
Operator
- 동작 수행 메소드
Sequence
- 메소드 체인을 하나의 시퀀스로 간주
UpStream & DownStream
- Sequence 기준 위 아래를 의미 (ex. filter() 기준)
Reactive Extension
- RxJS, RxAndroid, RxKotlin, RxPython, RxScala