1. RxAndroid
RxAndroid 是专为Android设计的RxJava扩展，它包含各类工具简化Android应用开发。
首先，AndroidSchedulers调度器是针对Android线程系统而设计。想要在UI线程运行？没问题，只需使用AndroidSchedulers.mainThread()。
retrofitService.getImage(url)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(bitmap -> myImageView.setImageBitmap(bitmap));
如果你有自己的Handler，您可通过HandlerThreadScheduler1把它链接到你的Handler。
接下来，我们介绍AndroidObservable，它为Android生命周期内工作提供了便利。它提供bindActivity()和bindFragment()，自动使用AndroidSchedulers.mainThread()，Activity 或者 Fragment结束的时候通知。（注： Observable与Android生命周期关联，已经已入RxLifecycle库）
AndroidObservable.bindActivity(this, retrofitService.getImage(url))
.subscribeOn(Schedulers.io())
.subscribe(bitmap -> myImageView.setImageBitmap(bitmap));
我也喜欢AndroidObservable.fromBroadcast()方法，它允许你创建一个Observable类型BroadcastReceiver。下面展示网络变化时发出通知。
IntentFilter filter = new IntentFilter(ConnectivityManager.CONNECTIVITY_ACTION);
AndroidObservable.fromBroadcast(context, filter)
.subscribe(intent -> handleConnectivityChange(intent));
最后，我们介绍ViewObservable，它为View提供了一些绑定。ViewObservable.clicks()：这个方法让你在View被点击时做出响应，ViewObservable.text()：观察TextView内容改变。（现在可以RxBinding库中找到这些内容）
ViewObservable.clicks(mCardNameEditText, false)
.subscribe(view -> handleClick(view));
2. Retrofit
著名的Retrofit库已经支持RxJava，Retrofit是“Type-safe HTTP client for Android and Java”。通常定义一个异步方法需要添加一个回调方法（Callback）:
@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);
现在通过Observable能做到你想做的，不但能获取到数据，同时能对数据进行修改。
Retrofit支持Observable与HTTP调用相结合。比如：我们有一个方法需要先取得用户图片，然后取得用户基本信息数据。我们可以通过RxJava的zip()操作符把两个结果合并在一起。
Observable.zip(
service.getUserPhoto(id),
service.getPhotoMetadata(id),
(photo, metadata) -> createPhotoWithData(photo, metadata))
.subscribe(photoWithData -> showPhoto(photoWithData));
在第二篇中我展示过使用flatMap()操作符的例子。下面我想要展示的是使用RxJava + Retrofit组合多个HTTP请求是多么的简单。
3. 处理遗留，缓慢的代码
Retrofit返回Observables使逻辑变得多个简洁。但是如果你使用的其他库不支持RxJava呢？或者你程序内部的代码想过转换为Ob？基本上，如何在新系统中转换遗留代码而不需重写一切？
Observable.just() 和 Observable.from() 大都足以从遗留代码中创建Observable：
private Object oldMethod() { … }
public Observable<Object> newMethod() {
return Observable.just(oldMethod());
}
如果oldMethod()是快速的，这工作得很好。如果是耗时的呢？在把oldMethod()传递给Observable.just()之前就会阻塞线程。
为了解决这个问题，我一直是用一个小窍门，使用defer()包装耗时的操作：
private Object slowBlockingMethod() { … }
public Observable<Object> newMethod() {
return Observable.defer(() -> Observable.just(slowBlockingMethod()));
}
现在这个Observable在调用subscribe()方法钱都不会调用slowBlockingMethod()。
4. 生命周期
最后，我来解决最困难的部分。你如何处理Activity生命周期？有两个难缠的问题：
1. 在配置改变之间(如屏幕旋转)保持Subscription
假设你使用Retrofit构建了一个HTTP请求，然后在ListView展示结果。如果网络请求还没结束的时候，用户旋转了屏幕怎么办？你想保持刚才的请求，怎么做呢？
2. Observables 持有Context导致内存泄漏
这个问题是由subscription持有Context什么引起的，这样使得与Views交互变得容易。Observable不停止，你可能最终保留了很多额外的内存。
不幸的是，对于任何一个问题没有灵丹妙药，但也有一些可以遵循，使您的生活更轻松的指引。
第一个问题可以用一些RxJava内置的缓存机制来解决，这样你可以对同一个Observable执行退订/订阅，而不需要重复获取Observable的过程。特别是，cache()(或者replay())会继续执行请求（甚至你unsubscribe）。这意味着你可以在Activity重新创建后通过一个新的subscription回复。
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));
请注意，我们在两种情况使用相同的缓存请求，这种方式底层调用只发生一次，不管你在哪里缓存请求，但是类似所有的生命周期解决方案，都必须在生命周期中某处存储请求(类似fragment或者单例等)。
第二个问题解决方案是subscriptions调用unsubscribe方法。这里存在一个普遍的模式：使用CompositeSubscription来保持所有的Subscriptions，然后在onDestroy() 或者 onDestroyView()时调用unsubscribe()方法。
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，并且在内部创建CompositeSubscription ，生命周期最后自动unsubscribed。
警告！CompositeSubscription.unsubscribe() 不能够手动调用，换句话说就是有库自动调用。如果您计划重新使用这种模式之后，你必须创建一个新的CompositeSubscription作为替代。
解决这两个问题涉及添加代码，解决这两个问题没有所有的样本。
5. 结论
RxJava仍然是相当新的，针对Android的适配甚至更新。RxAndroid是处于活跃的开发状态，当前我在这里给出的建议以后每年可能都被视为古怪。