可观察与可流动 rxJava2

Question

我一直在看新的rx java 2，我不太确定我是否理解了< code >背压的概念...

我知道我们有没有背压支持的可观察和有背压支持的可流动。

因此，基于示例，假设我有可流动与间隔：

        Flowable.interval(1, TimeUnit.MILLISECONDS, Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Consumer<Long>() {
                @Override
                public void accept(Long aLong) throws Exception {
                    // do smth
                }
            });

这将在大约128个值之后崩溃，很明显，我的消费速度比获取物品要慢。

但是< code>Observable也是如此

     Observable.interval(1, TimeUnit.MILLISECONDS, Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Consumer<Long>() {
                @Override
                public void accept(Long aLong) throws Exception {
                    // do smth
                }
            });

这将不会崩溃，即使我把一些消费延迟，它仍然工作。为了使< code >可流动工作，假设我将< code>onBackpressureDrop操作符，崩溃消失了，但是也没有发出所有的值。

所以我目前在脑海中找不到答案的基本问题是，当我可以使用普通的可观察仍然可以在不管理缓冲区的情况下接收所有值时，为什么我要关心反向压力？或者从另一方面来说，反向压力给我带来了哪些有利于管理和处理消耗的优势？

Answer 1

您的 Flowable 在没有背压处理的情况下在发出 128 个值后崩溃，这一事实并不意味着它总是会在 128 个值之后崩溃：有时它会在 10 个值后崩溃，有时它根本不会崩溃。我相信这就是你用Operaperable尝试这个例子时发生的事情 - 碰巧没有背压，所以你的代码正常工作，下次它可能不会。RxJava 2的不同之处在于，可观察s中不再有背压的概念，也没有办法处理它。如果您正在设计一个可能需要显式背压处理的反应序列 - 那么 Flowable 是您的最佳选择。

Answer 2

背压是指当你的可观察对象(发布者)创建的事件多于你的订阅者能够处理的事件时。因此，您可能会让订户错过事件，或者您可能会得到一个巨大的事件队列，最终导致html" target="_blank">内存不足。< code >可流动考虑了背压。< code>Observable不会。就是这样。

这让我想起一个漏斗，当它有太多的液体溢出。可流动有助于避免这种情况发生:

在巨大背压下:

但是使用可流动的，背压要小得多 ：

Rxjava2有一些背压策略，您可以根据您的用例使用。通过策略，我的意思是Rxjava2提供了一种方法来处理由于溢出（背压）而无法处理的对象。

以下是策略。我不会一一介绍，但例如，如果你不想担心溢出的物品，你可以使用这样的放置策略：

可观察到的流量（背压策略.DROP）

据我所知，队列中应该有128项的限制，之后可能会有溢出（背压）。即使不是128，也接近这个数字。希望这能帮助到某人。

如果您需要更改128的缓冲区大小，看起来可以这样做(但是要注意内存限制:

myObservable.toFlowable(BackpressureStrategy.MISSING).buffer(256); //but using MISSING might be slower.  

在软件开发中，背压策略通常意味着您告诉发射器放慢一点，因为消费者无法处理您的发射事件的速度。

Answer 3

背压在实践中体现的是有界缓冲区，Flowable.observeOn有一个包含128个元素的缓冲区，它会尽可能快地耗尽。您可以单独增加此缓冲区大小以处理突发源，所有背压管理实践仍然适用于1. x。Observable.observeOn有一个无界缓冲区，它会不断收集元素，您的应用程序可能会运行内存溢出。

例如，您可以使用可观察性：

• 处理图形用户界面事件
• 处理短序列（总共少于 1000 个元素）

例如，您可以使用可流动：

• 冷源和非定时源
• 生成器如源
• 网络和数据库访问器