RxJava2中Observable.toFlowable()触发OOM的原因咨询

核心差异原因在于两者的背压处理逻辑完全不同： #

• Observable无背压特性导致全量内存占用
  Observable设计时不支持背压，它会以最快速度推送所有数据到下游。当你通过toFlowable(BackpressureStrategy.BUFFER)转换时，RxJava会创建一个缓存区来接收Observable发送的全部元素——但Observable不会响应下游的背压请求，会一次性把100000个Integer对象全部塞进缓存。在仅20M的堆内存下，这种全量缓存直接耗尽内存，触发OOM。

• Flowable.fromIterable天然支持背压，按需加载数据
  Flowable本身是为背压场景设计的。当直接使用Flowable.fromIterable时，上游的Iterable数据源会根据下游的需求来生成元素：下游的delay操作符会根据自身处理节奏向上游请求数据，上游不会一次性把所有元素加载到内存中。哪怕把第二个例子的元素数量改成100000，也不会出现OOM，因为数据是按需流动的，内存中不会堆积大量未处理元素。

• 关于BUFFER策略的补充
  BackpressureStrategy.BUFFER的作用是缓存上游发送的元素，但它的安全前提是上游能响应背压。如果上游是无背压的Observable，这个缓存就会被瞬间填满；而Flowable.fromIterable作为有背压的上游，只会发送下游能处理的元素，缓存不会出现大规模堆积。

内容的提问来源于stack exchange，提问作者dname