android RXJava2.0(一)
原链接
作者:Season_zlc
链接:http://www.jianshu.com/p/464fa025229e
來源:简书
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。
看了之后只是学习记录而已
要在Android中使用RxJava2, 先添加Gradle配置:
compile 'io.reactivex.rxjava2:rxjava:2.0.1'compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
正题
在开始学习之前,先来介绍点原理性的东西。
网上也有很多介绍RxJava原理的文章,通常这些文章都从观察者模式开始,先讲观察者,被观察者,订阅关系巴拉巴拉一大堆,说实话,当我第一次看到这些文章的时候已经被这些名词给绕晕了,用了很长的时间才理清楚它们之间的关系。可能是我太蠢了,境界不够,领会不到那么多高大上的名词.
今天我用两根水管代替观察者和被观察者, 试图用通俗易懂的话把它们的关系解释清楚, 在这里我将从事件流这个角度来说明RxJava的基本工作原理。
先假设有两根水管:
上面一根水管为事件产生的水管,叫它上游
吧,下面一根水管为事件接收的水管叫它下游
吧。
两根水管通过一定的方式连接起来,使得上游每产生一个事件,下游就能收到该事件。注意这里和官网的事件图是反过来的, 这里的事件发送的顺序是先1,后2,后3这样的顺序, 事件接收的顺序也是先1,后2,后3的顺序, 我觉得这样更符合我们普通人的思维, 简单明了.
这里的上游和下游就分别对应着 RxJava
中的 Observable
和 Observer
,它们之间的连接就对应着 subscribe()
,因此这个关系用 RxJava
来表示就是:
//创建一个上游 Observable: Observable observable = Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter emitter) throws Exception { emitter.onNext(1); emitter.onNext(2); emitter.onNext(3); emitter.onComplete(); } }); //创建一个下游 Observer Observer observer = new Observer() { @Override public void onSubscribe(Disposable d) { Log.d(TAG, "subscribe"); } @Override public void onNext(Integer value) { Log.d(TAG, "" + value); } @Override public void onError(Throwable e) { Log.d(TAG, "error"); } @Override public void onComplete() { Log.d(TAG, "complete"); } }; //建立连接 observable.subscribe(observer);
结果:
08-12 10:08:43.142 19034-19034/com.abilix.learn.permissiondemo D/RxActivity: onSubscribe08-12 10:08:43.142 19034-19034/com.abilix.learn.permissiondemo D/RxActivity: 108-12 10:08:43.142 19034-19034/com.abilix.learn.permissiondemo D/RxActivity: 208-12 10:08:43.142 19034-19034/com.abilix.learn.permissiondemo D/RxActivity: 308-12 10:08:43.142 19034-19034/com.abilix.learn.permissiondemo D/RxActivity: onComplete
注意: 只有当上游和下游建立连接之后, 上游才会开始发送事件. 也就是调用了subscribe() 方法之后才开始发送事件.
把这段代码连起来写就成了RxJava引以为傲的链式操作:
接下来解释一下其中两个陌生的玩意: ObservableEmitter
和 Disposable
.
ObservableEmitter
: Emitter
是发射器的意思,那就很好猜了,这个就是用来发出事件的,它可以发出三种类型的事件,通过调用emitter
的onNext(T value)
、onComplete()
和onError(Throwable error)
就可以分别发出next
事件、complete
事件和error
事件。
但是,请注意,并不意味着你可以随意乱七八糟发射事件,需要满足一定的规则:
- 上游可以发送无限个
onNext
, 下游也可以接收无限个onNext
. - 当上游发送了一个
onComplete
后, 上游onComplete
之后的事件将会继续发送, 而下游收到onComplete事件之后将不再继续接收事件. - 当上游发送了一个
onError
后, 上游onError
之后的事件将继续发送, 而下游收到onError
事件之后将不再继续接收事件. - 上游可以不发送
onComplete
或onError
. - 最为关键的是
onComplete
和onError
必须唯一并且互斥, 即不能发多个onComplete
, 也不能发多个onError
, 也不能先发一个onComplete
, 然后再发一个onError
, 反之亦然
注: 关于onComplete和onError唯一并且互斥这一点, 是需要自行在代码中进行控制, 如果你的代码逻辑中违背了这个规则,* 并不一定会导致程序崩溃*. 比如发送多个onComplete是可以正常运行的, 依然是收到第一个onComplete就不再接收了, 但若是发送多个onError, 则收到第二个onError事件会导致程序会崩溃.
以上几个规则用示意图表示如下:
介绍了 ObservableEmitter
, 接下来介绍 Disposable
, 这个单词的字面意思是一次性用品,用完即可丢弃的. 那么在 RxJava
中怎么去理解它呢, 对应于上面的水管的例子, 我们可以把它理解成两根管道之间的一个机关, 当调用它的 dispose()
方法时, 它就会将两根管道切断, 从而导致下游收不到事件.
注意: 调用dispose()并不会导致上游不再继续发送事件, 上游会继续发送剩余的事件.
来看个例子, 我们让上游依次发送1,2,3,complete,4
,在下游收到第二个事件之后, 切断水管, 看看运行结果:
Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter emitter) throws Exception { Log.d(TAG, "emit 1"); emitter.onNext(1); Log.d(TAG, "emit 2"); emitter.onNext(2); Log.d(TAG, "emit 3"); emitter.onNext(3); Log.d(TAG, "emit complete"); emitter.onComplete(); Log.d(TAG, "emit 4"); emitter.onNext(4); } }).subscribe(new Observer() { private Disposable mDisposable; private int i; @Override public void onSubscribe(Disposable d) { Log.d(TAG, "subscribe"); mDisposable = d; } @Override public void onNext(Integer value) { Log.d(TAG, "onNext: " + value); i++; if (i == 2) { Log.d(TAG, "dispose"); mDisposable.dispose(); Log.d(TAG, "isDisposed : " + mDisposable.isDisposed()); } } @Override public void onError(Throwable e) { Log.d(TAG, "error"); } @Override public void onComplete() { Log.d(TAG, "complete"); } });
结果:
12-02 06:54:07.728 7404-7404/zlc.season.rxjava2demo D/TAG: subscribe12-02 06:54:07.728 7404-7404/zlc.season.rxjava2demo D/TAG: emit 112-02 06:54:07.728 7404-7404/zlc.season.rxjava2demo D/TAG: onNext: 112-02 06:54:07.728 7404-7404/zlc.season.rxjava2demo D/TAG: emit 212-02 06:54:07.728 7404-7404/zlc.season.rxjava2demo D/TAG: onNext: 212-02 06:54:07.728 7404-7404/zlc.season.rxjava2demo D/TAG: dispose12-02 06:54:07.728 7404-7404/zlc.season.rxjava2demo D/TAG: isDisposed : true12-02 06:54:07.728 7404-7404/zlc.season.rxjava2demo D/TAG: emit 312-02 06:54:07.728 7404-7404/zlc.season.rxjava2demo D/TAG: emit complete12-02 06:54:07.728 7404-7404/zlc.season.rxjava2demo D/TAG: emit 4
从运行结果我们看到, 在收到
onNext2
这个事件后, 切断了水管, 但是上游仍然发送了 3, complete, 4这几个事件, 而且上游并没有因为发送了 onComplete 而停止. 同时可以看到下游的onSubscribe() 方法是最先调用的.即:
- 调用dispose()方法上游还会接着走
- 上游不会因为发送了onComplete而停止
- 下游中onSubscribe()方法是最先调用的
Disposable
的用处不止这些, 后面讲解到了线程的调度之后, 我们会发现它的重要性. 随着后续深入的讲解, 我们会在更多的地方发现它的身影.
另外, subscribe()
有多个重载的方法:
public final Disposable subscribe() {} public final Disposable subscribe(Consumer<? super T> onNext) {} public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError) {} public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) {} public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) {} public final void subscribe(Observer<? super T> observer) {}
最后一个带有Observer参数的我们已经使用过了,这里对其他几个方法进行说明.
- 不带任何参数的
subscribe()
表示下游不关心任何事件,你上游尽管发你的数据去吧, 老子可不管你发什么. 带有一个
Consumer
参数的方法表示下游只关心onNext事件, 其他的事件我假装没看见, 因此我们如果只需要onNext
事件可以这么写:Observable.create(new ObservableOnSubscribe
() { @Override public void subscribe(ObservableEmitter emitter) throws Exception { Log.d(TAG, "emit 1"); emitter.onNext(1); Log.d(TAG, "emit 2"); emitter.onNext(2); Log.d(TAG, "emit 3"); emitter.onNext(3); Log.d(TAG, "emit complete"); emitter.onComplete(); Log.d(TAG, "emit 4"); emitter.onNext(4); } }).subscribe(new Consumer () { @Override public void accept(Integer integer) throws Exception { Log.d(TAG, "onNext: " + integer); } });
2017/8/12 11:18:58
自己总结
这个系列(一)今天学习了
- Observable
- Observer
- subscribe()
- 通常我们使用的是带(Observer)参数的subscribe(Observer)方法
- 不带任何参数的subscribe()方法代表上游随便发,下游收到算我输
- 带有一个Consumer的subscribe(Consumer)方法代表只接收onNext方法
- 剩下类推
- ObservableEmitter
- Disposable
- 调用dispose()方法上游还会接着走
- 上游不会因为发送了onComplete而停止
- 下游中onSubscribe()方法是最先调用的
- 发射规则:
- 上游可以发送无限个
onNext
, 下游也可以接收无限个onNext
. - 当上游发送了一个
onComplete
后, 上游onComplete
之后的事件将会继续发送, 而下游收到onComplete事件之后将不再继续接收事件. - 当上游发送了一个
onError
后, 上游onError
之后的事件将继续发送, 而下游收到onError
事件之后将不再继续接收事件. - 上游可以不发送
onComplete
或onError
. - 最为关键的是
onComplete
和onError
必须唯一并且互斥, 即不能发多个onComplete
, 也不能发多个onError
, 也不能先发一个onComplete
, 然后再发一个onError
, 反之亦然
- 上游可以发送无限个
更多相关文章
- Android热插拔事件处理流程--Vold
- Android自动化测试初探(四): 模拟键盘鼠标事件(Socket+Instrumentat
- Android事件分发和View绘制流程分析(三)
- android onTouch事件的派发
- Android ListView嵌套Button,Button事件覆盖item事件解决办法
- Android 事件中 OnTouch 事件
- android 为TextView的部分文字设置超链接样式并监听点击事件
- Android 你的OnTouchEvent() 触屏事件的优化了吗
- 如何在Android中在fragment中实现点击按钮事件?