RxJava系列文章目录导读：

一、RxJava create 操作符的用法和源码分析
二、RxJava map 操作符用法详解
三、RxJava flatMap 操作符用法详解
四、RxJava concatMap 操作符用法详解
五、RxJava onErrorResumeNext 操作符实现 app 与服务器间 token 机制
六、RxJava retryWhen 操作符实现错误重试机制
七、RxJava 使用 debounce 操作符优化 app 搜索功能
八、RxJava concat 操作处理多数据源
九、RxJava zip 操作符在 Android 中的实际使用场景
十、RxJava switchIfEmpty 操作符实现 Android 检查本地缓存逻辑判断
十一、RxJava defer 操作符实现代码支持链式调用
十二、combineLatest 操作符的高级使用
十三、RxJava 导致 Fragment Activity 内存泄漏问题
十四、interval、takeWhile 操作符实现获取验证码功能
十五、RxJava 线程的自由切换

---

1. map 操作符的作用

Returns an Observable that applies a specified function to each item emitted by the source Observable and emits the results of these function applications.

下面是官方对于 map 操作符的流程图：

对Observable发射的数据都应用一个函数，然后再发射最后的结果集。最后map()方法返回一个新的Observable。

2. 用法示例

1）先来个简单的例子

假设我们从服务器获取了一个字符串集合，我们想里面的数据项都转成大写，然后把集合的顺序反转。如把 [“this”,"is","rxJava"] 转成 ["RXJAVA","IS",“THIS”]。

Observable.from(new String[]{"This", "is", "RxJava"}).map(new Func1<String, String>() {@Overridepublic String call(String s) {printLog(tvLogs, "Transform Data toUpperCase: ", s);return s.toUpperCase();}})//转成List.toList().map(new Func1<List<String>, List<String>>() {@Overridepublic List<String> call(List<String> strings) {printLog(tvLogs, "Transform Data Reverse List: ", strings.toString());Collections.reverse(strings);return strings;}}).observeOn(AndroidSchedulers.mainThread()).subscribeOn(Schedulers.io()).subscribe(new Action1<List<String>>() {@Overridepublic void call(List<String> s) {printLog(tvLogs, "Consume Data ", s.toString());}});

输出结果：

Transform Data toUpperCase: 'This' , Main Thread:false, Thread Name:RxCachedThreadScheduler-1
Transform Data toUpperCase: 'is' , Main Thread:false, Thread Name:RxCachedThreadScheduler-1
Transform Data toUpperCase: 'RxJava' , Main Thread:false, Thread Name:RxCachedThreadScheduler-1
Transform Data Reverse List: '[THIS, IS, RXJAVA]' , Main Thread:false, Thread Name:RxCachedThreadScheduler-1
Consume Data '[RXJAVA, IS, THIS]' , Main Thread:true, Thread Name:main

2）来个复杂点的示例

假设我们有一个主机列表，想根据这个主机列表好获取它们的IP地址。

首先得有一个方法，根据主机获取IP：

    private String getIPByUrl(String str) throws MalformedURLException, UnknownHostException {URL urls = new URL(str);String host = urls.getHost();String address = InetAddress.getByName(host).toString();int b = address.indexOf("/");return address.substring(b + 1);}

然后通过map操作符来实现：

private Observable<String> processUrlsIpByMap() {return Observable.just("http://www.baidu.com/","http://www.google.com/","https://www.bing.com/").map(new Func1<String, String>() {@Overridepublic String call(String s) {try {return s + " : " + getIPByUrl(s);} catch (MalformedURLException e) {e.printStackTrace();} catch (UnknownHostException e) {e.printStackTrace();}return null;}}).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Action1<String>() {@Overridepublic void call(String s) {printLog(tvLogs, "Consume Data: ", s);}});}

输出结果：

Consume Data: 'http://www.baidu.com/ : 115.239.210.27' 
Consume Data: 'http://www.google.com/ : 216.58.203.36'
Consume Data: 'https://www.bing.com/ : 202.89.233.104'

---

如果你觉得本文帮助到你，给我个关注和赞呗！

另外，我为 Android 程序员编写了一份：超详细的 Android 程序员所需要的技术栈思维导图。

如果有需要可以移步我的 GitHub -> AndroidAll，里面包含了最全的目录和对应知识点链接，帮你扫除 Android 知识点盲区。 由于篇幅原因只展示了 Android 思维导图：