深入浅出RxJava(二：操作符)_rxjava操作符-程序员宅基地

在第一篇blog中，我介绍了RxJava的一些基础知识，同时也介绍了map()操作符。当然如果你并没有意愿去使用RxJava我一点都不诧异，毕竟才接触了这么点。看完这篇blog，我相信你肯定想立即在你的项目中使用RxJava了，这篇blog将介绍许多RxJava中的操作符，RxJava的强大性就来自于它所定义的操作符。

首先先看一个例子：

准备工作

假设我有这样一个方法：
这个方法根据输入的字符串返回一个网站的url列表（啊哈，搜索引擎）

Observable<List<String>> query(String text);

现在我希望构建一个健壮系统，它可以查询字符串并且显示结果。根据上一篇blog的内容，我们可能会写出下面的代码：

query("Hello, world!")
    .subscribe(urls -> {
        for (String url : urls) {
            System.out.println(url);
        }
    });

这种代码当然是不能容忍的，因为上面的代码使我们丧失了变化数据流的能力。一旦我们想要更改每一个URL，只能在Subscriber中来做。我们竟然没有使用如此酷的map()操作符！！！

当然，我可以使用map操作符，map的输入是urls列表，处理的时候还是要for each遍历，一样很蛋疼。

万幸，还有Observable.from()方法，它接收一个集合作为输入，然后每次输出一个元素给subscriber：

Observable.from("url1", "url2", "url3")
    .subscribe(url -> System.out.println(url));

我们来把这个方法使用到刚才的场景：

query("Hello, world!")
    .subscribe(urls -> {
        Observable.from(urls)
            .subscribe(url -> System.out.println(url));
    });

虽然去掉了for each循环，但是代码依然看起来很乱。多个嵌套的subscription不仅看起来很丑，难以修改，更严重的是它会破坏某些我们现在还没有讲到的RxJava的特性。

改进

救星来了,他就是flatMap()。
Observable.flatMap()接收一个Observable的输出作为输入，同时输出另外一个Observable。直接看代码：

query("Hello, world!")
    .flatMap(new Func1<List<String>, Observable<String>>() {
        @Override
        public Observable<String> call(List<String> urls) {
            return Observable.from(urls);
        }
    })
    .subscribe(url -> System.out.println(url));

这里我贴出了整个的函数代码，以方便你了解发生了什么，使用lambda可以大大简化代码长度：

query("Hello, world!")
    .flatMap(urls -> Observable.from(urls))
    .subscribe(url -> System.out.println(url));

flatMap()是不是看起来很奇怪？为什么它要返回另外一个Observable呢？理解flatMap的关键点在于，flatMap输出的新的Observable正是我们在Subscriber想要接收的。现在Subscriber不再收到List<String>，而是收到一些列单个的字符串，就像Observable.from()的输出一样。

这部分也是我当初学RxJava的时候最难理解的部分，一旦我突然领悟了，RxJava的很多疑问也就一并解决了。

还可以更好

flatMap()实在不能更赞了，它可以返回任何它想返回的Observable对象。
比如下面的方法：

// 返回网站的标题，如果404了就返回null
Observable<String> getTitle(String URL);

接着前面的例子，现在我不想打印URL了，而是要打印收到的每个网站的标题。问题来了，我的方法每次只能传入一个URL，并且返回值不是一个String，而是一个输出String的Observabl对象。使用flatMap()可以简单的解决这个问题。

query("Hello, world!")
    .flatMap(urls -> Observable.from(urls))
    .flatMap(new Func1<String, Observable<String>>() {
        @Override
        public Observable<String> call(String url) {
            return getTitle(url);
        }
    })
    .subscribe(title -> System.out.println(title));

使用lambda:

query("Hello, world!")
    .flatMap(urls -> Observable.from(urls))
    .flatMap(url -> getTitle(url))
    .subscribe(title -> System.out.println(title));

是不是感觉很不可思议？我竟然能将多个独立的返回Observable对象的方法组合在一起！帅呆了！
不止这些，我还将两个API的调用组合到一个链式调用中了。我们可以将任意多个API调用链接起来。大家应该都应该知道同步所有的API调用，然后将所有API调用的回调结果组合成需要展示的数据是一件多么蛋疼的事情。这里我们成功的避免了callback hell（多层嵌套的回调，导致代码难以阅读维护）。现在所有的逻辑都包装成了这种简单的响应式调用。

丰富的操作符

目前为止，我们已经接触了两个操作符，RxJava中还有更多的操作符，那么我们如何使用其他的操作符来改进我们的代码呢？
getTitle()返回null如果url不存在。我们不想输出"null"，那么我们可以从返回的title列表中过滤掉null值！

query("Hello, world!")
    .flatMap(urls -> Observable.from(urls))
    .flatMap(url -> getTitle(url))
    .filter(title -> title != null)
    .subscribe(title -> System.out.println(title));

filter()输出和输入相同的元素，并且会过滤掉那些不满足检查条件的。

如果我们只想要最多5个结果：

query("Hello, world!")
    .flatMap(urls -> Observable.from(urls))
    .flatMap(url -> getTitle(url))
    .filter(title -> title != null)
    .take(5)
    .subscribe(title -> System.out.println(title));

take()输出最多指定数量的结果。

如果我们想在打印之前，把每个标题保存到磁盘：

query("Hello, world!")
    .flatMap(urls -> Observable.from(urls))
    .flatMap(url -> getTitle(url))
    .filter(title -> title != null)
    .take(5)
    .doOnNext(title -> saveTitle(title))
    .subscribe(title -> System.out.println(title));

doOnNext()允许我们在每次输出一个元素之前做一些额外的事情，比如这里的保存标题。

看到这里操作数据流是多么简单了么。你可以添加任意多的操作，并且不会搞乱你的代码。

RxJava包含了大量的操作符。操作符的数量是有点吓人，但是很值得你去挨个看一下，这样你可以知道有哪些操作符可以使用。弄懂这些操作符可能会花一些时间，但是一旦弄懂了，你就完全掌握了RxJava的威力。

你甚至可以编写自定义的操作符！这篇blog不打算将自定义操作符，如果你想的话，清自行Google吧。

感觉如何？

好吧，你是一个怀疑主义者，并且还很难被说服，那为什么你要关心这些操作符呢？

因为操作符可以让你对数据流做任何操作。

将一系列的操作符链接起来就可以完成复杂的逻辑。代码被分解成一系列可以组合的片段。这就是响应式函数编程的魅力。用的越多，就会越多的改变你的编程思维。

另外，RxJava也使我们处理数据的方式变得更简单。在最后一个例子里，我们调用了两个API，对API返回的数据进行了处理，然后保存到磁盘。但是我们的Subscriber并不知道这些，它只是认为自己在接收一个Observable<String>对象。良好的封装性也带来了编码的便利！

在第三部分中，我将介绍RxJava的另外一些很酷的特性，比如错误处理和并发，这些特性并不会直接用来处理数据。

原文链接

本文链接：https://blog.csdn.net/lzyzsd/article/details/44094895

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

Unity的Animator动画系统-——StateMachineBehaviours，用来实现怪物的行为-程序员宅基地

文章浏览阅读2.3k次，点赞7次，收藏26次。文章目录Unity的Animator动画系统-——StateMachineBehaviours，用来实现怪物的行为。前言一、StateMachineBehaviours简介二、用法举例1.把要用到的虚方法封装一下2.接下来就可以用到封装好的SealedSMB了，代码如下：3.怪物具体的行为类4.ChomperSMBIdle类，去调用ChomperBehavior里的行为总结Unity的Animator动画系统-——StateMachineBehaviours，用来实现怪物的行为。前言今天记录下uni_statemachinebehaviour

java--栈、堆、方法区_java栈,堆,方法区的绘制-程序员宅基地

文章浏览阅读245次。栈的特点如下：1 .栈描述的是方法执行的内存模型，每个方法被调用都回创建一个栈帧（存储局部变量、操作数、方法出口等）2。JVM为每个县城创建一个栈，用于存放该线程执行方法的信息（实际参数、局部变量等）3.栈属于线程私有，不能实现线程间的共享4.栈的存储特性是“先进后出，后进先出”。（弹夹结构）5.栈是由系统自动分配，速度快！栈是一个连续的内存空间！堆的特点如下：1 .堆用于存储..._java栈,堆,方法区的绘制

【检测】Prime Sample Attention in Object Detection-程序员宅基地

文章浏览阅读3k次。Prime Sample Attention in Object Detection作者：CUHK SenseTime Joint Lab， NTU在目标检测中的一个普遍认知就是应该平等的对待每个sample和目标。这篇文章研究了不同的样本对于最终结果的影响。作者认为在每个minibatch中的样本既不是独立的也不是同样重要的，所以一个平均的结果并不能意味是一个更高的mAP。作者提出了Prim..._prime sample attention in object detection

Elasticsearch地理空间之geo_shape_elasticsearch geo_shape-程序员宅基地

文章浏览阅读6.2k次，点赞2次，收藏20次。参考文章：Elasticsearch地理形状Elasticsearch geo_shape地理形状ES地理范围查询第二讲：地理位置信息之geo_shapeES GEO地理空间查询java版一、概述通常情况，我们使用一个经纬度坐标表示一个店铺的位置、一个用户的位置，经纬度在地图上仅仅表示一个点，有时候需要表示一个区域，例如：停车场、商场、学校等等，这些区域拥有各种各样的形状，包括：圆形、多边形等等。ES中存储地理形状的数据类型为: geo_shapegeo_shape支持存储的常用形状数据如_elasticsearch geo_shape

WMI的讲解(是什么，做什么，为什么)-程序员宅基地

文章浏览阅读2w次，点赞17次，收藏72次。讲在前面：笔者在阅读了WMI的微软官方文档以及国内优秀前辈的介绍文章后，获益匪浅，WMI是一个较为老的知识点了，但是对于想要简单理解WMI的同学来说，对于一个新的知识点进行理解最好是能够有生动形象的例子进行抛砖引玉式的解读，将晦涩难懂的知识点吃透、理解后用简单的话语将其作用表达清楚，使其读者能够快速的理解并为读者接下来深入理解打好基础，以便在攻防中更好的利用WMI，所以此篇文章笔者使用通俗的话语将WMI表达清楚，在下文中对于基础薄弱的同学对于COM组件、Pr_wmi

SpringBoot：AOP切面execution表达式_execution 切面表达式有返回值吗-程序员宅基地

文章浏览阅读2k次。execution表达式基本语法格式为：execution（<修饰符模式>？<返回类型模式><方法名模式>（<参数模式>）<异常模式>？）说明：除了返回类型模式，方法名模式和参数模式外，其它项都是可选的。例如：@Pointcut(“execution(public * com..controller….*(…))”）说明：1、【非必填】修饰符模式。public 表示public 级别方法。可以不写，不写就是所有的方法（publ_execution 切面表达式有返回值吗

随便推点

EEG信号的节律信号的生成_eeg 信号节律波提取滤波器综合设计-程序员宅基地

文章浏览阅读582次。EEG信号中常用的节律信号包括，delta, theta, alpha, beta。由于这些节律信号在某个固定的频率段上，因此可以用滤波的方法得到。滤波器的设计，可以是IIR，和FIR。如果是对相位没有要求，滤波后需要计算其波段能量，IIR滤波器可选；如果对信号的相位有要求，线性相位的FIR滤波器可选。选用经典滤波器的问题是，要选择合适的通带和阻带的频率，还要选择合适的衰减的指标，这些指标的不同，滤波的结果会不一样。基于小波包的节律信号获取，是一个常用的滤波方式，因为小波变换实现也更简单。..._eeg 信号节律波提取滤波器综合设计

PDF改背景和字体颜色_goodnotes中如何快速把底页颜色和字体颜色改变-程序员宅基地

文章浏览阅读2.4w次。想打印一个PDF, 却是很深的背景白的字, SIGH. 用Adobe Acrobat Professioinal 7.0打开, 发现只能一页一页的删除背景, 改字颜色, 如下: PDF中各部分是按元素保存的, 可以查看一个个元素, 包括背景, 图片, 文字, 可以对每个元素进行修改. 点击视图-->导览标签-->内容, 打开内容视图, 在这里可以看到所有的元素. 它们是以页面为分组, _goodnotes中如何快速把底页颜色和字体颜色改变

读透《阿里巴巴数据中台实践》，其到底有什么高明之处？_阿里数据中台如何落实-程序员宅基地

文章浏览阅读1w次，点赞10次，收藏66次。最近阿里巴巴分享了《阿里巴巴数据中台实践》这个PPT（自行搜索原始文章），对于数据中台的始作俑者，还是要怀着巨大的敬意去学习的，因此仔细的研读了，希望能发现一些不一样的东西。读这些专业的PPT，实际是非常耗时的，你需要把这些PPT外表的光鲜扒光，死抠上面的每一个字去理解底下隐藏的含义，然后跟你的已有知识体系去对比，看看是否有助于完善自己的认知，对于自己不理解的，还需要经常去检索相关的文档。..._阿里数据中台如何落实

使用poi读取excel异常IOException: OPC Compliance error [M4.3]: Producers shall not create a document ele..._exception in thread "main" cn.hutool.poi.exception-程序员宅基地

文章浏览阅读4k次。前言：前一段时间，帮女朋友整理她们公司的破Excel文档，本着减少工作量的原则（居家好男人），帮忙写了个java main去读取整理Excel，到后来发现在读取到xlsx的excel报错，报错信息居然没看懂。。。报错信息Exception in thread "main" cn.hutool.poi.exceptions.POIException: IOException: OPC Co..._exception in thread "main" cn.hutool.poi.exceptions.poiexception: ioexceptio

Beyond Compare文件比对_beyond compare 4.2 密钥-程序员宅基地

文章浏览阅读3.2k次。Beyond Compare_beyond compare 4.2 密钥

第一章：初探Spring Cloud Config配置集中管理_springcloud 集中配置管理-程序员宅基地

文章浏览阅读1.5k次。前路艰难，但谨记，你并不孤独。Spring Cloud如火如荼，抽空研究研究Spring大家族中的新份子。具体的介绍不会粗线在本系列博文中，如需要理论等知识直接百度or谷歌。Spring Cloud中保护N多已构建好的微服务，可以做到即插即用，其中大致包含几种服务：Config、Eureka、Ribbon、Hystrix、Feign、Bus等，具体介绍及开源地址请见：Spring Cloud中文官_springcloud 集中配置管理