避免遗漏背压异常

Question

从C#开始，当我使用RX并且有背压时，项目会不断地添加到内部队列中，直到应用程序运行内存溢出（据我所知）。

在ReactiveX（RXJava）中，似乎他们采取了不同的立场，在背压开始构建时抛出异常。

这意味着我必须使用类似于onBackpressureBuffer（）和在调用subscribe（）时传入一个订阅者

可能是因为我用的是RX。NET的方法，但对我来说，这似乎是精神上的。

首先，我的理解是否正确？

其次，我是否可以“禁用”此功能，使其与RX的行为方式相同。NET，因为我不想让我的subscribe（）调用复杂化，因为我必须检查是否实现了这些背压操作符中的一个，以查看是否必须调用request（）。




Answer 1

大多数时候，正确的方法是使用良好的背压策略，例如onBackPressureDrop。但是，记住这样做很容易出错。

当我们转换到RxJava2时，我们意识到大约100%的观察对象只想使用onBackPressureBuffer。在这种情况下，我们增加了rx。环形缓冲器。大小，防止了所有背压崩溃，继续我们的生活。

https://eng.uber.com/rxjava-backpressure/

Answer 2

背压相关的异常发生在源可观察不支持背压的情况下，很少有与时间相关的运算符有这种行为，并且许多可观察运算符是为0.20之前的版本实现的。另一方面，订阅者默认以无界模式运行（他们请求Long.MAX_VALUE并且从不费心请求更多）。大多数运算符在这种情况下都有快速路径，或者根本不干扰背压。

异常最常见的来源是observeOn和merge操作符。您需要重新实现它们。ObserveOn可以切换到无界队列，merge可以完全跳过使用队列。下面是这两个操作符的示例实现。

Answer 3

在scala中（我不知道Java语法，但方法调用是相同的），您只需要

bservable.subscribe

成

<代码>fastHotObservable。反向压力缓冲器。订阅（下一个=

这应该可以做到。当然，在运行它时，必须有一段时间处于非活动状态，因此进程偶尔会有时间来追赶和处理缓冲的元素。

我不认为这是心理上的，我觉得很好，你可以选择自己处理未处理的背压的策略，而不是被迫选择适合你的策略。我也更喜欢明确地指定它。

事实上，战略是RX。网络使用并不总是最好的。最近我一直在使用一些onBackpressureDrop调用来忘记我没有时间处理的鼠标移动，我很高兴我可以避免这么容易地缓冲它们。