前言
Rxjava，由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。
如果还不了解RxJava，请看文章：Android：这是一篇 清晰 & 易懂的Rxjava 入门教程
-
RxJava如此受欢迎的原因，在于其提供了丰富 & 功能强大的操作符，几乎能完成所有的功能需求 - 今天，我将为大家带来
Rxjava中的常见开发应用场景：从磁盘、内存缓存中获取缓存数据 ，希望大家会喜欢。
Carson带你学RxJava系列文章，包括 原理、操作符、应用场景、背压等等，请关注看文章：Android：这是一份全面 & 详细的RxJava学习指南
目录
1. 需求场景
- 注：关于
Rxjava中的创建操作符firstElement（）和concat（）的使用请看文章
Android RxJava：最基础的操作符详解 - 创建操作符
Android RxJava：组合 / 合并操作符 详细教程
2. 功能说明
对于从磁盘 / 内存缓存中 获取缓存数据 的功能逻辑如下：
3. 具体实现
- 详细请看代码注释
// 该2变量用于模拟内存缓存 & 磁盘缓存中的数据
String memoryCache = null;
String diskCache = "从磁盘缓存中获取数据";
/*
* 设置第1个Observable：检查内存缓存是否有该数据的缓存
**/
Observable<String> memory = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
// 先判断内存缓存有无数据
if (memoryCache != null) {
// 若有该数据，则发送
emitter.onNext(memoryCache);
} else {
// 若无该数据，则直接发送结束事件
emitter.onComplete();
}
}
});
/*
* 设置第2个Observable：检查磁盘缓存是否有该数据的缓存
**/
Observable<String> disk = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
// 先判断磁盘缓存有无数据
if (diskCache != null) {
// 若有该数据，则发送
emitter.onNext(diskCache);
} else {
// 若无该数据，则直接发送结束事件
emitter.onComplete();
}
}
});
/*
* 设置第3个Observable：通过网络获取数据
**/
Observable<String> network = Observable.just("从网络中获取数据");
// 此处仅作网络请求的模拟
/*
* 通过concat（） 和 firstElement（）操作符实现缓存功能
**/
// 1. 通过concat（）合并memory、disk、network 3个被观察者的事件（即检查内存缓存、磁盘缓存 & 发送网络请求）
// 并将它们按顺序串联成队列
Observable.concat(memory, disk, network)
// 2. 通过firstElement()，从串联队列中取出并发送第1个有效事件（Next事件），即依次判断检查memory、disk、network
.firstElement()
// 即本例的逻辑为：
// a. firstElement()取出第1个事件 = memory，即先判断内存缓存中有无数据缓存；由于memoryCache = null，即内存缓存中无数据，所以发送结束事件（视为无效事件）
// b. firstElement()继续取出第2个事件 = disk，即判断磁盘缓存中有无数据缓存：由于diskCache ≠ null，即磁盘缓存中有数据，所以发送Next事件（有效事件）
// c. 即firstElement()已发出第1个有效事件（disk事件），所以停止判断。
// 3. 观察者订阅
.subscribe(new Consumer<String>() {
@Override
public void accept( String s) throws Exception {
Log.d(TAG,"最终获取的数据来源 = "+ s);
}
});
- 测试结果
4. Demo地址
Carson_Ho的Github地址 = RxJava2实战系列：从磁盘 / 内存缓存中 获取缓存数据
5. 总结
- 本文主要讲解了
Rxjava的实际开发需求场景：从磁盘 / 内存缓存中 获取缓存数据 - Carson带你学RxJava系列文章：
入门
Carson带你学Android：这是一篇清晰易懂的Rxjava入门教程
Carson带你学Android：面向初学者的RxJava使用指南
Carson带你学Android：RxJava2.0到底更新了什么？
原理
Carson带你学Android：图文解析RxJava原理
Carson带你学Android：手把手带你源码分析RxJava
使用教程：操作符
Carson带你学Android：RxJava操作符教程
Carson带你学Android：RxJava创建操作符
Carson带你学Android：RxJava功能性操作符
Carson带你学Android：RxJava过滤操作符
Carson带你学Android：RxJava组合/合并操作符
Carson带你学Android：RxJava变换操作符
Carson带你学Android：RxJava条件/布尔操作符
实战
Carson带你学Android：什么时候应该使用Rxjava？(开发场景汇总)
Carson带你学Android：RxJava线程控制(含实例讲解)
Carson带你学Android：图文详解RxJava背压策略
Carson带你学Android：RxJava、Retrofit联合使用汇总(含实例教程)
Carson带你学Android：优雅实现网络请求嵌套回调
Carson带你学Android：网络请求轮询(有条件)
Carson带你学Android：网络请求轮询(无条件)
Carson带你学Android：网络请求出错重连(结合Retrofit)
Carson带你学Android：合并数据源
Carson带你学Android：联想搜索优化
Carson带你学Android：功能防抖
Carson带你学Android：从磁盘/内存缓存中获取缓存数据
Carson带你学Android：联合判断
欢迎关注Carson_Ho的简书
不定期分享关于安卓开发的干货，追求短、平、快，但却不缺深度。
