RxJava

Subscriber和Observer的区别

Subscriber

和

Observer

不仅基本使用方式一样，实质上，在

RxJava

的

subscribe

过程中，

Observer

也总是会先被转换成一个

Subscriber

再使用。所以如果你只想使用基本功能，选择

Observer

和

Subscriber

是完全一样的。它们的区别对于使用者来说主要有两点：

onStart()

: 这是

Subscriber

增加的方法。它会在

subscribe

刚开始，而事件还未发送之前被调用，可以用于做一些准备工作，例如数据的清零或重置。这是一个可选方法，默认情况下它的实现为空。需要注意的是，如果对准备工作的线程有要求（例如弹出一个显示进度的对话框，这必须在主线程执行），

onStart()

就不适用了，因为它总是在

subscribe

所发生的线程被调用，而不能指定线程。要在指定的线程来做准备工作，可以使用

doOnSubscribe()

方法，具体可以在后面的文中看到。

unsubscribe()

: 这是

Subscriber

所实现的另一个接口

Subscription

的方法，用于取消订阅。在这个方法被调用后，

Subscriber

将不再接收事件。一般在这个方法调用前，可以使用

isUnsubscribed()

先判断一下状态。

unsubscribe()

这个方法很重要，因为在

subscribe()

之后， Observable 会持有

Subscriber

的引用，这个引用如果不能及时被释放，将有内存泄露的风险。所以最好保持一个原则：要在不再使用的时候尽快在合适的地方（例如

onPause()

onStop()

等方法中）调用

unsubscribe()

来解除引用关系，以避免内存泄露的发生。

变换

RxJava 提供了对事件序列进行变换的支持，这是它的核心功能之一，也是大多数人说『RxJava 真是太好用了』的最大原因。所谓变换，就是将事件序列中的对象或整个序列进行加工处理，转换成不同的事件或事件序列。

操作符

其实操作符就是为了提供一些函数式的特性。函数式最大的好处就是处理数据简洁易懂。

map就是相当于对每一个元素进行变换，返回变换后的集合

filter就是对集合进行过滤

each就是遍历集合

take取出集合中的前几个

skip跳过前几个元素

unique相当于按照数学上的集合处理，去重

其实我觉得题主觉得最难理解的应该是flatMap和Observable的概念吧。Observable可以理解成lazy load的集合。flatMap想当于对lazyLoad的集合中的每个元素再进行一次lazy load。（此段引用自hi大头鬼hi）

变换操作

这些操作符可用于对Observable发射的数据进行变换，详细解释可以看每个操作符的文档

操作符	含义
Buffer	缓存，可以简单的理解为缓存，它定期从Observable收集数据到一个集合，然后把这些数据集合打包发射，而不是一次发射一个
FlatMap	扁平映射，将Observable发射的数据变换为Observables集合，然后将这些Observable发射的数据平坦化的放进一个单独的Observable，可以认为是一个将嵌套的数据结构展开的过程。
GroupBy	分组，将原来的Observable分拆为Observable集合，将原始Observable发射的数据按Key分组，每一个Observable发射一组不同的数据
Map	映射，通过对序列的每一项都应用一个函数变换Observable发射的数据，实质是对序列中的每一项执行一个函数，函数的参数就是这个数据项
Scan	扫描，对Observable发射的每一项数据应用一个函数，然后按顺序依次发射这些值
Window	窗口，定期将来自Observable的数据分拆成一些Observable窗口，然后发射这些窗口，而不是每次发射一项。类似于Buffer，但Buffer发射的是数据，Window发射的是Observable，每一个Observable发射原始Observable的数据的一个子集

组合操作

组合操作符用于将多个Observable组合成一个单一的Observable

操作符	含义
And/Then/When	通过模式(And条件)和计划(Then次序)组合两个或多个Observable发射的数据集
CombineLatest	当两个Observables中的任何一个发射了一个数据时，通过一个指定的函数组合每个Observable发射的最新数据（一共两个数据），然后发射这个函数的结果
Join	无论何时，如果一个Observable发射了一个数据项，只要在另一个Observable发射的数据项定义的时间窗口内，就将两个Observable发射的数据合并发射
Merge	将两个Observable发射的数据组合并成一个
StartWith	在发射原来的Observable的数据序列之前，先发射一个指定的数据序列或数据项
Switch	将一个发射Observable序列的Observable转换为这样一个Observable：它逐个发射那些Observable最近发射的数据
Zip	打包，使用一个指定的函数将多个Observable发射的数据组合在一起，然后将这个函数的结果作为单项数据发射

错误处理

这些操作符用于从错误通知中恢复

操作符	含义
Catch	捕获，继续序列操作，将错误替换为正常的数据，从onError通知中恢复
Retry	重试，如果Observable发射了一个错误通知，重新订阅它，期待它正常终止

辅助操作

一组用于处理Observable的操作符

操作符	含义
Delay	延迟一段时间发射结果数据
Do	注册一个动作占用一些Observable的生命周期事件，相当于Mock某个操作
Materialize/Dematerialize	将发射的数据和通知都当做数据发射，或者反过来
ObserveOn	指定观察者观察Observable的调度程序（工作线程）
Serialize	强制Observable按次序发射数据并且功能是有效的
Subscribe	收到Observable发射的数据和通知后执行的操作
SubscribeOn	指定Observable应该在哪个调度程序上执行
TimeInterval	将一个Observable转换为发射两个数据之间所耗费时间的Observable
Timeout	添加超时机制，如果过了指定的一段时间没有发射数据，就发射一个错误通知
Timestamp	给Observable发射的每个数据项添加一个时间戳
Using	创建一个只在Observable的生命周期内存在的一次性资源

条件和布尔操作

这些操作符可用于单个或多个数据项，也可用于Observable

操作符	含义
All	判断Observable发射的所有的数据项是否都满足某个条件
Amb	给定多个Observable，只让第一个发射数据的Observable发射全部数据
Contains	判断Observable是否会发射一个指定的数据项
DefaultIfEmpty	发射来自原始Observable的数据，如果原始Observable没有发射数据，就发射一个默认数据
SequenceEqual	判断两个Observable是否按相同的数据序列
SkipUntil	丢弃原始Observable发射的数据，直到第二个Observable发射了一个数据，然后发射原始
SkipWhile	丢弃原始Observable发射的数据，直到一个特定的条件为假，然后发射原始Observable剩余的数据
TakeUntil	发射来自原始Observable的数据，直到第二个Observable发射了一个数据或一个通知
TakeWhile	发射原始Observable的数据，直到一个特定的条件为真，然后跳过剩余的数据

算术和聚合操作

这些操作符可用于整个数据序列

操作符	含义
Average	计算Observable发射的数据序列的平均值，然后发射这个结果
Concat	不交错的连接多个Observable的数据
Count	计算Observable发射的数据个数，然后发射这个结果
Max	计算并发射数据序列的最大值
Min	计算并发射数据序列的最小值
Reduce	按顺序对数据序列的每一个应用某个函数，然后返回这个值
Sum	计算并发射数据序列的和

连接操作

一些有精确可控的订阅行为的特殊Observable

操作符	含义
Connect	指示一个可连接的Observable开始发射数据给订阅者
Publish	将一个普通的Observable转换为可连接的
RefCount	使一个可连接的Observable表现得像一个普通的Observable
Replay	确保所有的观察者收到同样的数据序列，即使他们在Observable开始发射数据之后才订阅

转换操作

操作符	含义
To	将Observable转换为其它的对象或数据结构
Blocking	阻塞Observable的操作符

参考：

Intro To RxJava 系列教程 - 云在千峰

给 Android 开发者的 RxJava 详解

RxJava 入门 - 傅圆的博客 | MrFu Blog

RxJava学习总结 - 推酷

Operators—-RxWeekend - 傅圆的博客 | MrFu Blog