Rxjava2入门教程三：Operators操作符

朱雀 2023-07-13 13:49 135阅读 0赞

### Operators操作符 ###

**操作符（Operators）**：其实质是函数式编程中的高阶函数，是对响应式编程的各个过程拆分封装后的产物。以便于我们操作数据流。  
按照其作用具体可分为以下几类：  
创建：创建一个可观察对象Observable并发射数据  
过滤：从Observable发射的数据中取出特定的值  
变换：对Observable发射的数据执行变换操作  
组合：组合多个Observable,例如：\{1,2,3\}+\{4,5,6\}-->\{1,2,3,4,5,6\}  
聚合：聚合多个Observable，例如：\{1,2,3\}+\{4,5,6\}-->\{\[1,4\],\[2,5\],\[3,6\]\}  
下面对一些常用的操作符做一下介绍（后面的章节中，会做全面汇总）

创建操作：

**create**:基础创建操作符  
**just**:创建一个Observable，可接受一个或多个参数，将每个参数逐一发送

Observable.just("hello world");//发送一个字符串"hello world"
    Observable.just(1,2,3,4);//逐一发送1,2,3,4这四个整数

**fromArray**:创建一个Observable，接受一个数组，并将数组中的数据逐一发送  
**fromIterable**：</b>创建一个Observable，接受一个可迭代对象，并将可迭代对象中的数据逐一发送  
**range**：</b>创建一个Observable，发送一个范围内的整数序列

Observable.range(1,10);//从1开始以步长1递增发送10个数据  
运行如下代码：

![format_png][]

demo1\_range.jpg

控制台打印：

0
      1
      2
      3
      4

过滤操作（filter与distinct）：

**filter**：filter使用Predicate 函数接口传入条件值，来判断Observable发射的每一个值是否满足这个条件，如果满足，则继续向下传递，如果不满足，则过滤掉。  
如下图：

![format_png 1][]

05F271FEB0494D3C85FA622419DD943A.jpg

运行如下代码：

![format_png 2][]

demo2\_filter.jpg

通过rang操作符发射整数序列0~10；然后通过filter过滤能被3整除的数，控制台打印如下;

0
        3
        6
        9

**distinct**:过滤掉重复的数据项，过滤规则为：只允许还没有发射过的数据项通过。  
如下图：

![format_png 3][]

2DFB371B1F314B90B8E7A55966B1EC5D.jpg

运行如下代码：

![format_png 4][]

demo3\_distinct.jpg

通过just操作符，发射数据序列\{1,1,2,3,1,2,2,4,5\}；然后通过distinct过滤去重，运行结果如下：

1
        2
        3
        4
        5

链接使用

所有的操作符均可以链接配合使用，共同对结果起作用  
先对数据序列去重\{1,1,2,3,1,2,2,4,5\}，然后在筛选出偶数

![format_png 5][]

demo4\_distinct\_filter.jpg

运行结果如下;

2
        4

变换操作（map与flatMap）

**map**:对Observable发射的每一项数据应用一个函数，执行变换操作  
map操作符，需要接收一个函数接口Function<T,R>的实例化对象，实现接口内R apply(T t)的方法，在此方法中可以对接收到的数据t进行变换后返回。  
如下图：

![format_png 6][]

0449AFF58A654A8282737BE31F3226E7.jpg

运行如下代码：

![format_png 7][]

demo5\_map.jpg

在方法apply中，对Observable发射过来的数字integer执行了以下变换integer+"^2 = "+integer\*intege后返回。  
运行结果如下：

0^2 = 0
        1^2 = 1
        2^2 = 4
        3^2 = 9
        4^2 = 16

**flatMap**:将一个发射数据的Observable变换为多个Observable，然后将多个Observable发射的数据合并到一个Observable中进行发射  
如下图：

![format_png 8][]

BD6A82E54E6648BB8A3FD66AFA19EDBF.jpg

运行如下代码：

![format_png 9][]

demo6\_flatMap.jpg

首先，用just操作符，发射三个数组，通过flatMap变换，将每个数组中的元素用操作符fromArray取出后逐一发射  
最后观察者接收数据如下;

1
        2
        3
        4
        5
        6
        7
        8
        9

组合操作（mergeWith与concatWith）

**mergeWith**：合并多个Observable发射的数据，可能会让Observable发射的数据交错。  
如下图：

![format_png 10][]

D81F3936DC1E46DFB6E375C2B14B0DF5.jpg

运行如下代码：

![format_png 11][]

demo7\_mergeWith.jpg

一个Observable用just发送数据序列1,2,3,4,5，另一个Observable用fromArray逐一发送数组中的数据5,6,7,8,9，然后用mergeWith将两者组合，运行如下

1
        2
        3
        4
        5
        5
        6
        7
        8
        9

**concatWith**：同mergeWith一样，用以合并多个Observable发射的数据，但是concatWith不会让Observable发射的数据交错。  
如下图：

![format_png 12][]

concatWith.jpg

运行如下代码：

![format_png 13][]

demo8\_concatWith.jpg

一个Observable用just发送数据序列1.2.3.4，5，另一个Observable用fromArray逐一发送数组中的数据5,6,7,8,9，然后用concatWith将两者组合，运行如下

1
          2
          3
          4
          5
          5
          6
          7
          8
          9

聚合操作（zipWith）

**zipWith**：将多个Obversable发射的数据，通过一个函数BiFunction对对应位置的数据处理后放到一个新的Observable中发射，所发射的数据个数与最少的Observabel中的一样多。  
定义一个函数：

![format_png 14][]

344FA00396BB4C5EA85D004F9ADEDAC0.jpg

聚合如下:

![format_png 15][]

CDA3BBC425CE4097B4BE45B923E526B1.jpg

代码如下：

![format_png 16][]

demo9\_zipWith.jpg

zipWith需要接收两个参数，  
一个是可观察对象，  
另一个是聚合函数接口BiFunction,这个接口有三个泛型，分别为第一个可观察对象发射的数据类型，第二个可观察对象发射的数据类型，经过聚合函数apply处理后返回的数据类型

代码运行结果为；

1红娃
        2橙娃
        3黄娃
        4绿娃
        5青娃
        6蓝娃
        7紫娃

**以上的操作符均可以链接使用，下面的代码链接了本节中的所有操作符**

![format_png 17][]

demo10\_link\_all\_operators.jpg

运行结果如下；

3:红娃
        4:橙娃
        1:黄娃
        2:绿娃

[format_png]: /images/20230529/773648d63ab24036bb38128c1fd9b176.png
[format_png 1]: /images/20230529/e93bee81d61a40f2a42e1ea0c9b4b4fd.png
[format_png 2]: /images/20230529/64f67e2d62784696a9c9125901d24d97.png
[format_png 3]: /images/20230529/527b8a69224942b68e7badfa800ad82a.png
[format_png 4]: /images/20230529/5ea227bc9e7d43169b2959bcbf108530.png
[format_png 5]: /images/20230529/896e8691671f4c78b0fc556b242e17e7.png
[format_png 6]: /images/20230529/6da4422b90344f95b886cc957f58af45.png
[format_png 7]: /images/20230529/1e145a789c7244e7a66e27a707f14aab.png
[format_png 8]: /images/20230529/73b01073a2b6446e9f072f91e2799c1d.png
[format_png 9]: /images/20230529/ede0e2ee03814267b2de72980f3a2063.png
[format_png 10]: /images/20230529/32cfed979d8e4b0f937275637fe6f58b.png
[format_png 11]: /images/20230529/281ed9b57da74fc887690d6231aa22e0.png
[format_png 12]: /images/20230529/97f65d981efc4589a682951042dc81b7.png
[format_png 13]: /images/20230529/340ba2600df946d1bc6a95ec3c6d0d3a.png
[format_png 14]: /images/20230529/8c6ad75430fc41e481222213c0e3a6bc.png
[format_png 15]: /images/20230529/3cf6157237944be4857a0a55d3509d66.png
[format_png 16]: /images/20230529/0f598ed3b378485f8634b52abe5f7095.png
[format_png 17]: /images/20230529/7f9ef1858b284b819d9a0cd1ff79430c.png