咱們爲何要在Android中使用RxJava

本文翻譯來自–>Why should we use RxJava on Android
另外： 微涼一季
再另外： 微涼一季

感受RxJava近期風生水起，不學習一下都很差意思了。灑家也是初學RxJava，也是感受代碼好像更復雜更難懂了。看了一篇外文感同身受，簡單翻譯一下。本文簡介使用RxJava優點所在。但可能需要有一點RxJava基礎，推薦先看一下拋物線的那篇經典的匠心寫做。
—–華麗切割線。譯文開始———

Reactive Extensions (Rx) 是一系列接口和方法。爲開發人員提供了一種易懂且迅速簡單易維護的方法。

RxJava就是幹這事兒的，提供一系列tools來幫你寫出簡潔的代碼。
老實說，一開始我以爲RxJava 寫的代碼理解起來很是困難。並且引入一個庫，單單就是爲了用用這樣的新式的api，這困擾到了我。後來。我懂了。以傳統的編碼方式。隨着app的發展，我需要重構代碼、一遍一遍的反覆樣板代碼。以知足用戶不斷變動的新需求，這讓我苦不堪言。
我作的大量工做，事實上是改寫相關方法和接口，就是因爲需求的變動（這是開發與產品間那些血案的原罪）或者需要改變展現的信息亦或是需要改變處理信息數據..這很是抓狂。

另外。這樣的代碼讓其它來維護的人來理解，通常是很是耗時的。

舉個栗子:咱們需要從數據庫獲取一組用戶的鏈表數據，並展現出來。咱們可以用AsyncTask後臺查詢數據庫，得到的結果給Ui的適配器展現出來。簡單演示樣例代碼：

public class SampleTask extends AsyncTask<Void,Void,List<Users>> {
    private final SampleAdapter mAdapter;

    public SampleTask(SampleAdapter sampleAdapter) {
        mAdapter = sampleAdapater;
    }

    @Override
    protected List<Users> doInBackground(Void... voids) {
        //fetch there results from the database and return them to the onPostExecute
        List<Users> users = getUsersFromDatabase();
        return users;
    }

    @Override
    protected void onPostExecute(List<Users> users) {
        super.onPostExecute(products);
        // Checking if there are users on the database
        if(users == null) {
            //No users, presenting a view saying there are no users
            showEmptyUsersMessageView();
            return;
        }
        for(User user : users){
            mAdapter.add(user);
        }
        mAdapter.notifyDataSetChanged();
    }
}

現在有個新需求，要求僅僅顯示非guest的user，咱們處理的方法是，在加入到adapter前加個條件推斷是否是guset，或者改變數據庫查詢的條件。

更有甚者。你又被要求從數據庫中獲取另外的其它信息。跟user一併在這個adapter中顯示出來呢？
這就是咱們爲何要用RxJava了，把咱們從這個泥潭中拉出來。換個姿式。咱們Rx代碼是這樣子（若是您已學習過Rx基礎使用方法）：

public Observable<List<User>> fetchUsersFromDatabase() {
    return Observable.create(new Observable.OnSubscribe<List<User>(){
        @Override
        public void call(Subscriber<?
super List<User>> subscriber){ // Fetch information from database subscriber.onNext(getUserList()); subscriber.onCompleted(); } }); }

像這樣被調用：

fetchUsersFromDatabase()
.subscribeOn(Schedulers.io())
//will process everything in a new thread
.observeOn(AndroidSchedulers.mainThread())
//will listen the results on the main thread
.subscribe(new Subscriber<List<User>>() {
           @Override
            public void onCompleted() {
            }
            @Override
            public void onError(Throwable e) {
            }
            @Override
            public void onNext(List<User> users) {
                //Do whatever you want with each user
            }
        });

開始改需求了哈
怎麼不顯示guests呢。RxJava分分鐘過濾掉這樣的不速之客：

fetchUsersFromDatabase()
        .filter(new Func1<User, Boolean>() {
            @Override
            public Boolean call(User user) {
                //only return the users which are not guests
                return !user.isGuest();
            }
        })
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new Subscriber<User>() {
                       @Override
                       public void onCompleted() {
                       }

                       @Override
                       public void onError(Throwable e) {
                           /*Check if there was any error while retrieving from database*/
                       }

                       @Override
                       public void onNext(User user) {
                           //Do whatever you want with each user
                       }
                   }
        );

傳統的方式，即使是個簡單的變動。爲了保持優雅的接口化編程，咱們也得建立新接口，重構代碼來實現過濾。

但是使用RxJava讓這一切變得優雅了，咱們僅僅需要一個被觀察者用來獲取所有的信息，讓後你就可以盡情的用這些方法來過濾獲取你想要的數據。
可能你又會說了。ok，這是很是好很是易讀的結構。但是這彷佛使代碼量變多了呢。well you are right，但是這就是Retrolambda閃耀的時候了，這個庫爲咱們兼容了以使用java8 lambda表達式，方法引用等等。

幫咱們簡化代碼例如如下：

fetchUsersFromDatabase()
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(value -> {
                    //Do whatever with the value
                },error -> {
                    //do something with in case of error
                }
        );

這個問題完美搞定，而後你又開始問了，我需要添加另外的查詢結果和user一同顯示在這個adapter中怎麼破。這真不是事兒：

fetchUsersFromDatabase()
        .zipWith(fetchSomethingElseFromDatabase(), (users, somethingElse) -> {
            /*here combine users and something else into a new object*/
        })
        .subscribe( o -> {
            /*use the combine object from users and something else to fill the adapter */
});

如上，咱們可以輕鬆組合數據庫查出來的其它數據和users給一個adapter一同顯示。是否是更易維護。代碼少。易讀，清晰？
若是要更深刻的學習RXJava可以看如下這篇文章，我看後受益不淺。

[Party tricks with RxJava, RxAndroid & Retrolambda](https://medium.com/p/1b06ed7cd29c)
另外，這篇教程 [tutorial ](https://gist.github.com/staltz/868e7e9bc2a7b8c1f754) 也幫我在RxJava路上進階了很是多。