RxJS 是一个功能强大的 JavaScript 库，它是基于 ReactiveX 规范的实现。RxJS 提供了一系列操作符，让我们可以简洁、易读地处理异步数据流。在这些操作符中，Flowable 和 Backpressure 是非常重要的概念。
什么是 Flowable
Flowable 是 RxJava 的概念，它是一个支持背压（Backpressure）的 Observable。背压是一种用于控制数据流速的机制，在我们需要处理大量数据流的时候非常有用。Flowable 可以使得数据的生产者和消费者之间的速度匹配。
RxJS 中的 Flowable 支持背压，不同于 Observable 的是 Flowable 可以发出一个未来的回执给生产者，告诉他们数据消费的情况。这就给了生产者更多的掌控，可以在高峰期间限制或者缓慢数据流的发布，以防止生产线被压垮。
什么是 Backpressure
Backpressure 是一个用于控制流量的机制，用于调整生产者和消费者之间的速率。当数据流的发布速度大于消费速度的时候，Backpressure 机制就会启动。这个机制会告诉生产者，在哪些情况下需要暂停数据流的发布，直到消费者已经准备好接收更多的数据。
常见的 Backpressure 模式有四种：
- Drop：直接丢弃数据，不做任何处理
- Buffer：将数据放入缓冲区，等待消费者从缓冲区中读取数据
- Latest：丢弃旧数据，只保留最新的数据
- Error：当消费者准备接收数据的时候，立即抛出一个错误
Flowable 和 Backpressure 的实现
RxJS 的 Flowable 在 RxJava 基础之上进行了优化和改进，提高了性能和可用性。Flowable 实现了 ReactiveX 规范中的 Backpressure 功能，以下是 Flowable 和 Backpressure 的实现方式：
-- -------------------- ---- -------
------ - ---- - ---- -------
------ - ------------ ---------- - ---- -----------------
----- ------ - -------- -- -- -- -- -- -- -- -- -----
------
------
---------------
------------------ -- -
-------------------
------ ---
--
-
------------------- -- ---------------------上述代码是一个简单的 Flowable 实现，它通过 bufferCount 操作符控制了数据的流量。当 source 发出的数据量达到 5 个时，bufferCount 就会将这些数据值打包成数组发出，并且先前的数据就会在缓冲区中消失。当 source 的数据流速度弱于 bufferCount 的输出速度时（也就是后者更快），catchError 操作符会阻塞 source 生产者，以防止缓冲区溢出。
总结
Flowable 和 Backpressure 是 RxJS 中非常重要的概念。Flowable 支持背压，可以使生产者和消费者之间的速率匹配。而 Backpressure 则是用于控制流量的机制，常见的模式有 Drop、Buffer、Latest 和 Error。RxJS 的 Flowable 和 Backpressure 实现非常简单，可以通过 bufferCount、catchError 等操作符轻松地控制数据流的速度，提高数据的处理能力和可用性。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64e4b1a7f6b2d6eab302826e