Android开发(48) rxjava 入门篇

2016-06-23 本文已影响413人张云飞Vir

什么是 rxJava?

RxJava is a Java VM implementation of Reactive Extensions: a library for composing asynchronous and event-based programs by using observable sequences.
简单来说，rxJava 是一种 基于事件的，使用了可被观察序列 的异步 响应 扩展 的类库。

特性

rxJava 是解决异步问题的。
rxJava 是基于事件机制的。
rxJava 是处理响应扩展的，解决事件的响应问题（比如事件的响应在哪个线程？）。
rxJava 是序列的。它是个有顺序的队列，按顺序的，先进后出的。它对集合对象的支持很好。

rxJava 使用了设计模式里的观察者模式来实现。它的核心理念的两个东西：

被观察者被观察的对象，它是一个事件源，它的状态将会订阅者观察到。
观察者（订阅者）关注“被观察者”的对象
订阅建立关系，我们说“订阅者”订阅了“被观察者”

rxJava 可以用来改善用户操作体验，它很方便的切换代码运行的线程（UI线程或者工作线程），它与AsyncTask的功能类似，使得我们可以在工作线程共执行耗时的逻辑，完成后再UI线程处理视图状态的编号。
rxjava 能带来代码可读性，让代码清晰。

引用类库

compile 'io.reactivex:rxjava:1.0.14'
compile 'io.reactivex:rxandroid:1.0.1'

简单示例

Rxjava的代码很优雅，链式的写法，很清晰的表达了代码的行为。

Observable.from () 创建了一个被观察的对象。
　　.map() 方法执行了转换，将对象转成字符串
　　.subscribeOn() 指示了在哪个线程里执行上面的转换操作。
　　.observeOn() 指示了在哪个线程里执行对结果的响应操作，比如后面的 alert 方法。
　　.subscribe() 传递了具体的响应处理，即执行了 alert方法。

示例：

Observable.from(userBeans)
                .map(new Func1<UserBean, String>() {
                    @Override
                    public String call(UserBean userBean) {
                        //处理对象的转换
                        return String.format("%s(%s)", userBean.name, userBean.age);
                    }
                })
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Action1<String>() {
                    @Override
                    public void call(String str) {
                       
                        alert(str); //在UI视图显示
                    }
                });

从单个对象创建被观察对象的演示

使用 just() 方法，指定单个对象来创建被观察对象实例。

private void doSomeOne() {
    Observable.just("Hello, world!").subscribe(new Action1<String>() {
        @Override
        public void call(String str) {
            alert(str);
        }
    });
}

从一个集合创建被观察对象的演示

使用 from() 方法，指定一个集合来创建被观察对象实例。

private void doSomeArray() {
    Observable.from(new String[]{"A", "B", "C"}).subscribe(new Action1<String>() {
        @Override
        public void call(String str) {
            alert(str);
        }
    });
}

对象转换的演示

我们使用 map() 方法进行转换。下面的代码演示了从 UserBean数组创建被观察对象，然后使用map()方法转换成字符串。

private void doSomeEntity() {
    UserBean[] userBeans = new UserBean[3];
    userBeans[0] = new UserBean("jo", 18);
    userBeans[1] = new UserBean("ken", 9);
    userBeans[2] = new UserBean("hack", 30);

    //增加了map方法，转出 实体到字符串
    Observable.from(userBeans).map(new Func1<UserBean, String>() {
        @Override
        public String call(UserBean userBean) {
            return String.format("%s(%s)", userBean.name, userBean.age);
        }
    }).subscribe(new Action1<String>() {
        @Override
        public void call(String str) {
            alert(str);
        }
    });
}

调度器 Scheduler

Scheduler 用以指定运行在哪个线程下。比如：

 .subscribeOn(Schedulers.io())                  指示运行在io线程
 .observeOn(AndroidSchedulers.mainThread())     指示运行在主线程

subscribeOn 方法

它指定 subscribe() 发生在 IO 线程. 比如：subscribeOn(Schedulers.io())
一般来说，我们常用的处理图片，网络访问，会在这里用这个方法指定为 io 线程运行。

observeOn

它指定 Subscriber 的回调发生在主线程 .observeOn(AndroidSchedulers.mainThread())
一般来说，android下都会使用主线程以操作视图

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。
AndroidSchedulers.mainThread()
Android下特有的, 在 Android 主线程运行。

参考：

https://github.com/ReactiveX/RxJava
http://gank.io/post/560e15be2dca930e00da1083