Android(安卓)RxJava 实战系列:从磁盘 / 内存缓存中 获取缓存数据
16lz
2021-01-26
前言
Rxjava
,由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点,深受各大Android
开发者的欢迎。
如果还不了解RxJava,请看文章:Android:这是一篇 清晰 & 易懂的Rxjava 入门教程
RxJava
如此受欢迎的原因,在于其提供了丰富 & 功能强大的操作符,几乎能完成所有的功能需求- 今天,我将为大家带来
Rxjava
中的常见开发应用场景:从磁盘、内存缓存中获取缓存数据 ,希望大家会喜欢。
- 本系列文章主要基于
Rxjava 2.0
- 接下来的时间,我将持续推出
Android
中Rxjava 2.0
的一系列文章,包括原理、操作符、应用场景、背压等等 ,有兴趣可以继续关注Carson_Ho的安卓开发笔记!!
目录
1. 需求场景
- 注:关于
Rxjava
中的创建操作符firstElement()
和concat()
的使用请看文章
Android RxJava:最基础的操作符详解 - 创建操作符
Android RxJava:组合 / 合并操作符 详细教程
2. 功能说明
对于从磁盘 / 内存缓存中 获取缓存数据 的功能逻辑如下:
3. 具体实现
- 详细请看代码注释
// 该2变量用于模拟内存缓存 & 磁盘缓存中的数据 String memoryCache = null; String diskCache = "从磁盘缓存中获取数据"; /* * 设置第1个Observable:检查内存缓存是否有该数据的缓存 **/ Observable memory = Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter emitter) throws Exception { // 先判断内存缓存有无数据 if (memoryCache != null) { // 若有该数据,则发送 emitter.onNext(memoryCache); } else { // 若无该数据,则直接发送结束事件 emitter.onComplete(); } } }); /* * 设置第2个Observable:检查磁盘缓存是否有该数据的缓存 **/ Observable disk = Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter emitter) throws Exception { // 先判断磁盘缓存有无数据 if (diskCache != null) { // 若有该数据,则发送 emitter.onNext(diskCache); } else { // 若无该数据,则直接发送结束事件 emitter.onComplete(); } } }); /* * 设置第3个Observable:通过网络获取数据 **/ Observable 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() { @Override public void accept( String s) throws Exception { Log.d(TAG,"最终获取的数据来源 = "+ s); } });
- 测试结果
4. Demo地址
Carson_Ho的Github地址 = RxJava2实战系列:从磁盘 / 内存缓存中 获取缓存数据
5. 总结
- 本文主要讲解了
Rxjava
的实际开发需求场景:从磁盘 / 内存缓存中 获取缓存数据 - 下面我将结合 实际场景应用 &
Rxjava
的相关使用框架(如Retrofit
、Eventbus
) ,继续对Android
中Rxjava
的实际开发需求场景进行深入讲解 ,主要包括:
- 感兴趣的同学可以继续关注carson_ho的微信公众号
请 帮顶 / 评论点赞!因为你的鼓励是我写作的最大动力!
更多相关文章
- 【android】关于ListView的一些体会1
- Android(安卓)Studio Intent向上下活动传递数据 第一行代码
- 跟Google学习Android开发-起始篇-保存数据(3)
- Firefox常见问题总结
- Android(安卓)内容提供器---内容提供器基础(概述)
- Android(安卓)数据持久化存储
- H5跟ios、android数据对接
- Android(安卓)低功耗(BLE)蓝牙(三)
- 宏锦软件 Android(安卓)的 ListView 使用详解