리액티브 시스템 & Reactive Streams 정리

카테고리 없음

seungh0 2024. 2. 3. 00:44

리액티브 선언문

방법
- 메시지 구동: 리액티브 시스템에서 주요 통신 수단으로 비동기 메시지 기반의 통신을 통해 구성 요소들의 느슨한 결합, 격리성, 위치 투명성을 보장.
형태:
- 탄력성
  - 시스템의 작업량이 변화하더라도 일정한 응답을 유지하는 것.
  - 시스템으로 유입되는 입력이 많든 적든 간에 시스템에서 요구하는 응답성을 일정하게 유지하는 것.
- 회복성
  - 시스템에 장애가 발생하더라도 응답성을 유지하는 것
  - 이러한 회복성을 확보하기 위해, 리액티브 시스템의 구성요소들은 비동기 메시지 기반 통신을 통해 느슨한 결합과 격리성을 보장.
값
- 응답성
  - 비동기 메시지 기반 통신을 바탕으로 한 회복성과 탄력성을 확보함으로써 즉각적으로 응답 가능한 시스템을 구축할 수 있음을 의미.

리액티브 시스템에서의 비동기 메시지 통신은 Non-Blocking I/O 방식의 통신입니다.
- Blocking I/O 방식의 통신에서는 해당 스레드가 작업을 처리하려면 처리할 때 까지 남아있는 작업들은 해당 작업이 끝날 때 까지 차단되어 대기합니다.
- 반면에 Non-Blocking I/O 방식의 통신에서는 스레드가 차단되지 않음.

리액티브 라이브러리를 어떻게 구현할지 정의해둔 별도의 표준 사양.
- 데이터 스트림을 Non-Bloking이면서 비동기적인 방식으로 처리하기 위한 리액티브 라이브러리의 표준 사양.
- Reactive Streams를 구현한 구현체로는 Rxjava, Reactor, Akka Streasm, Java 9 Flow API 등이 존재.

Subscriber는 전달 받을 데이터를 구독합니다. (subscribe)
Publisher는 데이터를 통지할 준비가 되었음을 Subscriber에게 알린다(onSubscribe)
Publisher가 데이터를 통지할 준비가 되었다는 알림을 받은 Subscriber는 전달받기를 원하는 데이터의 갯수를 Publisher에게 요청합니다 (Subscription.request)
- Publisher가 통지하는 속도가 Publisher로부터 통지된 데이터를 Subscriber가 처리하는 속도보다 더 빠르면 처리를 기다리는 데이터는 쌓이게 되고, 이는 결과적으로 시스템 부하가 커지는 결과를 낳게 됨.
- 이러한 문제를 해결하기 위해 Subscription.request를 통해 데이터 갯수를 제어하는 것.
다음으로 Publisher는 Subscriber로부터 요청받은 만큼 데이터를 통지합니다 (onNext)
이렇게 Publisher와 Subscriber 간에 데이터 통지, 데이터 수신, 데이터 요청 과정을 반복하다가 Publisher가 모든 데이터를 통지하게 되면 마지막으로 데이터 전송이 완료되었음을 Subscriber에게 알립니다. (onComplete). 만약에 Publisher가 데이터를 처리하는 과정에서 에러가 발생하면 에러가 발생했음을 Subscriber에게 알립니다(onError)

public interface Publisher<T> {
   void subscribe(Subscriber<? super T> s);
}

public interface Subscriber<T> {
  void onSubscribe(Subscription s);
  void onNext(T t);
  void onError(Throwable t);
  void onComplete();
}

public interface Subscription {
  void request(long n);
  void cancel();
}

public interface Processor<T, R> extends Subscriber<T>, Publisher<R> {

}