編輯：關於Android編程
RxAndroid是RxJava在Android上的一個擴展，大牛JakeWharton的項目。據說和Retorfit、OkHttp組合起來使用，效果不是一般的好。而且用它似乎可以完全替代eventBus和OTTO，這麼牛的東西當然要研究研究了 ，看看它到底有多厲害。
RxJava的GitHub地址：https://github.com/ReactiveX/RxJava
RxAndroid的GitHub地址：https://github.com/ReactiveX/RxAndroid
中文文檔：https://mcxiaoke.gitbooks.io/rxdocs/content/
一篇寫的比較好的入門RxJava的文章的地址：http://gank.io/post/560e15be2dca930e00da1083
Rx(Reactive Extensions)是一個庫，用來處理事件和異步任務，在很多語言上都有實現，RxJava是Rx在Java上的實現。簡單來說，RxJava就是處理異步的一個庫，最基本是基於觀察者模式來實現的。通過Obserable和Observer的機制，實現所謂響應式的編程體驗。
Android的童鞋都知道，處理異步事件，現有的AsyncTask、Handler，不錯的第三方事件總線EventBus、OTTO等等都可以處理。並且大部分童鞋應該都很熟練了。而且經我目前的學習來看，RxJava這個庫，上手確實有門檻，不是拿來就能用。但是作為一個猿，那些可能出現的優秀的框架技術，及時的跟進和學習是必要的，從中汲取營養才能幫助自己成長。況且有童鞋已經表示，它完全可以替代EventBus和OTTO，來看看吧。
最概括的兩個字：簡潔。而且當業務越繁瑣越復雜時這一點就越顯出優勢——它能夠保持簡潔。
簡單的demo看不出來，真正投入項目使用了應該就有體會了。它提供的各種功能強悍的操作符真的很強大。
這裡只介紹Android Studio的接入方式，如果你還在用Eclipse的話，我建議你換了。
配置buile.gradle:(以下為當前最新版本，如有更新請到上述GitHub鏈接查看更新)
dependencies {
compile 'io.reactivex:rxandroid:1.2.1'
compile 'io.reactivex:rxjava:1.1.6'
}
配置完之後就可以使用RxJava的API了。介紹兩個個關鍵的類：
(1)Observable (2)Subscriber 即：被觀察者(Observable)和觀察者(Subscriber)，其實我覺得叫發布者和訂閱者更好理解一些，但大家都叫被觀察者和觀察者。
主干的使用過程就是1.創建被觀察者。2.創建觀察者。3.將二者建立聯系。完畢。然後被觀察中發出信息觸發觀察者的動作，執行相應的方法，就這樣。你先別急著吐槽它很平庸。它的強大在於這個過程中提供的各種操作變換的技巧會讓你可以簡潔的處理相當繁瑣的代碼邏輯。
先看一個簡單的demo:
//創建一個被觀察者(發布者)
Observable observable = Observable.create(new Observable.OnSubscribe() {
@Override
public void call(Subscriber subscriber) {
subscriber.onNext(1001);
subscriber.onNext(1002);
subscriber.onNext(1003);
subscriber.onCompleted();
}
});
//創建一個觀察者
Subscriber subscriber = new Subscriber() {
@Override
public void onCompleted() {
Log.d(TAG, "onCompleted.. ");
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "subscriber onError.. " + e.getMessage());
}
@Override
public void onNext(Integer integer) {
Log.d(TAG, "onNext.. integer:" + integer);
}
};
//注冊觀察者(這個方法名看起來有點怪，還不如寫成regisiterSubscriber(..)或者干脆addSubscriber(..))
//注冊後就會開始調用call()中的觀察者執行的方法 onNext() onCompleted()等
observable.subscribe(subscriber);
上面的例子中，當Observable發射數據時，會依次調用Subscriber的onNext()方法，將發射的數據作為參數傳給onNext()，如果出錯，則會調用Subscriber的onError()方法，完成所有數據發射後，調用onCompleted()方法，整個過程完畢。
但是，subcribe()方法默認在當前線程被調用。所以，這樣使用的話，被觀察者和觀察者的所有的動作都是在同一個線程完成的，沒卵用…
但是當然肯定不會就這個程度了，RxJava有兩個方法可以很方便的指定觀察者和被觀察者代碼運行的線程，RxAndroid還有一個擴展，可以指定在UI線程運行。你懂的！
如下：
//設置觀察者和發布者代碼所要運行的線程後注冊觀察者 observable.subscribeOn(Schedulers.immediate())//在當前線程執行subscribe()方法 .observeOn(AndroidSchedulers.mainThread())//在UI線程執行觀察者的方法 .subscribe(subscriber);
通過Scheduler作為參數來指定代碼運行的線程，非常方便，好用到不行…其他常用的參數還有：
Schedulers.immediate(): 直接在當前線程運行，相當於不指定線程。這是默認的 Scheduler。
Schedulers.newThread(): 總是啟用新線程，並在新線程執行操作。
Schedulers.io(): I/O 操作（讀寫文件、讀寫數據庫、網絡信息交互等）所使用的 Scheduler。行為模式和 newThread() 差不多，區別在於 io() 的內部實現是是用一個無數量上限的線程池，可以重用空閒的線程，因此多數情況下 io() 比 newThread() 更有效率。不要把計算工作放在 io() 中，可以避免建不必要的線程。
Schedulers.computation(): 計算所使用的 Scheduler。這個計算指的是 CPU 密集型計算，即不會被 I/O 等操作限制性能的操作，例如圖形的計算。這個 Scheduler 使用的固定的線程池，大小為 CPU 核數。不要把 I/O 操作放在 computation() 中，否則 I/O 操作的等待時間會浪費 CPU。
另外， Android 還有一個專用的 AndroidSchedulers.mainThread()，它指定的操作將在 Android 主線程運行。
以上介紹了主干使用流程，從這裡我們往細一點再看。前文說了，RxJava的強大之處在於它的各種操作符。在創建Observable對象的方式上，同樣有很多方便的操作符的實現，上面是通過Observable.create()方法創建的observable對象，這裡介紹其他幾個常用的方法。
通過from創建Observable：
//Teacher為一個數據Bean，包含姓名，年齡，住址三個字段 Listteachers = new ArrayList<>(); for (int i = 0; i < 4; i++) { teachers.add(new Teacher("name" + i, i, "place" + i)); } //from方法支持繼承了Interable接口的參數，所以常用的數據結構(Map、List..)都可以轉換 Observable fromObservale = Observable.from(teachers); fromObservale.subscribe(new Subscriber () { @Override public void onCompleted() { Log.i(TAG, "from(teachers) onCompleted"); } @Override public void onError(Throwable e) { Log.e(TAG, "from(teachers) " + e.getMessage()); } @Override public void onNext(Teacher teacher) { //依次接收到teachers中的對象 Log.d(TAG, "from(teachers) onNext:" + teacher.toString()); } });
用from方法創建Observable，可以傳入一個數組，或者一個繼承了Iterable的類的對象作為參數，也就是說，java中常用的數據結構如List、Map等都可以直接作為參數傳入from()方法用以構建Observable。這樣，當Observable發射數據時，它將會依次把序列中的元素依次發射出來。
通過just創建Observable：
//Just類似於From，但是From會將數組或Iterable的元素具取出然後逐個發射，而Just只是簡單的原樣發射，將數組或Iterable當做單個數據。
//Just接受一至九個參數，返回一個按參數列表順序發射這些數據的Observable
Observable justObservable = Observable.just(1, "someThing", false, 3.256f, new Teacher("Jhon", 25, "NewYork"));
justObservable.subscribe(new Subscriber() {
@Override
public void onCompleted() {
Log.i(TAG, "just(...) onCompleted");
}
@Override
public void onError(Throwable e) {
Log.d(TAG, "just(...) onError:" + e.getMessage());
}
@Override
public void onNext(Object o) {
Log.d(TAG, "just(...) onNext:" + o.toString());
}
});
just直接接收object作為參數，原樣發射出來，也是非常方便的。
通過timer創建Observable：
//timer()創建一個Observable，它在一個給定的延遲後發射一個特殊的值 設定執行方法在UI線程執行
//延時兩秒後發射值
//實測 延時2s後發送了一個0
Observable timerObservable = Observable.timer(2, TimeUnit.SECONDS, AndroidSchedulers.mainThread());
timerObservable.subscribe(
new Subscriber() {
@Override
public void onCompleted() {
Log.i(TAG, "timer(...) onCompleted");
refreshStr("timer(...) onCompleted\n");
}
@Override
public void onError(Throwable e) {
Log.e(TAG, "timer(...) onError:" + e.getMessage());
refreshStr("timer(...) onError:" + e.getMessage());
}
@Override
public void onNext(Object o) {
Log.d(TAG, "timer(...) onNext:" + o.toString());
refreshStr("timerObservable 延時兩秒觸發 發送值：" + o.toString());
}
}
);
timer有定時的作用，延時發送一個值０。
通過range創建Observable(這裡疊加使用一個repeat方法)：
//range 發射從n到m的整數序列 可以指定Scheduler設置執行方法運行的線程 //repeat方法可以指定重復觸發的次數 Observable rangeObservable = Observable.range(3, 7).repeat(2); rangeObservable.subscribe( //在不寫觀察者的情況下，可以使用Action1和Action0這兩個接口來實現不完整定義的回調； 參見：ActionSubscriber //Action1可以代替實現onNext(); Action1 可以代替實現onError(); Action0可以代替實現onConplete() new Action1() { @Override public void call(Object o) { Log.e(TAG, "range(3, 7).repeat(2) onNext:"+o.toString()); } }, new Action1 () { @Override public void call(Throwable throwable) { Log.e(TAG, "range(3, 7).repeat(2) "+throwable.getMessage()); } }, new Action0() { @Override public void call() { Log.i(TAG, "range(3, 7).repeat(2) onCompleted"); } });
range發射從n到m的整數序列，repeat可以指定重復次數，以上發射的次序為：3，4，5，6，7，3，4，5，6，7。這裡用到的Action0和Action1是兩個可以替代Subscriber的接口，具體可以參見相關文檔和源碼實現，這裡不深入介紹。
其他還有Interval、Defer、Start等方法就不一一介紹了，本文主要是幫助初次接觸的童鞋入門，RxJava的操作符非常豐富，這裡很難一一說明，更多的內容要還需要大家自己去熟悉和探究。
除了多樣的Observable創建方式，RxJava還有一個神奇的操作就是變換。通過自己定義的方法，你可以將輸入的值變換成另一種類型再輸出(比如輸入url，輸出bitmap)，單一變換、批量變換、甚至實現雙重變換，嵌套兩重異步操作！並且代碼格式一如既往的干淨平整。是不是很牛？
使用map()方法做轉換:
Runnable run = new Runnable() {
@Override
public void run() {
//將文件路徑轉換為bitmap發出 觀察者直接收到bitmap進行處理
Observable observable = Observable.just(imgFilePath);
observable.map(new Func1() {
@Override
public Bitmap call(String imgFilePath) {
return getBitmapFromAssets(imgFilePath);
}
}).subscribeOn(Schedulers.immediate())//當前線程(子線程)發布
.observeOn(AndroidSchedulers.mainThread())//UI線程執行(更新圖片)
.subscribe(new Subscriber() {
@Override
public void onCompleted() {
Log.i(TAG, "observable.map(..) onCompleted");
}
@Override
public void onError(Throwable e) {
Log.i(TAG, "observable.map(..) onError" + e.getMessage());
}
@Override
public void onNext(Bitmap bitmap) {
//顯示圖片
iv.setImageBitmap(bitmap);
}
});
}
};
new Thread(run).start();
map()方法是最基本的變換操作，這裡只變換了一個數據，將文件路徑解析為Bitmap顯示出來。你當然也可以多傳入幾個參數或者用from操作符傳入一個數組或者集合等，批量操作，並且同時指定代碼運行的線程。而且這些所有的操作都可以在一條鏈式代碼中全部完成，易讀易維護。你是不是已經有一點體會到它的威力了？
flatMap()實現雙重變換
flatMap()將一個發射數據的Observable變換為多個Observables，然後將它們發射的數據合並後放進一個單獨的Observable。即：第一次轉換時，它依次將輸入的數據轉換成一個Observable，然後將這些Observable發射的數據集中到一個Observable裡依次發射出來。覺得莫名其妙？來看一個實際例子：
