Reactive Streams를 공부해보자!

❓ Publisher 와 Subscriber

💧 Publisher : 특정 조건이나 이벤트가 발생했을 때 메시지를 보내는 주체

☂ Subscriber : Publisher에 의해 전송된 메시지중에서 조건에 맞게 필터링된 메시지를 받아서 처리하는 주체

---

❓ Cold Sequence와 Hot Sequence

1,2,3,4 를 차례대로 publish하는 Publisher가 있다고 가정하자.

1이 publish된 이후에 Subscriber1가 Subscribe한다.

3이 publish된 이후에 Subscriber2가 Subscribe한다.

1. ❄ Cold Sequence

🔂 Subscriber가 Subscribe하는 시점에서 처음부터 지금까지 Publish된 과정을 다시 시작.

위와 같은과정에서 Subscriber1과 Subscriber2 모두 1부터 4까지 모두 Publish받게 된다.

2. 🔥 Hot Sequence

🔂 Subscriber가 Subscribe하는 시점에서부터 Publish된 것만을 Subscribe.

위와 같은과정에서 Subscriber1은 2,3,4를 Subscriber2는 4를 Publish받게 된다.

다음으로는 Reactor에서의 Publisher와 Subscriber를 공부해볼 예정이다.