前言
Rxjava泣矛，由于其基于事件流的鏈式調用、邏輯簡潔 & 使用簡單的特點禾蚕，深受各大 Android開發(fā)者的歡迎您朽。
如果還不了解RxJava，請看文章：Android：這是一篇 清晰 & 易懂的Rxjava 入門教程
-
RxJava如此受歡迎的原因换淆，在于其提供了豐富 & 功能強大的操作符哗总，幾乎能完成所有的功能需求 - 今天，我將為大家?guī)?
Rxjava中的常見開發(fā)應用場景：從磁盤倍试、內存緩存中獲取緩存數據 讯屈，希望大家會喜歡。
Carson帶你學RxJava系列文章县习，包括 原理涮母、操作符、應用場景躁愿、背壓等等叛本，請關注看文章：Android：這是一份全面 & 詳細的RxJava學習指南
目錄
1. 需求場景
- 注：關于
Rxjava中的創(chuàng)建操作符firstElement（）和concat（）的使用請看文章
Android RxJava：最基礎的操作符詳解 - 創(chuàng)建操作符
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) {
// 若有該數據，則發(fā)送
emitter.onNext(memoryCache);
} else {
// 若無該數據攘已，則直接發(fā)送結束事件
emitter.onComplete();
}
}
});
/*
* 設置第2個Observable：檢查磁盤緩存是否有該數據的緩存
**/
Observable<String> disk = Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) throws Exception {
// 先判斷磁盤緩存有無數據
if (diskCache != null) {
// 若有該數據炮赦，則發(fā)送
emitter.onNext(diskCache);
} else {
// 若無該數據，則直接發(fā)送結束事件
emitter.onComplete();
}
}
});
/*
* 設置第3個Observable：通過網絡獲取數據
**/
Observable<String> network = Observable.just("從網絡中獲取數據");
// 此處僅作網絡請求的模擬
/*
* 通過concat（） 和 firstElement（）操作符實現緩存功能
**/
// 1. 通過concat（）合并memory样勃、disk、network 3個被觀察者的事件（即檢查內存緩存性芬、磁盤緩存 & 發(fā)送網絡請求）
// 并將它們按順序串聯成隊列
Observable.concat(memory, disk, network)
// 2. 通過firstElement()峡眶，從串聯隊列中取出并發(fā)送第1個有效事件（Next事件），即依次判斷檢查memory植锉、disk辫樱、network
.firstElement()
// 即本例的邏輯為：
// a. firstElement()取出第1個事件 = memory，即先判斷內存緩存中有無數據緩存俊庇；由于memoryCache = null狮暑，即內存緩存中無數據，所以發(fā)送結束事件（視為無效事件）
// b. firstElement()繼續(xù)取出第2個事件 = disk辉饱，即判斷磁盤緩存中有無數據緩存：由于diskCache ≠ null搬男，即磁盤緩存中有數據，所以發(fā)送Next事件（有效事件）
// c. 即firstElement()已發(fā)出第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實戰(zhàn)系列：從磁盤 / 內存緩存中 獲取緩存數據
5. 總結
- 本文主要講解了
Rxjava的實際開發(fā)需求場景：從磁盤 / 內存緩存中 獲取緩存數據 - Carson帶你學RxJava系列文章：
入門
Carson帶你學Android：這是一篇清晰易懂的Rxjava入門教程
Carson帶你學Android：面向初學者的RxJava使用指南
Carson帶你學Android：RxJava2.0到底更新了什么？
原理
Carson帶你學Android：圖文解析RxJava原理
Carson帶你學Android：手把手帶你源碼分析RxJava
使用教程：操作符
Carson帶你學Android：RxJava操作符教程
Carson帶你學Android：RxJava創(chuàng)建操作符
Carson帶你學Android：RxJava功能性操作符
Carson帶你學Android：RxJava過濾操作符
Carson帶你學Android：RxJava組合/合并操作符
Carson帶你學Android：RxJava變換操作符
Carson帶你學Android：RxJava條件/布爾操作符
實戰(zhàn)
Carson帶你學Android：什么時候應該使用Rxjava？(開發(fā)場景匯總)
Carson帶你學Android：RxJava線程控制(含實例講解)
Carson帶你學Android：圖文詳解RxJava背壓策略
Carson帶你學Android：RxJava褐奴、Retrofit聯合使用匯總(含實例教程)
Carson帶你學Android：優(yōu)雅實現網絡請求嵌套回調
Carson帶你學Android：網絡請求輪詢(有條件)
Carson帶你學Android：網絡請求輪詢(無條件)
Carson帶你學Android：網絡請求出錯重連(結合Retrofit)
Carson帶你學Android：合并數據源
Carson帶你學Android：聯想搜索優(yōu)化
Carson帶你學Android：功能防抖
Carson帶你學Android：從磁盤/內存緩存中獲取緩存數據
Carson帶你學Android：聯合判斷
歡迎關注Carson_Ho的簡書
不定期分享關于安卓開發(fā)的干貨按脚，追求短、平敦冬、快辅搬，但卻不缺深度。
