0.前言

這可能是我拖延最嚴重的系列文章了，從第一篇《 RxJava之旅(1)：RxJava思想基礎(chǔ)》到這一篇的間隔差不多有一年，導(dǎo)致每想到這個系列都慚愧不已，甚至好幾次沖動差點刪了。事情是這樣的，去年寫完第一篇以后立刻投入到了公司的新項目中，等項目最繁忙的階段過去已經(jīng)是2017年初，彼時RxJava2已經(jīng)發(fā)布，導(dǎo)致我覺得這個系列文章失去了繼續(xù)下去的價值，另一方面由于太懶一些原因，始終沒有去了解RxJava2。最近抽出空來看了一下第一篇的內(nèi)容，突發(fā)想起來事實上RxJava1和RxJava2本質(zhì)上都是響應(yīng)式編程，所以繼續(xù)這個系列是有意義的。接下來我會從RxJava1入手，然后通過RxJava1和RxJava2的不同對RxJava2進行介紹。因此，在RxJava2已經(jīng)出現(xiàn)的時候，介紹RxJava1是有意義的。

這一篇文章我們會從響應(yīng)式編程入手，從響應(yīng)式編程和面向?qū)ο缶幊踢M行對比，加深響應(yīng)式編程的理解，從而降低RxJava的學(xué)習(xí)曲線。

1.開始

作為入門，首先讓我們來快速地瀏覽一下RxJava的使用，在你的模塊(module)的build.gradle中添加依賴：

compile 'io.reactivex:rxjava:x.y.z'

其中x.y.z替換為最新的版本，關(guān)于版本號的查詢，請點擊這里。截止本文時，最新版本為1.3.0，因此配置如下：

dependencies {
    compile fileTree(dir: 'libs', include: ['*.jar'])        
    androidTestCompile('com.android.support.test.espresso:espresso-core:2.2.2', {
    exclude group: 'com.android.support', module: 'support-annotations'
    })
    compile 'com.android.support:appcompat-v7:26.0.0-alpha1'
    compile 'com.android.support.constraint:constraint-layout:1.0.2'

    testCompile 'junit:junit:4.12'

    //RxJava2
    compile "io.reactivex.rxjava2:rxjava:2.1.2"
    //RxJava1
    compile 'io.reactivex:rxjava:1.3.0'
}

我們可以看到，這里同時配置了RxJava1和RxJava2。為了RxJava1到RxJava2的平穩(wěn)過渡，在編寫RxJava2時使用了不同的包名，這樣即使將二者同時放入依賴中也不會造成依賴沖突。因此RxJava1和RxJava2是可以同時使用的，只是要小心查看一下所引入的包名是否正確，以免在應(yīng)該使用RxJava1的地方引入了RxJava2的類。

2.RP是一種怎樣的體驗

在正式開始之前讓我們先耐心地討論一個問題。上一篇文章我們認真地討論了什么是RP(Reactive Programming, 響應(yīng)式編程，下同)，以及響應(yīng)式編程和面向過程與面向?qū)ο缶幊痰奶攸c。

我們這里用一小節(jié)的內(nèi)容來看看同樣一個需求用RP和OOP(Object Oriented Programing,面向?qū)ο缶幊蹋峦?是如何實現(xiàn)的，這樣的對比可以幫助更好地理解響應(yīng)式編程以及RxJava。

2.1一個簡單的問題

我們的問題非常簡單：在Android中有兩個輸入框用于數(shù)字的輸入，分別輸入數(shù)字a和數(shù)字b，并計算得到結(jié)果c，即a+b=c。

2.2界面與初始化

界面

這個界面非常簡單，所以布局文件的代碼就不貼出來了。

關(guān)于Activity的部分也沒有難度，但是有必要貼出來說明每個控件的對應(yīng)關(guān)系：

//輸入框a
editTextA = (EditText) findViewById(R.id.et_a);
//輸入框b
editTextB = (EditText) findViewById(R.id.et_b);
//結(jié)果c
textViewC = (TextView) findViewById(R.id.tv_c);
//計算按鈕c
button = (Button) findViewById(R.id.btn_cal);

接下來我們分別用OOP和RP的方式來解決這個簡單的問題。

2.3OOP的解決方案

首先讓我們使用面向?qū)ο蟮姆绞絹斫鉀Q這個問題，很簡單這里涉及到三個成員變量，分別是a，b和c，以及用于計算和返回結(jié)果的兩個方法。我們定義了一個叫做Plus的類，代碼如下：

public class Plus {
    private int a;
    private int b;
    private int c;//c沒有g(shù)et或set方法

    public int getA() {
        return a;
    }

    public void setA(int a) {
        this.a = a;
    }

    public int getB() {
        return b;
    }

    public void setB(int b) {
        this.b = b;
    }
    //相加
    public void sum(){
        c = a + b;
    }
    //獲取結(jié)果
    public int getResult(){
        return c;
    } 

}

我們用OOP的方式將這個問題抽象成一個類，通過set方法為變量賦值，通過sum方法進行計算，最后通過getResult方法獲取計算結(jié)果。

接下來我們考慮RP的方式是如何解決的。

2.4RP的解決方案

在第一篇中我們介紹了響應(yīng)式編程的核心概念，即一切皆數(shù)據(jù)流的編程思維。那么使用數(shù)據(jù)流的方式考慮我們這個簡單的問題，在a+b=c的公式中，a和b都是數(shù)據(jù)流，而c是對數(shù)據(jù)流a和數(shù)據(jù)流b的響應(yīng)。就是說通過監(jiān)聽數(shù)據(jù)流a和數(shù)據(jù)流b的變化，從而對c進行變化。

問題已經(jīng)變得清晰了，我們需要兩個數(shù)據(jù)流來表示a和b，然后將二者最新值相加并顯示在c的位置。

以下部分的代碼涉及到了很多還未介紹的RxJava內(nèi)容，在這里我們不會對此進行細致的介紹，在后面將會逐一講解

2.4.1數(shù)據(jù)源的創(chuàng)建

首先來看數(shù)據(jù)流A和數(shù)據(jù)流B的創(chuàng)建：

final Observable<TextViewAfterTextChangeEvent> observableA = RxTextView.afterTextChangeEvents(editTextA).filter(new Predicate<TextViewAfterTextChangeEvent>() {
        @Override
        public boolean test(@NonNull TextViewAfterTextChangeEvent textViewAfterTextChangeEvent) throws Exception {
            return null != textViewAfterTextChangeEvent.editable() && !TextUtils.isEmpty(textViewAfterTextChangeEvent.editable().toString());
        }
    }); 
    
final Observable<TextViewAfterTextChangeEvent> observableB = RxTextView.afterTextChangeEvents(editTextB).filter(new Predicate<TextViewAfterTextChangeEvent>() {
        @Override
        public boolean test(@NonNull TextViewAfterTextChangeEvent textViewAfterTextChangeEvent) throws Exception {
            return null != textViewAfterTextChangeEvent.editable() && !TextUtils.isEmpty(textViewAfterTextChangeEvent.editable().toString());
        }
    });

這里用到了RxTextView，這是RxBinding庫中的一個類，用于TextView相關(guān)事件的監(jiān)聽。而RxBinding是用于Android UI控件的響應(yīng)式庫，具體的內(nèi)容我們會在后面的文章具體介紹。在這里我們所用到的RxTextView.afterTextChangeEvents()實際上對應(yīng)著TextWatcher::afterTextChanged（）方法，這樣相當(dāng)于使用editTextA.addTextChangedListener()方法添加了一個TextWatcher，然后監(jiān)聽其afterTextChanged()方法，將每次變化后的數(shù)據(jù)作為新產(chǎn)生的數(shù)據(jù)項，以供我們后續(xù)的處理。

對于RxBinding的引用，在module的build.gradle里dependencies代碼塊中配置如下依賴：

compile 'com.jakewharton.rxbinding2:rxbinding:2.0.0'

2.4.2數(shù)據(jù)流的訂閱（監(jiān)聽）

我們已經(jīng)定義了數(shù)據(jù)流，接下來可以去監(jiān)聽數(shù)據(jù)源的變化了。但是這里還有一個問題：由誰來監(jiān)聽數(shù)據(jù)流？對兩個數(shù)據(jù)流分別進行監(jiān)聽并不是一個好的方案，這樣會破壞RP的響應(yīng)式設(shè)計，所以我們需要一個新的數(shù)據(jù)流用來將數(shù)據(jù)流a和數(shù)據(jù)流b組合在一起，形成一個新的數(shù)據(jù)流c，然后對數(shù)據(jù)流c進行訂閱，將每次變化的值展示在界面上。

讓我們看一下數(shù)據(jù)流c是如何創(chuàng)建的：

Observable.combineLatest(observableA, observableB, new BiFunction<TextViewAfterTextChangeEvent, TextViewAfterTextChangeEvent, String>() {
        @Override
        public String apply(@NonNull TextViewAfterTextChangeEvent textViewAfterTextChangeEvent, @NonNull TextViewAfterTextChangeEvent textViewAfterTextChangeEvent2) throws Exception {
            int a = TextUtils.isEmpty(textViewAfterTextChangeEvent.editable().toString())? 0 : Integer.valueOf(textViewAfterTextChangeEvent.editable().toString());
            int b = TextUtils.isEmpty(textViewAfterTextChangeEvent2.editable().toString())? 0 : Integer.valueOf(textViewAfterTextChangeEvent2.editable().toString());
            return String.valueOf(a + b);

        }
    });

這里我們第一次用到了RxJava中的操作符(operator)，操作符是RP中一個很重要的概念，往往用于數(shù)據(jù)流的轉(zhuǎn)變。如果我們將數(shù)據(jù)流比作生產(chǎn)的流水線的話，操作符就是流水線上的某些儀器，可以對流水線上的物品進行轉(zhuǎn)換，組合等操作。

這里我們簡單介紹一個所用到的combineLatest，具體的在后面介紹。combineLatest可以將多個數(shù)據(jù)流（我們這里是兩個）的最后一項數(shù)據(jù)組合在一起，然后生成一個新的數(shù)據(jù)流繼續(xù)向下流動。圖示如下：

我們這里取到a和b的最后一個int數(shù)值，然后將它們加在一起。

2.4.3訂閱

在得到新生成的數(shù)據(jù)流c后，我們對數(shù)據(jù)流c進行訂閱，將c的每次變化都展示在界面，代碼如下：

Observable.combineLatest(observableA, observableB, new BiFunction<TextViewAfterTextChangeEvent, TextViewAfterTextChangeEvent, String>() {
        @Override
        public String apply(@NonNull TextViewAfterTextChangeEvent textViewAfterTextChangeEvent, @NonNull TextViewAfterTextChangeEvent textViewAfterTextChangeEvent2) throws Exception {
            int a = TextUtils.isEmpty(textViewAfterTextChangeEvent.editable().toString())? 0 : Integer.valueOf(textViewAfterTextChangeEvent.editable().toString());
            int b = TextUtils.isEmpty(textViewAfterTextChangeEvent2.editable().toString())? 0 : Integer.valueOf(textViewAfterTextChangeEvent2.editable().toString());
            return String.valueOf(a + b);

        }
    }).subscribe(new Observer<String>() {
        @Override
        public void onSubscribe(@NonNull Disposable d) {
            Log.d(TAG, "onSubscribe");

        }

        @Override
        public void onNext(@NonNull String s) {
            Log.d(TAG, s);
            textViewC.setText(s);//展示結(jié)果c
        }

        @Override
        public void onError(@NonNull Throwable e) {
            Log.e(TAG, e.getMessage());
        }

        @Override
        public void onComplete() {
            Log.d(TAG, "completed");
        }
    });

2.4.4 效果

可以注意到我們并沒有使用按鈕進行處理，而是根據(jù)數(shù)據(jù)的變化自動進行響應(yīng)。這符合RP的概念，也是RxJava的優(yōu)點之一。最后展現(xiàn)的結(jié)果如圖：

3.Hello RxJava1!

我們已經(jīng)看到了使用RxJava進行響應(yīng)式編程是如何便捷，那么這一節(jié)我們終于可以開始學(xué)習(xí)RxJava1了，讓我們從一段最簡單的代碼開始。

3.1 一段簡單的代碼

rx.Observable.just("Hello world")
            .subscribe(new rx.Observer<String>() {
                @Override
                public void onCompleted() {
                    Log.d(TAG,"completed.");
                }

                @Override
                public void onError(Throwable e) {
                    Log.e(TAG,e.getMessage());
                }

                @Override
                public void onNext(String s) {
                    Log.d(TAG,"next msg: " + s);
                }
            });

這是一段最簡單的RxJava代碼，我們的入門就從這里開始。

3.2 創(chuàng)建

just方法的完整定義如下：

public static <T> Observable<T> just(final T value)

just方法用于創(chuàng)建一個被觀察者，該方法可以將任何對象轉(zhuǎn)化為可觀察對象，其返回類型為Observable<T>。

關(guān)于創(chuàng)建的細節(jié)我們將在下一篇進行討論。

3.3訂閱

回顧一下第一篇的內(nèi)容，我們說過RxJava本質(zhì)上是觀察者模式。在觀察者模式中存在觀察者和被觀察者，觀察者訂閱被觀察者，當(dāng)觀察者發(fā)生變化時，被觀察者進行響應(yīng)。

RxJava和我們常見的觀察者模式有一點不同：由被觀察者去訂閱觀察者，而不是傳統(tǒng)的觀察者去訂閱被觀察者。當(dāng)Observable調(diào)用subscribe方法時，其入?yún)?code>Observer對象，即觀察者。在Observer中有三個方法，分別為onNext，onError，onComplete。

觀察者調(diào)用onNext對每一項流過的數(shù)據(jù)進行處理，如果處理失敗則調(diào)用onError，當(dāng)所有數(shù)據(jù)都處理完成且沒有錯誤時，應(yīng)當(dāng)調(diào)用onComplete方法。具體過程我們在下一篇進行介紹。

4.總結(jié)

事實上這一篇我們依然沒有對RxJava有什么實質(zhì)上的介紹，更像是對第一篇的補充。但是這一切我認為是值得的，因為很多人包括我在學(xué)習(xí)RxJava的初期都是直接撲向?qū)懛ê虯PI，由于對RP的理解不夠充分因此人為造成了較為陡峭的學(xué)習(xí)曲線。

在下一篇我們會詳細介紹創(chuàng)建和訂閱以及其源碼細節(jié)。