2. 程式人生 > >最適合使用RxJava處理的四種場景

最適合使用RxJava處理的四種場景

阿新 • • 發佈：2017-09-02
項目 cond mage ride 用戶 耗時 next image 多個

下面我們開始介紹RxJava最適合使用的四種場景，代碼示例基於RxJava1

場景一： 單請求異步處理

由於在Android UI線程中不能做一些耗時操作，比如網絡請求，大文件保存等，所以在開發中經常會碰到異步處理的情況，我們最典型的使用場景是RxJava+Retrofit處理網絡請求

MyService myService = retrofit.create(MyService.class);
myService.getSomething()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(this::updateUI, this::showError);

為了使代碼看起來簡潔點，這邊還使用了lambda表達式，updateUI和showError需要在當前類中實現，比如：

public void updateUI(Data data){
      //TODO something
}

public void showError(throwable t){
      //show error msg
}

場景二： 多異步請求連續調用

這種場景其實也很常見，我們做用戶頭像編輯的使用，一般就會有三個請求需要連續調用：

  1. 請求頭像上傳的地址
  2. 上傳頭像
  3. 更新用戶信息

在平時的代碼裏，我們需要一步步callback嵌套下來，代碼冗長太難看，而且不好維護，使用RxJava鏈式調用處理代碼邏輯就會非常清晰

MyService myService = retrofit.create(MyService.class);
myService.getUploadUrl()
        .flatMap(this::uploadImageTask)
        .flatMap(this::updateUserInfo)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(this::updateUI, this::showError);

這裏的just發送的固定值1，沒有實際意義，只是我覺得這樣更信息
你也可以用Observable.create創建observable。

場景三： 多異步請求合並處理

有時候在項目中，我們會碰到組合多個請求的結果後，再更新UI的情況，比如我們項目中就有一個從多個請求地址獲取通知數據，然後在APP上再按時間順序組合後展示的需求，這時候我們就可以用RxJava的zip函數來處理了

MyService myService = retrofit.create(MyService.class);
Observable o1 = myService.getNotification1();
Observable o2 = myService.getNotification2();
Observable.zip(o1,o2, this::combiNotification)
             .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(this::updateUI, this::showError);


public List<Notification> combiNotification(List<Notification> n1, List<Notification> n2){
      //TODO 合並通知列表
}

zip函數會等待兩個請求都完成後，調用我們的合並方法combiNotification，等合並處理後再回調subscribe中的方法。

場景四： 定時輪詢

RxJava還特別適合對定時輪詢任務的處理， 一種典型的例子就是APP提交了一個任務給後臺異步處理，假設後臺處理需要1-2分鐘左右，我們需要定時到後臺查詢進度，並更新到UI上, 傳統的做法是用Handler的postDelay方法，用RxJava實現的話就會非常簡潔

Subscription subscription =  Observable.interval(2, TimeUnit.SECONDS)
                .map(this::getProgress)
                .takeUntil(progress -> progress !=  100)
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Subscriber<Long>() {
                    @Override
                    public void onCompleted() {
                        //TODO finished
                    }

@Override
                    public void onError(Throwable e) {
                    }

@Override
                    public void onNext(int progress) {
                         //TODO update progress
                    }
                });

我們以定時2秒查詢一次，直到進度progress=100為止，自動終止輪詢。

以上各種RxJava方法都是異步耗時調用，考慮到Activity的退出時請求還沒有完成，我們需要在Activity的OnDestroy方法中取消RxJava調用

最適合使用RxJava處理的四種場景

相關推薦

最適合使用RxJava處理的四種場景

項目 cond mage ride 用戶 耗時 next image 多個 下面我們開始介紹RxJava最適合使用的四種場景，代碼示例基於RxJava1 場景一： 單請求異步處理 由於在Android UI線程中不能做一些耗時操作，比如網絡請求，大文件保存等，所以在開發中經

js取陣列最大值的四種方式

var arr = [7,2,0,-3,5];1.apply()應用某一物件的一個方法，用另一個物件替換當前物件 var max = Math.max.apply(null,arr);console.log(max)由於max()裡面引數不能為陣列，所以藉助apply(funtion,args)方法呼叫Ma

訊息佇列使用的四種場景介紹

訊息佇列中介軟體是分散式系統中重要的元件，主要解決應用耦合，非同步訊息，流量削鋒等問題 實現高效能，高可用，可伸縮和最終一致性架構 使用較多的訊息佇列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ 二、訊息佇列應用場景 以下介紹訊息佇列在實際應用中常用的使用

RxJava的四種Subjects：PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的理解

Subject：它既是Observable，又是observer。也就是既可以傳送事件，也可以接收事件。 下面是四個子類PublishSubject、ReplaySubject、BehaviorSubject、AsyncSubject的區別： PublishSubject<Integer>

this指向的四種場景

ons on() this 構造函數 並且 函數 實例對象 對象 test 第一、如果一個函數中有this，但是它沒有以對象方法的形式調用，而是以函數名的形式執行，那麽this指向的就是全局對象； 第二、如果一個函數中有this，並且這個函數是以對象方法的形式調用，那麽th

訊息佇列使用的四種場景

訊息佇列中介軟體是分散式系統中重要的元件，主要解決應用耦合，非同步訊息，流量削鋒等問題 實現高效能，高可用，可伸縮和最終一致性架構 使用較多的訊息佇列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ 二、訊息佇列應用場景 以下介紹訊息佇列在實際應用中常用的使用

最大子段和四種求法

給定n(1<=n<=100000)個整數（可能為負數）組成的序列a[1],a[2],a[3],…,a[n],求該序列如a[i]+a[i+1]+…+a[j]的子段和的最大值。當所給的整數均為負數時定義子段和為0，依此定義，所求的最優值為： Max{0,a[i]+a

消息隊列使用的四種場景介紹（轉）

rom 第三方 des soc 有一個 repl 訪問 都是 storm集群 消息隊列中間件是分布式系統中重要的組件，主要解決應用耦合，異步消息，流量削鋒等問題 實現高性能，高可用，可伸縮和最終一致性架構 使用較多的消息隊列有ActiveMQ，RabbitMQ，ZeroM

大量資料也不在話下，Spring Batch並行處理四種模式初探

# 1 前言 > 歡迎訪問[南瓜慢說 www.pkslow.com](https://www.pkslow.com/)獲取更多精彩文章！ `Spring相關文章：`[Springboot-Cloud](https://www.pkslow.com/categories/springboot) 前

算法入門：最大子序列和的四種算法（Java）

else 初始化 需要 nbsp ava 時間 pos sub for循環 最近再學習算法和數據結構，推薦一本書：Data structures and Algorithm analysis in Java 3rd 以下的四種算法出自本書 四種最大子序列和的算法： 問題描

java 強弱軟虛 四種引用，以及用到的場景

優先 時間 重新 通過 如果 sof queue hashcode 等待 1、利用軟引用和弱引用解決OOM問題：用一個HashMap來保存圖片的路徑和相應圖片對象關聯的軟引用之間的映射關系，在內存不足時，JVM會自動回收這些緩存圖片對象所占用的空間，從而有效地避免了OOM的

Android：圖解四種啟動模式 及 實際應用場景解說

類型 placed data val add The avi 能夠 per 在一個項目中會包括著多個Activity，系統中使用任務棧來存儲創建的Activity實例，任務棧是一種“後進先出”的棧結構。舉個栗子，若我們多次啟動同一個Activity。系統會創建多個實例依次放

json字串轉json物件的四種方式及對json字串的處理方式

1. 將json字串轉化為json物件 a. 方案一：jquery自帶的$.parseJSON函式 <script> var jsonstr="{\"id\":\"1\",\"name\":\"jack\"}"; var obj=$.parseJSON(jsonstr);

演算法 -- 四種方法獲取的最長“迴文串”，並對時間複雜進行分析對比&PHP

迴文串： “迴文串”是一個正讀和反讀都一樣的字串，比如“level”或者“noon”等等就是迴文串。 -- 來自百度百科 關於獲取字串中最長的迴文串的演算法中，目前有很多演算法，本文中主要是用PHP來實現的演算法之一。 演算法一：暴力解法 暴力計算出所有的字串並判斷。時間複雜

Java 處理 XML的四種方法 --&amp;gt;附:XmlUtils

XML現在已經成為一種通用的資料交換格式,平臺的無關性使得很多場合都需要用到XML。本文將詳細介紹用Java解析XML的四種方法。         XML現在已經成為一種通用的資料交換格式,它的平臺無關性,語言無關性,系統

一.背景 先說下windbg使用場景.各位coder在工作中或多或少都會遇到下面四種情況 1.原生代碼好好的,放伺服器上執行一段時間後,IIS服務突然佔用 w3wp.exe CPU突然100% ,

一.背景 先說下windbg使用場景.各位coder在工作中或多或少都會遇到下面四種情況 1.原生代碼好好的,放伺服器上執行一段時間後,IIS服務突然佔用 w3wp.exe CPU突然100% ,不得不回收應用程式池,如果哪次回收晚了,被客戶發現,後果很痛苦~ 2.你的w3wp.

資料預處理的四種方式

資料預處理 調整資料尺寸 讓所有的屬性按照相同的尺度來度量資料； 梯度下降演算法 神經網路 SVM 迴歸演算法 K 近鄰演算法 # 調整資料尺度（0..） import pandas as pd import numpy as np f

Java 中的四種引用使用場景分析

強引用 強引用的物件，永遠不會被垃圾回收，JVM 寧願丟擲 OutOfMemeory 錯誤也不會回收這種物件。 軟引用 soft 沒有強引用而只有軟引用的物件，只要記憶體空間足夠，垃圾回收器就不會回收（嚴謹的說法是，GC 根據記憶體使用情況酌情考慮什麼時候回收）。 MyO

Unity場景載入四種方式，不同遊戲場景載入方式不同

以前只是負責用，卻不知道里面的具體含義，特定去查看了一下資料。記錄下來。 Application.LoadLevel()：同步載入  Application.LoadLevelAsync():非同步載入  Application.LoadLevelAddic

Java 四種引用介紹及使用場景

強引用-FinalReference 介紹： 強引用是平常中使用最多的引用，強引用在程式記憶體不足（OOM）的時候也不會被回收，使用方式： String str = new String("str");這個str就是強引用。    可用場景： 地球人都知道，但是我講不出來。 軟引