Publisher와 Subscriber간의 프로세스

Backpressure란?

Publisher에서 Emit되는 데이터를 Subscriber쪽에서 안정적으로 처리하기 위한 제어 기능

Reactor에서의 Backpressure 처리 방법

• 요청 데이터의 개수를 제어하는 방법
  • Subscriber가 적절히 처리할 수 있는 수준의 데이터 개수를 Publisher에게 요청
• Backpressure 전략을 사용하는 방법
  • Reactor에서 제공하는 Backpressure 전략을 사용

Backpressure 전략

• IGNORE 전략
  • Backpressure를 적용하지 않는다
• ERROR 전략
  • Downstream으로 전달할 데이터가 버퍼에 가득 찰 경우, Exception을 발생시키는 전략
• DROP 전략
  • Downstream으로 전달할 데이터가 버퍼에 가득 찰 경우, 버퍼 밖에서 대기하는 먼저 Emit된 데이터부터 Drop 시키는 전략
• LATEST 전략
  • Downstream으로 전달할 데이터가 버퍼에 가득 찰 경우, 버퍼 밖에서 대기하는 가장 최근에(나중에) Emit된 데이터부터 버퍼에 채우는 전략
• BUFFER 전략
  • Downstream으로 전달할 데이터가 버퍼에 가득 찰 경우, 버퍼 안에 있는 데이터를 Drop시키는 전략

Drop 전략