RxJava API和Java9 Flow API之间的区别

Question

在Java最近几个主要版本的每一次迭代中，似乎都有管理并发任务的新方法。

在Java9中，我们有Flow API，它类似于RxJava的Flowable API，但在Java9中，它有一组简单得多的类和接口。

Java 9

具有类似流API的类的完整包，即io.reactivex.flowables、io.reactivex.subscribers、io.reactivex.processors、io.reactivex.observables，它们似乎做了类似的事情。

这两个库的主要区别是什么？为什么有人会使用Java9Flow库而不是更多样化的RxJava库，或者反之亦然？

Answer 1

这两个库的主要区别是什么？

Java9Flow API不是一个独立的库，而是Java Standard Edition库的一个组件，由采用2015年初建立的Reactive Streams规范的4个接口组成。理论上，它的包含可以支持in-JDK中的特定用法，例如孵化的HttpClient，可能是计划的parts中的异步数据库连接，当然还有SubmissionPublisher。

RxJava是一个Java库，它使用ReactiveX风格的API设计，在reactive（push）数据流上提供丰富的运算符集。版本2通过flowable和各种xxxprocessor实现了Reactive Streams API，该API允许其他兼容库使用flowable实例，进而可以将任何发布者包装成flowable来使用这些实例，并用它们组成丰富的操作符集。

因此,Reactive Streams API是最小的接口规范,RXJava2是它的一个实现,另外RxJava声明了一大组额外的方法,以形成自己丰富而流畅的API。

RXJava1启发了Reactive Streams规范，但不能利用它（必须保持兼容）。RXJava2是一个完整的重写版本和一个独立的主版本，它可以接受和使用Reactive Streams规范（由于Rsc项目，甚至可以在内部对其进行扩展），并且比Java9早一年发布。此外，决定v1和v2都支持Java6，从而支持大量的Android运行时。因此，它不能直接利用Java9提供的流API，而只能通过桥接。这种桥接器也被其它基于反应流的库所需要和/或提供。

RXJava3可能以Java9流API为目标，但这一点还没有决定，而且取决于后续Java版本带来的特性（即值类型），我们可能在一年左右的时间内不会有v3。

在此之前，有一个名为Reactive4JavaFlow的原型库，它实现了Flow API，并在其上提供了一个ReactiveX风格丰富的fluent API。

为什么有人会使用Java9Flow库而不是更多样化的RxJava库，或者反之亦然？

Flow API是互操作规范，而不是最终用户API。通常，您不会直接使用它，而是将流传递给它的各种实现。在讨论JEP 266时，作者没有发现任何现有库的API足够好，可以在Flow API中提供默认的内容（不像丰富的java.util.Stream)。因此，决定用户现在必须依赖第三方实现。

您必须等待现有的反应库通过它们自己的桥实现或将要实现的新库来支持Flow API。

在Flow API上提供丰富的运算符集只是库实现它的唯一原因。数据源供应商（即，反应型数据库驱动程序、网络库）可以开始通过流API实现他们自己的数据访问器，并依赖于丰富的库来包装这些访问器并为它们提供转换和协调，而不必强迫每个人实现各种这些操作符。

因此，一个更好的问题是，您现在应该开始使用基于流API的互操作还是坚持使用反应流？