介绍

rxjava-android 模块包含RxJava的Android特定的绑定代码。它给RxJava添加了一些类，用于帮助在Android应用中编写响应式(reactive)的组件。

  • 它提供了一个可以在给定的Android Handler 上调度 Observable 的调度器 Scheduler，特别是在UI主线程上。
  • 它提供了一些操作符，让你可以更容易的处理 Fragment 和 Activity 的生命周期方法。
  • 它提供了很多Android消息和通知组件的包装类，用于与Rx的调用链搭配使用。
  • 针对常见的Android用例和重要的UI，它提供了可复用的、自包含的响应式组件。（即将到来）

Binaries

你可以在 http://search.maven.org 找到用于Maven, Ivy, Gradle和其它构建系统的二进制文件和依赖信息。

Maven 示例：

  1. <dependency>
  2.     <groupId>io.reactivex</groupId>
  3.     <artifactId>rxandroid</artifactId>
  4.     <version>0.23.0</version>
  5. </dependency>

Ivy 示例：

  1. <dependency org="io.reactivex" name="rxandroid" rev="0.23.0" />

当前支持的最低API版本(minSdkVersion)是 10 (Android 2.3/Gingerbread)

示例

在UI线程观察(Observing)

在Android上，通常处理异步任务时你会在主线程上等待(observing)处理结果，一般情况下你使用 AsyncTask 达到这个目的。使用RxJava，你会使用 observeOn 操作符声明你要在主线程等待 Observable 的结果：

  1. public class ReactiveFragment extends Fragment {
  3. @Override
  4. public void onCreate(Bundle savedInstanceState) {
  5.     super.onCreate(savedInstanceState);
  6.     Observable.from("one", "two", "three", "four", "five")
  7.             .subscribeOn(Schedulers.newThread())
  8.             .observeOn(AndroidSchedulers.mainThread())
  9.             .subscribe(/* an Observer */);
  10. }

这个例子中，Observable在一个新的线程执行，结果通过 onNext 在主线程发射。

在任意线程观察(Observing)

前面的例子是一个普遍概念的特殊版本：Android使用一个叫 Handler 的类绑定异步通信到消息循环。为了在任意线程 观察 一个Observable，需要创建一个与那个类关联的 Handler，然后使用 AndroidSchedulers.handlerThread 调度器：

  1. new Thread(new Runnable() {
  2.     @Override
  3.     public void run() {
  4.         final Handler handler = new Handler(); // bound to this thread
  5.         Observable.from("one", "two", "three", "four", "five")
  6.                 .subscribeOn(Schedulers.newThread())
  7.                 .observeOn(AndroidSchedulers.handlerThread(handler))
  8.                 .subscribe(/* an Observer */)
  10.         // perform work, ...
  11.     }
  12. }, "custom-thread-1").start();

这个例子中，Observable在一个新的线程执行，结果通过 onNext 在 custom-thread-1 线程上发射。（这个例子不太自然，因为你可以调用observeOn(Schedulers.currentThread())，但是它说清楚了这个想法。）

Fragment和Activity生命周期

在Android上，要在异步操作中访问框架中的对象有些棘手，那是因为Andoid系统可以决定销毁(destroy)一个 Activity，例如，当一个后台线程还在运行的时候，如果这个线程尝试访问一个已经死掉的Activity中的View对象，会导致异常退出(Crash)。（这也会导致内存泄露，因为 Activity 已经不可见了，你的后台线程还持有它的引用。）

这仍然是在Android上使用RxJava需要关注的一个问题，但是通过使用 Subscription和其它Observable操作符，你可以优雅地解决这个问题。通常来说，当你在Activity中订阅一个Observable的结果时（无论是直接的还是通过一个内部类），你必须在 onDestroy 里取消订阅，就像下面例子里展示的那样：

  1. // MyActivity
  2. private Subscription subscription;
  4. protected void onCreate(Bundle savedInstanceState) {
  5.     this.subscription = observable.subscribe(this);
  6. }
  8. ...
  10. protected void onDestroy() {
  11.     this.subscription.unsubscribe();
  12.     super.onDestroy();
  13. }

这样确保所有指向订阅者(这个Activity)的引用尽快释放，不会再有通知通过 onNext 发射给这个订阅者。

有一个问题，如果由于屏幕方向的变化导致这个 Activity 被销毁，在 onCreate 中这个Observable会再次启动。你可以使用 cache 或 replay 操作符阻止它发生，这些操作符保证Observable在 Activity 的生命周期内存在（你可以在一个全局的缓存中保存它，比如放在Fragment中。）你可以使用任何操作符，只要能保证：当订阅者订阅一个已经在运行的Observable时，在它与Activity 解除关联的这段时间里发射的数据都会被回放，并且来自这个Observable的任何离线通知都会正常分发。

参考资料