本篇文章給大家分享的是有關RxJava中怎么從多個數(shù)據(jù)源獲取數(shù)據(jù),小編覺得挺實用的,因此分享給大家學習,希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。
成都創(chuàng)新互聯(lián)從2013年成立,先為臨潭等服務建站,臨潭等地企業(yè),進行企業(yè)商務咨詢服務。為臨潭企業(yè)網(wǎng)站制作PC+手機+微官網(wǎng)三網(wǎng)同步一站式服務解決您的所有建站問題。
具體的說,計劃如下:
偶爾的聯(lián)網(wǎng)操作,只為獲取***數(shù)據(jù)。
盡可能快的讀取到數(shù)據(jù)(通過獲取之前緩存的網(wǎng)絡數(shù)據(jù))。
基本模式
為每一個數(shù)據(jù)源(網(wǎng)絡,磁盤和內存)創(chuàng)建Observable,使用concat()和first()操作符,構造一個簡單的實現(xiàn)方式。
concat() 操作符持有多個Observable對象,并將它們按順序串聯(lián)成隊列。 first() 操作符只從串聯(lián)隊列中取出并發(fā)送***個事件。因此,如果使用concat().first(),無論多少個數(shù)據(jù)源,只有***個事件會被檢索出并發(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();
這種模式的關鍵在于concat()操作符只有需要數(shù)據(jù)的時候才會訂閱所有的Observable數(shù)據(jù)源。由于first()操作符會較早的停止檢 索隊列,所以,如果存在緩存數(shù)據(jù),就沒有必要訪問較慢的數(shù)據(jù)源。 也就是說,如果memory返回結果,就不必擔心disk和network會被訪問。相反地,如果內存和磁盤都沒有數(shù)據(jù),才執(zhí)行網(wǎng)絡請求。
注意concat()所持有的Observable數(shù)據(jù)源,是按照一個接一個的順序被檢索的。
持久化數(shù)據(jù)
很明顯,下一步是緩存數(shù)據(jù)。如果不把網(wǎng)絡請求后的結果緩存到磁盤,磁盤訪問后的結果緩存到內存,那么這根本不就不叫緩存。接下來要寫的代碼就是,網(wǎng)絡數(shù)據(jù)的持久化操作。
我的解決方案是,讓每個數(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ù)將會在加載后自動保存。
(這個策略的另一個優(yōu)勢在于networkWithSave和diskWithCache可以在任何地方被使用,不局限于我們的多數(shù)據(jù)模式下。)
陳舊的數(shù)據(jù)
不幸的,現(xiàn)在我們保存數(shù)據(jù)的那些代碼,執(zhí)行的有點過頭了。無論數(shù)據(jù)是否過時,它總是返回相同的數(shù)據(jù)。我們希望做到,偶爾連接服務器抓取***的數(shù)據(jù)。
解決方法在于,使用first()操作符進行過濾。就是設置它拒絕接收毫無價值的數(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了。因此,只要有一個數(shù)據(jù)源的數(shù)據(jù)過期,就繼續(xù)檢索下一個數(shù)據(jù)源,直到找到***數(shù)據(jù)為止。
first()和takeFirst()操作符的比較
對于這種設計模式,first()和takeFirst()操作符可以二選其一。
兩種調用方式的區(qū)別在于,如果所有數(shù)據(jù)源的數(shù)據(jù)均過期,沒有任何的有效數(shù)據(jù)作為事件發(fā)送,first()會拋出 NoSuchElementException異常(譯者注:first()操作符均return false),而takeFirst()操作符則直接調用完成操作,不會拋出任何異常。
使用哪個操作符,完全取決于是否需要明確處理缺失的數(shù)據(jù)。
以上就是RxJava中怎么從多個數(shù)據(jù)源獲取數(shù)據(jù),小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
當前題目:RxJava中怎么從多個數(shù)據(jù)源獲取數(shù)據(jù)
轉載源于:http://muchs.cn/article8/ppjeip.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站排名、微信小程序、企業(yè)建站、、云服務器、網(wǎng)站策劃
聲明:本網(wǎng)站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經(jīng)允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯(lián)