【Android】RxJava的使用(一)基本用法
2016-08-02 17:59
477 查看
转自:http://www.jianshu.com/p/19cac3c5b106
(第一篇只介绍了RxJava的基本用法,暂时还无法看出RxJava的优势。切莫着急,随着慢慢深入就能体会到RxJava带来的方便了)
参考:给 Android 开发者的 RxJava 详解
(本文部分内容引用自该博客)
a library for composing asynchronous and event-based programs using observable sequences for the Java VM
翻译过来就是:
一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库
对于新手们来说这个太抽象了,我们(我也是新手)需要看到看到一个更加具体的解释,简单来说,它就是一个实现异步操作的库。(还是不懂?看代码更实在)
观察者:监视着被观察者的行为,当被观察者某个状态改变的时候会通知观察者,观察者会执行对应的操作;
被观察者:被监视的对象,当某个状态改变的时候会通知观察者;
订阅(或注册):将观察者和被观察者建立联系。
(很乱?来个栗子?)
这里举一个我个常用的例子,点击Button后触发OnClickListener
中的onClick()事件。在这个事件中他们的角色分别如下:
观察者:OnClickListener;
被观察者:Button;
订阅(或注册):setOnClickListener()。
观察者:Observer;
被观察者:Observable;
订阅(或注册):subscribe()。
观察者
Observer 即观察者,它决定事件触发的时候将有怎样的行为。
RxJava 观察者的事件回调方法除了普通事件onNext()(相当于onClick()/onEvent())之外,还定义了两个特殊的事件:onCompleted()和onError()。
onCompleted(): 事件队列完结。RxJava 不仅把每个事件单独处理,还会把它们看做一个队列。RxJava 规定,当不会再有新的onNext()发出时,需要触发onCompleted()方法作为标志。
onError(): 事件队列异常。在事件处理过程中出异常时,onError()
会被触发,同时队列自动终止,不允许再有事件发出。
在一个正确运行的事件序列中,onCompleted()和onError()有且只有一个,并且是事件序列中的最后一个。需要注意的是,onCompleted()
和onError()二者也是互斥的,即在队列中调用了其中一个,就不应该再调用另一个。
被观察者
Observable 即被观察者,它决定什么时候触发事件以及触发怎样的事件。可以使用create()、just(T...)、from(T[])或from(Iterable<? extends T>)来创建一个 Observable ,并为它定义事件触发规则。
订阅
创建了Observable和Observer之后,再用subscribe()方法将它们联结起来
直接看代码吧,这里只展示了RxJava的基本用法,暂时看不出RxJava的优势。
添加依赖
以上用到的都是rx包里面的,别用错了!!!
Observer
上面完成了一次Rxjava的基本使用。
除了Observer接口之外,RxJava 还内置了一个实现了Observer的抽象:Subscriber。Subscriber对Observer接口进行了一些扩展,但他们的基本使用方式是完全一样的:
不仅基本使用方式一样,实质上,在 RxJava 的 subscribe 过程中,Observer也总是会先被转换成一个Subscriber再使用。如图:
Rxjava源码
所以如果你只想使用基本功能,选择Observer和Subscriber是完全一样的。它们的区别对于使用者来说主要有两点:
onStart(): 这是Subscriber增加的方法。它会在 subscribe 刚开始,而事件还未发送之前被调用,可以用于做一些准备工作,例如数据的清零或重置。这是一个可选方法,默认情况下它的实现为空。需要注意的是,如果对准备工作的线程有要求(例如弹出一个显示进度的对话框,这必须在主线程执行),onStart()就不适用了,因为它总是在 subscribe 所发生的线程被调用,而不能指定线程。要在指定的线程来做准备工作,可以使用doOnSubscribe()方法,具体可以在后面的文中看到。
unsubscribe(): 这是Subscriber所实现的另一个接口Subscription
的方法,用于取消订阅。在这个方法被调用后,Subscriber将不再接收事件。一般在这个方法调用前,可以使用isUnsubscribed()先判断一下状态。unsubscribe()这个方法很重要,因为在subscribe()之后,Observable会持有Subscriber的引用,这个引用如果不能及时被释放,将有内存泄露的风险。所以最好保持一个原则:要在不再使用的时候尽快在合适的地方(例如onPause()onStop()等方法中)调用unsubscribe()来解除引用关系,以避免内存泄露的发生。
Observable
Observable的其他几种创建方法,一下Observable等价于之前使用Create()创建的Observable:
1、使用Observable.just()创建被观察者
2、使用Observable.from()创建被观察者
或
(别急,因为是第一篇,我只介绍了他们之间的关系以及最基础的用法。后面的几篇我会介绍RxJava的其他功能,还有一些复杂的嵌套关系的处理,到时候知道RxJava的强大之处了)
最后一篇文章我会给出代码地址
前言
最近经常看到RxJava这个字眼,也看到很多人在博客中推荐使用RxJava。好奇的我怎么能错过,于是Google了一下,说RxJava好用的和说RxJava难用的都有,于是自己也亲自尝试了一下(感觉不容易上手)。写博客记录下学习的过程,一方面作为巩固,另一方面希望能帮助到初学者。(第一篇只介绍了RxJava的基本用法,暂时还无法看出RxJava的优势。切莫着急,随着慢慢深入就能体会到RxJava带来的方便了)
参考:给 Android 开发者的 RxJava 详解
(本文部分内容引用自该博客)
介绍
在GitHub主页上的介绍:a library for composing asynchronous and event-based programs using observable sequences for the Java VM
翻译过来就是:
一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库
对于新手们来说这个太抽象了,我们(我也是新手)需要看到看到一个更加具体的解释,简单来说,它就是一个实现异步操作的库。(还是不懂?看代码更实在)
优点
RxJava的好处就在于它的简洁性,逻辑简单的时候看不出RxJava的优势,想必大家都知道在调度过程比较复杂的情况下,异步代码经常会既难写也难被读懂。这时候RxJava的优势就来了,随着程序逻辑变得越来越复杂,它依然能够保持简洁。观察者模式
首先要先介绍一下观察者模式(可能比喻的不够恰当,意思到了就好);观察者:监视着被观察者的行为,当被观察者某个状态改变的时候会通知观察者,观察者会执行对应的操作;
被观察者:被监视的对象,当某个状态改变的时候会通知观察者;
订阅(或注册):将观察者和被观察者建立联系。
(很乱?来个栗子?)
这里举一个我个常用的例子,点击Button后触发OnClickListener
中的onClick()事件。在这个事件中他们的角色分别如下:
观察者:OnClickListener;
被观察者:Button;
订阅(或注册):setOnClickListener()。
RxJava
在上面介绍了观察者模式,这里也将RxJava中的三个角色进行一下角色分配观察者:Observer;
被观察者:Observable;
订阅(或注册):subscribe()。
观察者
Observer 即观察者,它决定事件触发的时候将有怎样的行为。
RxJava 观察者的事件回调方法除了普通事件onNext()(相当于onClick()/onEvent())之外,还定义了两个特殊的事件:onCompleted()和onError()。
onCompleted(): 事件队列完结。RxJava 不仅把每个事件单独处理,还会把它们看做一个队列。RxJava 规定,当不会再有新的onNext()发出时,需要触发onCompleted()方法作为标志。
onError(): 事件队列异常。在事件处理过程中出异常时,onError()
会被触发,同时队列自动终止,不允许再有事件发出。
在一个正确运行的事件序列中,onCompleted()和onError()有且只有一个,并且是事件序列中的最后一个。需要注意的是,onCompleted()
和onError()二者也是互斥的,即在队列中调用了其中一个,就不应该再调用另一个。
被观察者
Observable 即被观察者,它决定什么时候触发事件以及触发怎样的事件。可以使用create()、just(T...)、from(T[])或from(Iterable<? extends T>)来创建一个 Observable ,并为它定义事件触发规则。
订阅
创建了Observable和Observer之后,再用subscribe()方法将它们联结起来
直接看代码吧,这里只展示了RxJava的基本用法,暂时看不出RxJava的优势。
使用
例:打印机个字符串添加依赖
compile 'io.reactivex:rxjava:1.0.14' compile 'io.reactivex:rxandroid:1.0.1'
//创建一个观察者 Observer<String> observer = new Observer<String>() { @Override public void onCompleted() { Log.i(TAG, "Completed"); } @Override public void onError(Throwable e) { Log.i(TAG, "Error"); } @Override public void onNext(String s) { Log.i(TAG, s); } }; //使用Observable.create()创建被观察者 Observable observable1 = Observable.create(new Observable.OnSubscribe<String>() { @Override public void call(Subscriber<? super String> subscriber) { subscriber.onNext("Hello"); subscriber.onNext("Wrold"); subscriber.onCompleted(); } }); //订阅 observable1.subscribe(observer);
以上用到的都是rx包里面的,别用错了!!!
Observer
上面完成了一次Rxjava的基本使用。
扩展
Subscriber除了Observer接口之外,RxJava 还内置了一个实现了Observer的抽象:Subscriber。Subscriber对Observer接口进行了一些扩展,但他们的基本使用方式是完全一样的:
Subscriber<String> subscriber = new Subscriber<String>() { @Override public void onNext(String s) { Log.d(tag, "Item: " + s); } @Override public void onCompleted() { Log.d(tag, "Completed!"); } @Override public void onError(Throwable e) { Log.d(tag, "Error!"); } };
不仅基本使用方式一样,实质上,在 RxJava 的 subscribe 过程中,Observer也总是会先被转换成一个Subscriber再使用。如图:
Rxjava源码
所以如果你只想使用基本功能,选择Observer和Subscriber是完全一样的。它们的区别对于使用者来说主要有两点:
onStart(): 这是Subscriber增加的方法。它会在 subscribe 刚开始,而事件还未发送之前被调用,可以用于做一些准备工作,例如数据的清零或重置。这是一个可选方法,默认情况下它的实现为空。需要注意的是,如果对准备工作的线程有要求(例如弹出一个显示进度的对话框,这必须在主线程执行),onStart()就不适用了,因为它总是在 subscribe 所发生的线程被调用,而不能指定线程。要在指定的线程来做准备工作,可以使用doOnSubscribe()方法,具体可以在后面的文中看到。
unsubscribe(): 这是Subscriber所实现的另一个接口Subscription
的方法,用于取消订阅。在这个方法被调用后,Subscriber将不再接收事件。一般在这个方法调用前,可以使用isUnsubscribed()先判断一下状态。unsubscribe()这个方法很重要,因为在subscribe()之后,Observable会持有Subscriber的引用,这个引用如果不能及时被释放,将有内存泄露的风险。所以最好保持一个原则:要在不再使用的时候尽快在合适的地方(例如onPause()onStop()等方法中)调用unsubscribe()来解除引用关系,以避免内存泄露的发生。
Observable
Observable的其他几种创建方法,一下Observable等价于之前使用Create()创建的Observable:
1、使用Observable.just()创建被观察者
Observable observable2 = Observable.just("Hello", "World");
2、使用Observable.from()创建被观察者
String [] words = {"Hello", "World"}; Observable observable3 = Observable.from(words);
或
List<String> list = new ArrayList<String>(); list.add("Hellow"); list.add("Wrold"); Observable observable4 = Observable.from(list);
小结
目前没看出RxJava的任何好处,感觉代码还多了~~~(别急,因为是第一篇,我只介绍了他们之间的关系以及最基础的用法。后面的几篇我会介绍RxJava的其他功能,还有一些复杂的嵌套关系的处理,到时候知道RxJava的强大之处了)
最后一篇文章我会给出代码地址
相关文章推荐
- 【Android】RxJava的使用(一)基本用法
- Android使用OrmLite数据库框架 之 基本用法
- Android Rxjava的from方法的基本用法
- Android RxJava的基本使用四
- android中handler的一些总结以及使用(一)之handler的基本用法
- android中Service的基本用法和IntentService的使用
- [Android]RxJava的简单介绍和基本使用(二):retrofit2的简单介绍
- android中RXJava的基本使用
- Android RxJava的基本使用一
- Android Retrofit+rxjava+okhttp请求网络的基本用法
- RxJava RxAndroid 入门使用用法 参照博文自己领悟使用解析
- RxJava(RxAndroid)基本使用入门
- Android ListView 最基本的用法,使用SimpleCursorAdapter 。 附例子。
- Android Rxjava的create的基本用法
- [Android开发] RxJava2之路二 - 基本使用方法
- android动画的使用(上-基本用法)
- Android RxJava,RxAndroid,rxlifecycle2基本使用
- RxJava(RxAndroid)基本使用入门
- Android RxJava的基本使用三
- RxJava(RxAndroid)基本使用入门