文章轉(zhuǎn)載自：Hi大頭鬼_深入淺出RxJava四-在Android中使用響應式編程
個人感覺CSDN上看起來字體不是很舒服隔躲，所以轉(zhuǎn)載一下际长。
英文原文
在第1，2，3篇中省容，我大概介紹了RxJava是怎么使用的。下面我會介紹如何在Android中使用RxJava拂共。
RxAndroid
RxAndroid是RxJava的一個針對Android平臺的擴展唆途。它包含了一些能夠簡化Android開發(fā)的工具。
首先焕襟，AndroidSchedulers提供了針對Android的線程系統(tǒng)的調(diào)度器陨收。需要在UI線程中運行某些代碼？很簡單胧洒，只需要使用AndroidSchedulers.mainThread():
retrofitService.getImage(url)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(bitmap -> myImageView.setImageBitmap(bitmap));
如果你已經(jīng)創(chuàng)建了自己的Handler畏吓，你可以使用HandlerThreadScheduler將一個調(diào)度器鏈接到你的handler上墨状。
接著要介紹的就是AndroidObservable，它提供了跟多的功能來配合Android的生命周期菲饼。bindActivity()和bindFragment()方法默認使用AndroidSchedulers.mainThread()來執(zhí)行觀察者代碼肾砂，這兩個方法會在Activity或者Fragment結(jié)束的時候通知被觀察者停止發(fā)出新的消息。
AndroidObservable.bindActivity(this, retrofitService.getImage(url))
.subscribeOn(Schedulers.io())
.subscribe(bitmap -> myImageView.setImageBitmap(bitmap);
我自己也很喜歡AndroidObservable.fromBroadcast()方法宏悦，它允許你創(chuàng)建一個類似BroadcastReceiver的Observable對象镐确。下面的例子展示了如何在網(wǎng)絡變化的時候被通知到：
IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
AndroidObservable.fromBroadcast(context, filter)
.subscribe(intent -> handleConnectivityChange(intent));
最后要介紹的是ViewObservable,使用它可以給View添加了一些綁定。如果你想在每次點擊view的時候都收到一個事件饼煞，可以使用ViewObservable.clicks()源葫，或者你想監(jiān)聽TextView的內(nèi)容變化，可以使用ViewObservable.text()砖瞧。
ViewObservable.clicks(mCardNameEditText, false)
.subscribe(view -> handleClick(view));
Retrofit
大名鼎鼎的Retrofit庫內(nèi)置了對RxJava的支持息堂。通常調(diào)用發(fā)可以通過使用一個Callback對象來獲取異步的結(jié)果：
@GET("/user/{id}/photo")
void getUserPhoto(@Path("id") int id, Callback<Photo> cb);
使用RxJava，你可以直接返回一個Observable對象块促。
@GET("/user/{id}/photo")
Observable<Photo> getUserPhoto(@Path("id") int id);
現(xiàn)在你可以隨意使用Observable對象了荣堰。你不僅可以獲取數(shù)據(jù)，還可以進行變換竭翠。
Retrofit對Observable的支持使得它可以很簡單的將多個REST請求結(jié)合起來振坚。比如我們有一個請求是獲取照片的，還有一個請求是獲取元數(shù)據(jù)的斋扰，我們就可以將這兩個請求并發(fā)的發(fā)出渡八，并且等待兩個結(jié)果都返回之后再做處理：
Observable.zip(
service.getUserPhoto(id),
service.getPhotoMetadata(id),
(photo, metadata) -> createPhotoWithData(photo, metadata))
.subscribe(photoWithData -> showPhoto(photoWithData));
在第二篇里我展示過一個類似的例子（使用flatMap()）。這里我只是想展示以下使用RxJava + Retrofit可以多么簡單地組合多個REST請求传货。
遺留代碼屎鳍，運行極慢的代碼
Retrofit可以返回Observable對象，但是如果你使用的別的庫并不支持這樣怎么辦损离？或者說一個內(nèi)部的內(nèi)碼哥艇，你想把他們轉(zhuǎn)換成Observable的？有什么簡單的辦法沒僻澎？
絕大多數(shù)時候Observable.just() 和 Observable.from() 能夠幫助你從遺留代碼中創(chuàng)建 Observable 對象:
private Object oldMethod() { ... }
public Observable<Object> newMethod() {
return Observable.just(oldMethod());
}
上面的例子中如果oldMethod()足夠快是沒有什么問題的貌踏，但是如果很慢呢？調(diào)用oldMethod()將會阻塞住他所在的線程窟勃。
為了解決這個問題祖乳，可以參考我一直使用的方法 – 使用defer()來包裝緩慢的代碼：
private Object slowBlockingMethod() { ... }
public Observable<Object> newMethod() {
return Observable.defer(() -> Observable.just(slowBlockingMethod()));
}
現(xiàn)在，newMethod()的調(diào)用不會阻塞了秉氧，除非你訂閱返回的observable對象眷昆。
生命周期
我把最難的不分留在了最后。如何處理Activity的生命周期？主要就是兩個問題：
- 在
configuration改變（比如轉(zhuǎn)屏）之后繼續(xù)之前的Subscription亚斋。
比如你使用Retrofit發(fā)出了一個REST請求作媚，接著想在listview中展示結(jié)果。如果在網(wǎng)絡請求的時候用戶旋轉(zhuǎn)了屏幕怎么辦帅刊？你當然想繼續(xù)剛才的請求纸泡，但是怎么搞？ - Observable持有Context導致的內(nèi)存泄露
這個問題是因為創(chuàng)建subscription的時候赖瞒，以某種方式持有了context的引用女揭，尤其是當你和view交互的時候，這太容易發(fā)生栏饮！如果Observable沒有及時結(jié)束吧兔，內(nèi)存占用就會越來越大。
不幸的是袍嬉，沒有銀彈來解決這兩個問題境蔼，但是這里有一些指導方案你可以參考。
第一個問題的解決方案就是使用RxJava內(nèi)置的緩存機制冬竟，這樣你就可以對同一個Observable對象執(zhí)行unsubscribe/resubscribe欧穴，卻不用重復運行得到Observable的代碼。cache() (或者 replay())會繼續(xù)執(zhí)行網(wǎng)絡請求（甚至你調(diào)用了unsubscribe也不會停止）泵殴。這就是說你可以在Activity重新創(chuàng)建的時候從cache()的返回值中創(chuàng)建一個新的Observable對象。
Observable<Photo> request = service.getUserPhoto(id).cache();
Subscription sub = request.subscribe(photo -> handleUserPhoto(photo));
// ...When the Activity is being recreated...
sub.unsubscribe();
// ...Once the Activity is recreated...
request.subscribe(photo -> handleUserPhoto(photo));
注意拼苍，兩次sub是使用的同一個緩存的請求笑诅。當然在哪里去存儲請求的結(jié)果還是要你自己來做，和所有其他的生命周期相關的解決方案一延虎疮鲫，必須在生命周期外的某個地方存儲吆你。（retained fragment或者單例等等）。
第二個問題的解決方案就是在生命周期的某個時刻取消訂閱俊犯。一個很常見的模式就是使用CompositeSubscription來持有所有的Subscriptions妇多，然后在onDestroy()或者onDestroyView()里取消所有的訂閱。
private CompositeSubscription mCompositeSubscription
= new CompositeSubscription();
private void doSomething() {
mCompositeSubscription.add(
AndroidObservable.bindActivity(this, Observable.just("Hello, World!"))
.subscribe(s -> System.out.println(s)));
}
@Override
protected void onDestroy() {
super.onDestroy();
mCompositeSubscription.unsubscribe();
}
你可以在Activity/Fragment的基類里創(chuàng)建一個CompositeSubscription對象燕侠，在子類中使用它者祖。
注意! 一旦你調(diào)用了 CompositeSubscription.unsubscribe()，這個CompositeSubscription對象就不可用了, 如果你還想使用CompositeSubscription绢彤，就必須在創(chuàng)建一個新的對象了七问。
兩個問題的解決方案都需要添加額外的代碼，如果誰有更好的方案茫舶，歡迎告訴我械巡。
總結(jié)
RxJava還是一個很新的項目，RxAndroid更是。RxAndroid目前還在活躍開發(fā)中讥耗，也沒有多少好的例子有勾。我打賭一年之后我的一些建議就會被看做過時了。
