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

作者：佚名 2017-09-01 11:59:59

新聞移動開發

RxJava是非常熱門的函數響應式編程庫，在Android開發中已經非常流行了，剛開始上手會有點難，但只要理解了它，就再也回不去了。

RxJava是非常熱門的函數響應式編程庫，在Android開發中已經非常流行了，剛開始上手會有點難，但只要理解了它，就再也回不去了；不使用RxJava寫異步請求的話，就感覺各種不爽。

[[201947]]

本文不準備講RxJava的基礎知識，如果你對RxJava不熟悉，這里有篇不錯的教程可以參考《給 Android 開發者的 RxJava 詳解》。

下面我們開始介紹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
}

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

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

請求頭像上傳的地址
上傳頭像
更新用戶信息

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

Observable.just(1)
  .map(this::task1)
  .map(this::task2)
  .map(this::task3)
  .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調用

subscription.unsubscribe();

責任編輯：張燕妮來源：推酷

Android