RxJava - 概述
RxJava 是基于 Java 的 ReactiveX 扩展。它提供 Java 中的实现或 ReactiveX 项目。以下是 RxJava 的主要特征。
扩展观察者模式。
支持数据/事件序列。
提供运算符以声明方式组合序列。
内部处理线程、同步、线程安全和并发数据结构。
什么是 ReactiveX?
ReactiveX 是一个旨在为各种编程语言提供反应式编程概念的项目。反应式编程是指程序在数据出现时做出反应的场景。它是一个基于事件的编程概念，事件可以传播到寄存器观察者。
根据 Reactive，它们结合了观察者模式、迭代器模式和函数模式的优点。
观察者模式做得很好。ReactiveX 结合了观察者模式、迭代器模式和函数编程的最佳理念。
函数编程
函数编程围绕使用纯函数构建软件。纯函数不依赖于先前的状态，并且始终对传递的相同参数返回相同的结果。纯函数有助于避免与共享对象、可变数据和多线程环境中常见的副作用相关的问题。
反应式编程
反应式编程是指事件驱动编程，其中数据流以异步方式进入并在到达时进行处理。
函数式反应式编程
RxJava 同时实现了这两个概念，其中流的数据随时间而变化，消费者函数做出相应的反应。
反应式宣言
反应式宣言是一份在线文档，阐述了应用软件系统的高标准。根据宣言，以下是反应式软件的关键属性 −
响应式 −应始终及时响应。
消息驱动 − 应在组件之间使用异步消息传递，以便它们保持松散耦合。
弹性 − 即使在高负载下也应保持响应。
弹性 − 即使任何组件发生故障也应保持响应。
RxJava 的关键组件
RxJava 有两个关键组件:可观察对象和观察者。
可观察对象 −它表示一个类似于 Stream 的对象，可以发出零个或多个数据，可以发送错误消息，在发出一组数据时可以控制其速度，可以发送有限数据和无限数据。
观察者 − 它订阅 Observable 的序列数据并对每个可观察项做出反应。每当 Observable 发出数据时，观察者都会收到通知。观察者逐个处理数据。
如果项目不存在或前一个项目未返回回调，观察者永远不会收到通知。
