ReactiveX是什么为什么

ReactiveX是什么

是一个库，用于“使用一个可观测的序列组成异步和基于事件的程序”

解读：
用在异步和基于事件的程序中。例如网络，输入输出，用一个可观测的序列对这种程序进行组织。


扩展了观察者模式，来支持数据序列或者事件序列，并且添加操作符来把序列组合起来，而不用关心底层的线程化，同步，线程安全，并发数据结构，以及非阻塞IO。

解读：
扩展了观察者模式，支持数据序列（文件或者网络数据）和事件序列（Event），并且用陈述的方式把序列组织起来，
不用关心线程化，同步，线程安全，并发数据结构以及非阻塞IO


可观察对象填补了鸿沟，通过一个理想的方式去获取异步序列。

synchronous:
T getData()
Iterable<T> getData()
asynchronous:
Future<T> getData()
Observable<T> getData()

解读：
对比可以看出来。Observable对应的同步对象是Iterable，是一个迭代模式。
ReactiveX 操作在时间序列上的离散值。

核心概念： 操作在离散序列上的。

2. 为什么使用Observables？


a)  可组合的：
Java Future这种技术是一个比较直接的技术，来执行单个级别的异步执行，但是他们开始增加不可忽略的复杂度，当它们嵌套在一起的时候。很难用Future 组合基于条件的异步执行流。
ReactiveX Observables, 与之不同，就是为了组合异步数据的流或者序列。

b) 灵活的。

ReactiveX Observables 不仅支持发送单个scaler数据，而且可以发射一系列数据，或者数据流。Observable是一个抽象，可以用于这两种任意一个场景。一个Observable与Iterable是同样优美和灵活。

c)Observables Are Less Opinionated. Observable 不是偏见的。

  ReactiveX并不偏向某些特定的并发或异步源。 可以使用线程池，事件循环，非阻塞I / O，参与者（例如来自Akka的参与者）或任何适合您的需求，风格或专业知识的实现来实现可观察对象。 客户端代码将其与Observables的所有交互都视为异步，无论您的基础实现是阻塞的还是非阻塞的，但是您选择实现它。

这个Observable如何实现？
public Observable <data> getData（）;
从观察者的角度来看，没关系！
它在与调用方相同的线程上同步工作吗？
它在不同的线程上异步工作吗？
是否将其工作划分为多个线程，这些线程可能以任何顺序将数据返回给调用方？
它使用一个Actor（或多个Actor）代替线程池吗？
它是否使用带有事件循环的NIO进行异步网络访问？
它是否使用事件循环将工作线程与回调线程分开？
重要的是：使用ReactiveX，您以后可以改变主意，并从根本上改变Observable实现的基础性质，而又不会破坏Observable的使用者

d) Callbacks 有其自身的问题
回调通过不允许任何内容阻塞来解决Future.get（）上过早阻塞的问题。 它们自然有效，因为它们在响应准备就绪时执行。
但是，与Futures一样，尽管回调易于在单个级别的异步执行中使用，但通过嵌套组合，它们变得笨拙。
(Callback 地狱)

e) ReactiveX是多语言实现

目前，ReactiveX已以多种语言实现，并遵循了这些语言的习惯用法，并且正在迅速添加更多种语言。