本篇文章給大家分享的是有關(guān)RxJava中怎么從多個(gè)數(shù)據(jù)源獲取數(shù)據(jù)，小編覺得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說(shuō)，跟著小編一起來(lái)看看吧。

成都創(chuàng)新互聯(lián)從2013年成立，先為臨潭等服務(wù)建站，臨潭等地企業(yè)，進(jìn)行企業(yè)商務(wù)咨詢服務(wù)。為臨潭企業(yè)網(wǎng)站制作PC+手機(jī)+微官網(wǎng)三網(wǎng)同步一站式服務(wù)解決您的所有建站問(wèn)題。

具體的說(shuō)，計(jì)劃如下：

1. 偶爾的聯(lián)網(wǎng)操作，只為獲取***數(shù)據(jù)。

2. 盡可能快的讀取到數(shù)據(jù)（通過(guò)獲取之前緩存的網(wǎng)絡(luò)數(shù)據(jù)）。

基本模式

為每一個(gè)數(shù)據(jù)源（網(wǎng)絡(luò)，磁盤和內(nèi)存）創(chuàng)建Observable，使用concat()和first()操作符，構(gòu)造一個(gè)簡(jiǎn)單的實(shí)現(xiàn)方式。

concat() 操作符持有多個(gè)Observable對(duì)象，并將它們按順序串聯(lián)成隊(duì)列。 first() 操作符只從串聯(lián)隊(duì)列中取出并發(fā)送***個(gè)事件。因此，如果使用concat().first()，無(wú)論多少個(gè)數(shù)據(jù)源，只有***個(gè)事件會(huì)被檢索出并發(fā)送。

// 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();

這種模式的關(guān)鍵在于concat()操作符只有需要數(shù)據(jù)的時(shí)候才會(huì)訂閱所有的Observable數(shù)據(jù)源。由于first()操作符會(huì)較早的停止檢 索隊(duì)列，所以，如果存在緩存數(shù)據(jù)，就沒(méi)有必要訪問(wèn)較慢的數(shù)據(jù)源。  也就是說(shuō)，如果memory返回結(jié)果，就不必?fù)?dān)心disk和network會(huì)被訪問(wèn)。相反地，如果內(nèi)存和磁盤都沒(méi)有數(shù)據(jù)，才執(zhí)行網(wǎng)絡(luò)請(qǐng)求。

注意concat()所持有的Observable數(shù)據(jù)源，是按照一個(gè)接一個(gè)的順序被檢索的。

持久化數(shù)據(jù)

很明顯，下一步是緩存數(shù)據(jù)。如果不把網(wǎng)絡(luò)請(qǐng)求后的結(jié)果緩存到磁盤，磁盤訪問(wèn)后的結(jié)果緩存到內(nèi)存，那么這根本不就不叫緩存。接下來(lái)要寫的代碼就是，網(wǎng)絡(luò)數(shù)據(jù)的持久化操作。

我的解決方案是，讓每個(gè)數(shù)據(jù)源在發(fā)送完事件后，都保存或者緩存數(shù)據(jù)。

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); } });

現(xiàn)在，如果你使用networkWithSave和diskWithCache，數(shù)據(jù)將會(huì)在加載后自動(dòng)保存。

（這個(gè)策略的另一個(gè)優(yōu)勢(shì)在于networkWithSave和diskWithCache可以在任何地方被使用，不局限于我們的多數(shù)據(jù)模式下。）

陳舊的數(shù)據(jù)

不幸的，現(xiàn)在我們保存數(shù)據(jù)的那些代碼，執(zhí)行的有點(diǎn)過(guò)頭了。無(wú)論數(shù)據(jù)是否過(guò)時(shí)，它總是返回相同的數(shù)據(jù)。我們希望做到，偶爾連接服務(wù)器抓取***的數(shù)據(jù)。

解決方法在于，使用first()操作符進(jìn)行過(guò)濾。就是設(shè)置它拒絕接收毫無(wú)價(jià)值的數(shù)據(jù)。

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();       }     });

現(xiàn)在，我們只需要發(fā)送被斷定為***數(shù)據(jù)的事件就OK了。因此，只要有一個(gè)數(shù)據(jù)源的數(shù)據(jù)過(guò)期，就繼續(xù)檢索下一個(gè)數(shù)據(jù)源，直到找到***數(shù)據(jù)為止。

first()和takeFirst()操作符的比較

對(duì)于這種設(shè)計(jì)模式，first()和takeFirst()操作符可以二選其一。

兩種調(diào)用方式的區(qū)別在于，如果所有數(shù)據(jù)源的數(shù)據(jù)均過(guò)期，沒(méi)有任何的有效數(shù)據(jù)作為事件發(fā)送，first()會(huì)拋出 NoSuchElementException異常（譯者注：first()操作符均return  false），而takeFirst()操作符則直接調(diào)用完成操作，不會(huì)拋出任何異常。

使用哪個(gè)操作符，完全取決于是否需要明確處理缺失的數(shù)據(jù)。

以上就是RxJava中怎么從多個(gè)數(shù)據(jù)源獲取數(shù)據(jù)，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

當(dāng)前題目：RxJava中怎么從多個(gè)數(shù)據(jù)源獲取數(shù)據(jù)
轉(zhuǎn)載源于：http://jinyejixie.com/article8/ppjeip.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站排名、微信小程序、企業(yè)建站、、云服務(wù)器、網(wǎng)站策劃

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)