RxJava介绍

26 May 2017

RxJava

RxJava 是什么

官方的解释是： RxJava是 ReactiveX 在JVM上的一个实现，ReactiveX使用Observable序列组合异步和基于事件的程序。

Rx 是一个多语言实现

RxJava 支持Java 6或者更新的版本，以及其它的JVM语言如 Groovy, Clojure, JRuby, Kotlin 和 Scala。RxJava 可用于更多的语言环境，而不仅仅是Java和Scala，而且它致力于尊重每一种JVM语言的习惯。

为什么要使用 RxJava

函数式风格：对可观察数据流使用无副作用的输入输出函数，避免了程序里错综复杂的状态
简化代码：Rx的操作符通通常可以将复杂的难题简化为很少的几行代码
异步错误处理：传统的try/catch没办法处理异步计算，Rx提供了合适的错误处理机制

轻松使用并发：Rx的Observables和Schedulers让开发者可以摆脱底层的线程同步和各种并发问题

传统的调用方法 (此例子来自: https://gank.io/post/560e15be2dca930e00da1083#toc_32)

  new Thread() {
    @Override
    public void run() {
        super.run();
        for (File folder : folders) {
            File[] files = folder.listFiles();
            for (File file : files) {
                if (file.getName().endsWith(".png")) {
                    final Bitmap bitmap = getBitmapFromFile(file);
                    getActivity().runOnUiThread(new Runnable() {
                        @Override
                        public void run() {
                            imageCollectorView.addImage(bitmap);
                        }
                    });
                }
            }
        }
    }
  }.start();

此例子就是异步遍历文件，如果是以png结尾的就转换成位图，然后在主线程中显示。

如果我们换成RxJava来写呢

Observable.from(folders)
  .flatMap(new Func1<File, Observable<File>>() {
      @Override
      public Observable<File> call(File file) {
          return Observable.from(file.listFiles());
      }
  })
  .filter(new Func1<File, Boolean>() {
      @Override
      public Boolean call(File file) {
          return file.getName().endsWith(".png");
      }
  })
  .map(new Func1<File, Bitmap>() {
      @Override
      public Bitmap call(File file) {
          return getBitmapFromFile(file);
      }
  })
  .subscribeOn(Schedulers.io())
  .observeOn(AndroidSchedulers.mainThread())
  .subscribe(new Action1<Bitmap>() {
      @Override
      public void call(Bitmap bitmap) {
          imageCollectorView.addImage(bitmap);
      }
  });

是不是这样子写逻辑清晰多了。其实上面的例子还是简单的遍历筛选显示，如果再加上更加复杂的逻辑的话，代码将变得十分混乱，大家都是程序员，这种复杂的逻辑就算加了注释，隔几天不看，回头再来，也有可能看不懂。

所以RxJava是很必要学习并使用的。

RxJava 怎么使用呢？

简单的使用

Observable.just("hello", "my", "name", "is", "nichool")
              .subscribe(new Action1<String>() {
                  @Override
                  public void call(String s) {
                      LogUtils.LogW(s);
                  }
              });

通过just来创建一个被观察者，被观察者中决定将会做的事情，然后subscribe进行注册观察者。

以下为在观察者中将会打印的 :

RxJavaDemo: hello
RxJavaDemo: my
RxJavaDemo: name
RxJavaDemo: is
RxJavaDemo: nichool

复杂的操作

Student[] students= new Student[]{
           new Student("nichool", 100),
           new Student("li", 54),
           new Student("wang", 64),
           new Student("wu", 70),
           new Student("liu", 59),
           new Student("liu", 60),
   };

   Observable.from(students).filter(new Func1<Student, Boolean>() {
       @Override
       public Boolean call(Student student) {
           return student.score >= 60;
       }
   }).map(new Func1<Student, String>() {
       @Override
       public String call(Student student) {
           return student.mName + " is a qualified student";
       }
   }).subscribe(new Action1<String>() {
       @Override
       public void call(String s) {
           LogUtils.LogW(s);
       }
   });

以上代码为：在学生中查找及格的学生，并打印合格学生表。

RxJavaDemo: nichool is a qualified student
RxJavaDemo: wang is a qualified student
RxJavaDemo: wu is a qualified student
RxJavaDemo: liu is a qualified student

如果想了解更多的操作符使用请查看操作方法这篇文章

在Android上的配置与使用
```
compile 'io.reactivex:rxandroid:1.2.1'
// Because RxAndroid releases are few and far between, it is recommended you also
// explicitly depend on RxJava's latest version for bug fixes and new features.
compile 'io.reactivex:rxjava:1.1.6'
```
在需要使用RxJava的对应模块下的build.gradle 中添加这几句 (如需使用其他的版本，请修改版本号)。使用RxAndroid时最好带着RxJava，官方的解释是RxAndroid的版本还很少，需要用RxJava来弥补它的不足。

RxAndroid

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

它提供了一个可以在给定的Android Handler 上调度 Observable 的调度器 Scheduler，特别是在UI主线程上 (AndroidSchedulers.mainThread()、AndroidSchedulers.handlerThread(handler))。

它提供了一些操作符，让你可以更容易的处理 Fragment 和 Activity 的生命周期方法。

 // MyActivity
 private Subscription subscription;

 protected void onCreate(Bundle savedInstanceState) {
     this.subscription = observable.subscribe(this);
 }

 ...

 protected void onDestroy() {
     this.subscription.unsubscribe();
     super.onDestroy();
 }

它提供了很多Android消息和通知组件的包装类，用于与Rx的调用链搭配使用。
针对常见的Android用例和重要的UI，它提供了可复用的、自包含的响应式组件。（即将到来）

Android中使用 RxLifecycle 更好的保证及时的注册与解除注册。

 .compose(this.<Long>bindToLifecycle())   
 //这个订阅关系跟Activity绑定，Observable  和activity生命周期同步

RxLifecycle更多方法请自行百度

Twitter Facebook Google+