扣丁书屋

使用RxJava从多个数据源中加载数据

假设我需要从网络上获取一些数据。每次需要数据的时候,我都可以简单的访问网络,但是,将数据缓存到磁盘或内存则可以更有效率。

更明确的说,我希望是这样的:

1、偶尔的从网络上获取新数据。 2、然而可以尽快的恢复数据(通过缓存网络数据的结果)。

我想要使用RxJava实现。

基本模式

给每一数据源(网络、磁盘和内存)一个Observable<Data>接口,我们可以通过两个操作:concat()first(),来实现一个简单的解决方案。

concat()持有多个Observables,并且把它们连接在队列里。first()仅从队列里中获取到第一个条目。因此,如果你使用concat().first()可以从多个数据源中获取到第一个。

让我们看看它是如何实现的:

// Our sources (left as an exercise for the reader)
Observable<Data> memory = ...;  
Observable<Data> disk = ...;  
Observable<Data> network = ...;

// Retrieve the first source with data
Observable<Data> source = Observable  
  .concat(memory, disk, network)
  .first();

这种模式的关键是concat()只在需要资源的时候才会订阅每个子Observable。如果数据被缓存,就不需要通过速度慢的数据源来获取数据。

注意concat()Observables数据源的顺序问题,因为它们是被一个接一个检索出来的。

保存数据

很显然,下一步就是保存数据源。如果,你没有将网络请求的结果保存到磁盘,将磁盘的地址保存在内存中,那就再也没法挽救啦!上面所有的代码就是让网咯请求持久化。

我的解决方式是在每次发出请求的时候保存或缓存数据源:

Observable<Data> networkWithSave = network.doOnNext(data -> {  
  saveToDisk(data);
  cacheInMemory(data);
});

Observable<Data> diskWithCache = disk.doOnNext(data -> {  
  cacheInMemory(data);
});

现在,如果你使用networkWithSavediskWithCache,数据都将会在你下载的时候自动保存。

(这种策略的另外一个好处就是networkWithSave/diskWithCache可以在任何地方使用,不仅仅在我们的多个数据源模式下。)

旧数据

很不幸,现在我们保存数据的代码运行的太好啦!它总是会返回相同的数据,不管数据有没有过期。记着,我想要返回到偶尔从服务器获取新的数据。

这个解决方案在first()中,我们可以执行筛选,只需要过滤掉那些过期的数据:

Observable<Data> source = Observable  
  .concat(memory, diskWithCache, networkWithSave)
  .first(data -> data.isUpToDate());

现在,我们只会获取被证明是最新的条目。因此,如果我们的资源有一条旧数据,我们就会略过,直接到下一条数据,直到我们找到新数据。

first()vs.takeFirst()

你可以选择使用first(),你也可以选择使用takeFirst()

这两种调用的区别是当没有可用资源的时候,first()会抛出一个NoSuchElementException的异常,然而,takeFirst()只会简单的结束。

你使用哪种就看你是否需要明确的处理数据是否用完。

代码案例

这里是以上代码的运用,你可以在这儿checkout出代码:https://github.com/dlew/rxjava-multiple-sources-sample

如果你需要一个实际案例,checkout出Gfycat的应用,它是使用这种模式查看Gfycat中的动态数据。Gfycat中的代码并没有使用以上的所有功能(因为它不需要),但是它演示了concat().first()的基本用法。

当钢铁侠反应更灵敏-RxJava

发布于:2年以前  |  1820次阅读  |  详细内容 »

用RxJava替代EventBus

发布于:2年以前  |  2651次阅读  |  详细内容 »

RxJava Observables单元测试

发布于:2年以前  |  1777次阅读  |  详细内容 »

RxJava中repeatWhen 和 retryWhen 操作符的解释

发布于:2年以前  |  3462次阅读  |  详细内容 »

NotRxJava懒人专用指南

发布于:2年以前  |  1658次阅读  |  详细内容 »

使用RxJava从多个数据源中加载数据

发布于:2年以前  |  2147次阅读  |  详细内容 »

在Android开发中使用RxJava

发布于:2年以前  |  1680次阅读  |  详细内容 »

如何理解RxJava中的Subjects(第一部分)

发布于:2年以前  |  1702次阅读  |  详细内容 »

结合RxJava更简单地使用SQLite

发布于:2年以前  |  1722次阅读  |  详细内容 »

使用RxJava缓存Rest请求

发布于:2年以前  |  1597次阅读  |  详细内容 »

Android中调试RxJava

发布于:2年以前  |  1433次阅读  |  详细内容 »

使用RxJava.Observable取代AsyncTask和AsyncTaskLoader

发布于:2年以前  |  2124次阅读  |  详细内容 »

使用RxJava 2.0

发布于:3年以前  |  1692次阅读  |  详细内容 »

使用RxJava缓存Rest请求

原文链接 : Subscribe It While It&#039;s Hot: Cached Rest Requests With RxJava 免责声明: 在这篇文章中,我尝试去用正确的方法来解决一个常见的问题。我仍然正在整理我脑袋...

发布于:3年以前  |  2692次阅读  |  详细内容 »

在Android开发中使用RxJava

ReactiveX是专注于异步工作的API,它将异步事件的处理与观察者模式、迭代器模式及函数式编程相结合了起来。实时地处理返回数据是在工程中经常出现的情景,所以使用高效、可...

发布于:3年以前  |  2400次阅读  |  详细内容 »

Android中调试RxJava

原文链接 : Debugging RxJava on Android 调试是查找和分析bug的过程或者预防软件的正确操作出现问题Wikipedia。 当前调试不是一件容易的事情,我们在处理Android的异步操...

发布于:3年以前  |  2406次阅读  |  详细内容 »

所属标签

最多阅读

简化Android的UI开发 2年以前  |  515143次阅读
Android 深色模式适配原理分析 1年以前  |  26450次阅读
Android 样式系统 | 主题背景覆盖 1年以前  |  7989次阅读
Android Studio 生成so文件 及调用 1年以前  |  5632次阅读
30分钟搭建一个android的私有Maven仓库 3年以前  |  4777次阅读
Android设计与开发工作流 2年以前  |  4439次阅读
Google Enjarify:可代替dex2jar的dex反编译 3年以前  |  4420次阅读
Android多渠道打包工具:apptools 3年以前  |  4056次阅读
移动端常见崩溃指标 2年以前  |  4053次阅读
Google Java编程风格规范(中文版) 3年以前  |  3959次阅读
Android-模块化-面向接口编程 1年以前  |  3886次阅读
Android内存异常机制(用户空间)_NE 1年以前  |  3857次阅读
Android UI基本技术点 3年以前  |  3807次阅读
Android死锁初探 2年以前  |  3765次阅读

手机扫码阅读