使用RxJava从多个数据源获取数据
试想,需要一些动态数据的时候,只要每次都请求网络就可以了。但是,更有效率的做法是,把联网得到的数据,缓存到磁盘或内存。
具体的说,计划如下:
偶尔的联网操作,只为获取最新数据。
尽可能快的读取到数据(通过获取之前缓存的网络数据)。
我将通过使用 RxJava ,来实现这个计划。
基本模式
为每一个数据源(网络,磁盘和内存)创建Observable,使用concat()和first()操作符,构造一个简单的实现方式。
concat() 操作符持有多个Observable对象,并将它们按顺序串联成队列。 first() 操作符只从串联队列中取出并发送第一个事件。因此,如果使用concat().first(),无论多少个数据源,只有第一个事件会被检索出并发送。
- // Our sources (left as an exercise for the reader)
- Observable memory = ...;
- Observable disk = ...;
- Observable network = ...;
- // Retrieve the first source with data
- Observable source = Observable
- .concat(memory, disk, network)
- .first();
- // Our sources (left as an exercise for the reader)
- Observablememory = ...;
- Observabledisk = ...;
- Observablenetwork = ...;
- // Retrieve the first source with data
- Observablesource = Observable
- .concat(memory, disk, network)
- .first();
这种模式的关键在于concat()操作符只有需要数据的时候才会订阅所有的Observable数据源。由于first()操作符会较早的停止检 索队列,所以,如果存在缓存数据,就没有必要访问较慢的数据源。 也就是说,如果memory返回结果,就不必担心disk和network会被访问。相反地,如果内存和磁盘都没有数据,才执行网络请求。
注意concat()所持有的Observable数据源,是按照一个接一个的顺序被检索的。
持久化数据
很明显,下一步是缓存数据。如果不把网络请求后的结果缓存到磁盘,磁盘访问后的结果缓存到内存,那么这根本不就不叫缓存。接下来要写的代码就是,网络数据的持久化操作。
我的解决方案是,让每个数据源在发送完事件后,都保存或者缓存数据。
- Observable networkWithSave = network.doOnNext(new Action1() {
- @Override public void call(Data data) {
- saveToDisk(data);
- cacheInMemory(data);
- }
- });
- Observable diskWithCache = disk.doOnNext(new Action1() {
- @Override public void call(Data data) {
- cacheInMemory(data);
- }
- });
- ObservablenetworkWithSave = network.doOnNext(new Action1() {
- @Overridepublic void call(Datadata) {
- saveToDisk(data);
- cacheInMemory(data);
- }
- });
- ObservablediskWithCache = disk.doOnNext(new Action1() {
- @Overridepublic void call(Datadata) {
- cacheInMemory(data);
- }
- });
现在,如果你使用networkWithSave和diskWithCache,数据将会在加载后自动保存。
(这個策略的另一个优势在于networkWithSave和diskWithCache可以在任何地方被使用,不局限于我们的多数据模式下。)
陈旧的数据
不幸的,现在我们保存数据的那些代码,执行的有点过头了。无论数据是否过时,它总是返回相同的数据。我们希望做到,偶尔连接服务器抓取最新的数据。
解决方法在于,使用first()操作符进行过滤。就是设置它拒绝接收毫无价值的数据。
- Observable source = Observable
- .concat(memory, diskWithCache, networkWithSave)
- .first(new Func1() {
- @Override public Boolean call(Data data) {
- return data.isUpToDate();
- }
- });
- Observablesource = Observable
- .concat(memory, diskWithCache, networkWithSave)
- .first(new Func1() {
- @Overridepublic Boolean call(Datadata) {
- return data.isUpToDate();
- }
- });
现在,我们只需要发送被断定为最新数据的事件就OK了。因此,只要有一个数据源的数据过期,就继续检索下一个数据源,直到找到最新数据为止。
first()和takeFirst()操作符的比较
对于这种设计模式,first()和takeFirst()操作符可以二选其一。
两种调用方式的区别在于,如果所有数据源的数据均过期,没有任何的有效数据作为事件发送,first()会抛出 NoSuchElementException异常(译者注:first()操作符均return false),而takeFirst()操作符则直接调用完成操作,不会抛出任何异常。
使用哪个操作符,完全取决于是否需要明确处理缺失的数据。
代码示例
可以从这里检出,以上所有代码的实现示例: https://github.com/dlew/rxjava-multiple-sources-sample 。
如果需要一个真实示例,检出 Gfycat App ,它在获取数据的时候使用了这种模式。项目并没有使用以上展示的所有功能(因为不需要),但是,示范了concat().first()的基本用法。
来源:51CTO
使用RxJava从多个数据源获取数据相关推荐
- ajax请求数据 ztree_ajax 异步获取数据填充到表格显示(ajax) 文档(Options API) DataTables中文网...
描述(Description) 使用这个参数可以让 DataTables 像使用jQuery ajax 一样从一个数据源获取数据,最终获取到返回的数据 来显示表格,DataTables 支持 Java ...
- mysql从库数据源_SoapUI Pro教程:如何使用MySQL服务器作为数据源-从MySQL数据库获取数据...
SoapUI Pro拥有许多其他web服务测试工具所不具备的高级技术和功能.对于REST.SOAP以及其他流行的API和物联网协议,SoapUI Pro提供了业界最全面的功能测试功能.通过易用的图形界 ...
- R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据、获取美国10年期债券收益率数据
R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据.获取美国10年期债券收益率数据 目录 R语言使用quantmod包的getSymbols函数从指定金融数 ...
- R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据、从雅虎金融读取著名港股长江实业的股票数据
R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据.从雅虎金融读取著名港股长江实业的股票数据 目录 R语言使用quantmod包的getSymbols函数从 ...
- R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据、从雅虎金融读取著名的苹果公司的全部股票数据
R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据.从雅虎金融读取著名的苹果公司的全部股票数据 目录 R语言使用quantmod包的getSymbols函数 ...
- R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据、美股不使用后缀、其它股票需要使用后缀:大陆沪市使用:“.SS“,深市使用:“.SZ“,香港使用:“.HK
R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据.美股不使用后缀.其它股票需要使用后缀:大陆沪市使用:".SS",深市使用:" ...
- R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据、对股票进行除权除息调整
R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据.对股票进行除权除息调整 目录 R语言使用quantmod包的getSymbols函数从指定金融数据源获取 ...
- R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据、对股票进行除权除息调整、设置使用Adjusted列的数据
R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据.对股票进行除权除息调整.设置使用Adjusted列的数据 目录 R语言使用quantmod包的getSy ...
- R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据、计算除权除息之后的开盘价收盘价收益率和收盘价收益率、保持不变
R语言使用quantmod包的getSymbols函数从指定金融数据源获取指定时间段的股票数据.计算除权除息之后的开盘价收盘价收益率和收盘价收益率.保持不变 目录 R语言使用quantmod包的get ...
最新文章
- 动词ing形式的5种用法_课后文档:英语语法思维第7课动词的5个形式的用法
- WMS请求GetCapabilities,变成下载mapserv.exe解决办法
- 计算机24点游戏几把,24点游戏规则和解题方法
- 关于ibatis的SQL注入。
- 【证明】【一题多解】布尔不等式(union bound)的证明
- 做下一个互联网时代的“水电公司”——融云的通信云视野与蓝图
- Linux下重启tomcat
- 如何用计算机看苹果手机的文件,苹果手机备忘录在哪个文件夹?如何查看苹果手机文件...
- JAVA代码生成器源码-基于SSM架构
- IC 拔取器 rework station
- ChatGPT学习研究总结
- iPhone 12 发布了
- 如何在富途证券开户,富途证券如何开户,如何开通港股账户,如何炒港股
- 边缘设备、系统及计算杂谈(10)——dapr学习之三
- oracle erp 地产公司,Oracle ERP房地产行业解决方案概述
- 【后端】MySQL数据库体系(二)
- 21.04.07-直角坐标系的Location类
- SDN/Openflow学习总结
- 这一年,那一年,三年总结
- [Docker] Dockerfile 记录