리액티브 프로그래밍

Jun 03, 2020 조회수 203

1강

외부에 어떤 이벤트가 발생하면, 거기에 대응하는 방식으로 코드를 작성하는것

// Duality
// Obeserver Pattern
// Reactive Streams - 표준

for-each는 Iterable

// Iterable <--> Observable (duality)
// duality 기능은 똑같음, 그러나 반대 (쌍대성)
// DATA method <-> void method(DATA)

Iterabale : pull 방식
Observable : push 방식

자바인터페이스 Observable

Observable // Source -> Event/Data -> Observer

// - 옵저버패턴은 부족하다..!!!
// 1. 끝이라는 개념이 없음 (Complete가 없다)
// 2. Error 처리가 없다
// 옵저버를 확장하자 = @리액티브프로그래밍에 한축

Observable == Publisher
Observer == Subcribe

Observable.addObserver() == Publisher.subcribe()

Publisher.subcribe() 호출 시

//Subcriber 내부에
//onSubribe를 최초에 반드시 실행
//onNext ( 1 ~ N번 호출)
// onError, onComplete 둘중에 하나 호출
onSubscribe onNext* (onError | onComplete)?

onSubscribe(subscription) // subscription = publisher와, subcriber의 중개

subscription 통해서 요청 할 수 있음
publisher와 subscribe의 속도차를 subscription을 통해 (나 지금 바쁘니까, 몇개만 보내줘!) or (일단 한개만 줘봐!) or (계속줘!)

subscription은 왜 필요할까?
publisher가 100만개 엄청 빨리 쏴주는데, subscriber가 1개에 1초씩 걸린다..
둘사이에 중개가 필요하다.

@ 또다른 하나의 축 스케줄러

publisher가 작업이 많아서,
쓰레드를 여러개만들어 병렬적으로 onNext를 호출해도되느냐
-> NoNo 안됨,
-> subcriber는 시퀀스한 값을 보장받아야함.
-> 즉 한 쓰레드에서만 하나의 subcriber에 보내야됨

<br/>

// Reactive Streams - Operator
// Publisher -> Data -> Subscriber
// Publisher -> Data -> Ope1 -> Date2 -> Oper2 -> Data3 -> Subscriber

<br/>

**Thread pool Hell **

2~4시 Thread 개수 부족,
문제는 latency가 느려짐 ( 사용자 응답 시간)

왜그럼 thread pool hell이 발생하는가?

하나의 요청을 받아서 서버가 처리하는 동안에
서버가 또 다른 리모트서버에 여러 요청을 보내고
이 요청을 다 조합해서 결과를 리턴함.

하나 하나 에대해서 최선의 성능을 발생하도록 하겠지만,
보통은 0.1~0.2초 이지만,
예를 들어, 5개 정도의 순차적으로 응답한다면, 총 1초가 걸림.
따라서 1총동안 하나의 요청을 물고있고,
thread가 꽉차고, 레이턴시가 느려짐.

서버에서 또다른 리모트로 요청을 보내는 동안 cpu는 놀고있음.
그런데 thread는 가지고 있음.. 따라서 레이턴시가 느려지게 되있음.

'리액티브 프로그래밍' 관련된 다른글

이전 댓글 보기

알림

등록

이 포스팅은 쿠팡 파트너스 활동의 일환으로, 이에 따른 일정액의 수수료를 제공받습니다.