리액티브 프로그래밍이란?

• 변화의 전파와 데이터의 흐름과 관련된 선언적 프로그래밍이다.

• 데이터가 생성 및 전달 되면 이에 반응하여 데이터를 처리하는 방식의 프로그래밍 모델.

• 프로그램에서 필요한 데이터를 직접 가지고와서 처리를 하는 방식(pull)이 아닌 데이터를 받는 시점에 처리하는 방식(push)

• 이를 구현하기 위해서 데이터를 만들어내는 **생성자(Publisher)**와 이를 소비하게 되는 **소비자(Subscriber)**로 역할을 나눠 처리하는 프로세스를 가지게 된다.

• 이처럼 역할이 명확하게 나눠져 있어 비동기 구현이 쉽다.

• [ ] 선언적 프로그래밍이란? 실행할 동작을 구체적으로 명시하는 명령형 프로그래밍과 달리 단순히 목표를 선언하는 방식을 가리킨다

• [ ] Reactive Stream이란?

  데이터 스트림을 비동기 방식으로 처리할 수 있는 공통 메커니즘 또는 인터페이스. 인터페이스만 제공하고 상세 구현은 라이브러리 또는 프레임워크에서 구현

  • [ ] Data Stream이란?

비동기(Async-await, Non-Blocking) 통신 방식

• 요청(Request)을 보내고 응답(Response)을 기다리지 않고 그 다음(Next) 또는 다른(Other) 일(로직)을 수행한다. 그러다가 응답 메시지가 도착하면 잠시하던 일을 멈추고 전달받은 응답 메시지에 대한 처리를 수행한다.
• 이러한 방식 때문에 비동기처리는 리액티브 프로그래밍 안에 포함된다.
• 예를 들어 아메리카노를 사러(Request) 스타벅스에 갔다고 생각해보자. 커피가 나올 때까지 우리는 커피만 보고 기다리지 않는다. a) 매장 내에 자리가 있는지 확인을 하거나, b) 함께 온 지인과 이야기를 나누거나, c) SNS을 보거나 한다. 그러다, (Response)나의 닉네임이 불리면 (응답에 대한 적절한 처리)커피를 가지러 간다.

리액티브의 개념이 적용된 예

• Push 방식 : 데이터의 변화가 발생했을 떄 변경이 발생한 곳에서 데이터를 보내주는 방식
  • RTC(Real Time Communication)
  • 소켓 프로그래밍
  • DB Trigger
  • Spring의 ApplicationEvent
  • Angular의 데이터 바인딩
  • 스마트폰의 Push 메시지
• Pull 방식 : 변경된 데이터가 있는지 요청을 보내 질의하고 변경된 데이터를 가져오는 방식
  • 클라이언트 요청 & 서버 응답 방식의 애플리케이션
  • Java와 같은 절차형 프로그래밍 언어

리액티브 프로그래밍을 위해 알아야 될 것들

• Observable : 데이터 소스 (변경되는 데이터 관찰)
• 리액티브 연산자(Operators) : 데이터 소스를 처리하는 함수
• 스케쥴러(Scheduler) : 스레드 관리자