비교

배압(Back Pressure)이란?

Flowable에서 데이터를 통지하는 속도가 Subscriber에서 통지된 데이터를 전달받아 처리하는 속도 보다 따를 때 밸런스를 맞추기 위해 데이터 통지량을 제어하는 기능이다.

<aside> 💡 왜 밸런스를 맞춰야 할까?

발행자는 데이터를 빠른 속도로 보내고 구독자는 데이터를 느리게 처리하면서 어느순간 처리하지 못한 많은 양의 데이터가 쌓이게된다. 이때 데이터가 쌓여진 곳에 OOM 같은 이유로 유실된다고 했을 때 문제가 발생할 수 있다. 이런 이유로 데이터 처리속도가 불균형일 때 RxJava에서는 예외를 발생시킬 수 있다.

</aside>

배압 전략(BackpressureStrategy)

RxJava에서는 전략을 통해 Flowable이 통지 대기 중인 데이터를 어떻게 다룰지에 대한 배압 전략을 제공한다.

M ISSING 전략

• 배압을 적용하지 않는다.
• 나중에 onBackpressureXXX() 로 배압 적용을 할 수 있다.

ERROR 전략

• 통지된 데이터가 버퍼의 크기를 초고하하면 MissingBackpressureException 예외를 발생시킨다.
• 즉, 소비자가 생산자의 통지 속도를 따라 잡지 못할 때 발생한다.

BUFFER 전략

• DROP_LATEST
  • 버퍼가 가득 찬 시점에 버퍼내에서 가장 최근에 버퍼로(큐 마지막) 들어온 데이터를 DROP
  • DROP 된 빈 자리에 버퍼 밖에서 대기하던 데이터를 채운다.
• DROP_OLDEST
  • 버퍼가 가득 찬 시점에 버퍼내에서 가장 오래전에(먼저) 버퍼로 들어온 데이터를 DROP한다.
  • 버퍼 밖에서 대기하던 데이터를 채운다. (DROP된 자리에 채우는 것이 아닌 버퍼 마지막에 추가됨)
• DROP
  • 버퍼에 데이터가 모두 채워진 상태가 되면 이후에 생성되는 데이터를 버리고(DROP), 버퍼가 비워지는 시점에 DROP되지 않은 데이터부터 다시 버퍼에 담는다.
• LATEST
  • 버퍼에 데이터가 모두 채워진 상태가 되면 버퍼가 비워질 때까지 통지된 데이터는 버퍼 밖에서 대기하며, 버퍼가 비워지는 시점에 가장 나중에(최근에) 통지된 데이터부터 버퍼에 담는다.