RxJava 和 RxAndroid 一 (基础)
1、RxJava 项目地址
https://github.com/ReactiveX/RxJava
2、RxAndroid 项目地址
https://github.com/ReactiveX/RxAndroid
3、RxJava 和 RxAndroid 的关系
RxAndroid是RxJava的一个针对Android平台的扩展,主要用于 Android 开发
4、RxJava和EventBus的区别?
https://www.zhihu.com/question/32179258/answer/54989242
5、RxAndroid的使用方法
compile 'io.reactivex:rxandroid:1.2.0'
6、如何查看RxAndroid最新版本?
http://search.maven.org/#search%7Cga%7C1%7Ca%3A%22rxandroid%22
7、RxAndroid具体使用方法
http://gank.io/post/560e15be2dca930e00da1083#toc_14
http://blog.csdn.net/theone10211024/article/details/50435325
http://huxian99.github.io/tags/RxJava/
https://github.com/mcxiaoke/RxDocs
8、创建观察者
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
package lib.com.myapplication;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import rx.Observer;
import rx.Subscriber;
public class Main2Activity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super .onCreate(savedInstanceState);
setContentView(R.layout.activity_main2);
//创建观察者 2 种方法
Observer<String> observer = new Observer<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
}
} ;
// Subscriber 继承 Observer ,对Observer类做了扩展
Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
}
} ;
}
}
|
- 从上文可以看到,Subscriber继承Observer, 只是 Subscriber对Observer做了一些扩展。Subscriber的使用和Observer完全一样。
- Subscriber 多了一个 onStart 方法
onStart()
: 这是Subscriber
增加的方法。它会在 subscribe 刚开始,而事件还未发送之前被调用,可以用于做一些准备工作,例如数据的清零或重置。这是一个可选方法,默认情况下它的实现为空。需要注意的是,如果对准备工作的线程有要求(例如弹出一个显示进度的对话框,这必须在主线程执行),onStart()
就不适用了,因为它总是在 subscribe 所发生的线程被调用,而不能指定线程。要在指定的线程来做准备工作,可以使用doOnSubscribe()
方法,具体可以在后面的文中看到。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
// Subscriber 继承 Observer ,对Observer类做了扩展
Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
}
@Override
public void onStart() {
super .onStart();
}
} ;
|
9、创建被观察者
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
//create方式
Observable<String> observable = Observable.create( new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext( "aa" ) ;
subscriber.onNext( "bb" ) ;
subscriber.onNext( "cc" ) ;
subscriber.onCompleted();
}
});
//just方式 最多支持10个数据
Observable<String> observable1 = Observable.just( "aa" , "bb" , "cc" ) ;
// 将会依次调用:
// onNext("aa");
// onNext("bb");
// onNext("cc");
// onCompleted();
//from方式
//1:集合
List<String> list = new ArrayList<>() ;
list.add( "aa" ) ;
list.add( "bb" ) ;
list.add( "cc" ) ;
Observable<String> observable2 = Observable.from( list ) ;
//2:数组
String[] words = { "aa" , "bb" , "cc" };
Observable<String> observable3 = Observable.from( words ) ;
|
- Call()方法:当
Observable
被订阅的时候,OnSubscribe
的call()
方法会自动被调用,事件序列就会依照设定依次触发(对于上面的代码,就是观察者Subscriber
将会被调用三次onNext()
和一次onCompleted()
)。这样,由被观察者调用了观察者的回调方法,就实现了由被观察者向观察者的事件传递,即观察者模式。
10、订阅
由于观察者可以由两种方式被创建,所以订阅的方式也有两种
1
2
|
observable.subscribe( observer ) ;
observable.subscribe( subscriber ) ;
|
Observable.subscribe(Subscriber)
的内部实现是这样的(仅核心代码):1234567// 注意:这不是 subscribe() 的源码,而是将源码中与性能、兼容性、扩展性有关的代码剔除后的核心代码。
// 如果需要看源码,可以去 RxJava 的 GitHub 仓库下载。
public
Subscription subscribe(Subscriber subscriber) {
subscriber.onStart();
onSubscribe.call(subscriber);
return
subscriber;
}
- 在subscribe() 中,首先会调用 onStart() 方法,这个方法前文已经介绍了,是可选的。接着会调用 call()方法,我们已经分析了在call()方法中会调用多次 onNext() ,最后调用 onCompleted().看到这里你就会突然明白原来subscribe() 方法其实相当于依次执行了:onStart() --> onNext()--> onCompleted()
- 从这也可以看出,在 RxJava 中,
Observable
并不是在创建的时候就立即开始发送事件,而是在它被订阅的时候,即当subscribe()
方法执行的时候。 Observer
和Subscriber
具有相同的角色,而且Observer
在subscribe()
过程中最终会被转换成Subscriber
对象- 将传入的
Subscriber
作为Subscription
返回。这是为了方便unsubscribe()
.
11、RxBus
你是否听说过EventBus , 他是android 中的事件总线。用rxjava同样可以实现android的事件总线功能,也就是RxBus.
关于rxbus 的基本说明在这里 http://nerds.weddingpartyapp.com/tech/2014/12/24/implementing-an-event-bus-with-rxjava-rxbus/
然而这并没有什么卵用 !
下面是RxBus的封装版
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
package lib.com.myapplication;
import android.support.annotation.NonNull;
import android.util.Log;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.ConcurrentHashMap;
import rx.Observable;
import rx.subjects.PublishSubject;
import rx.subjects.Subject;
/**
* Created by ${zyj} on 2016/5/6.
*/
public class RxBus {
private static final String TAG = RxBus. class .getSimpleName();
private static RxBus instance;
public static boolean DEBUG = false ;
public static RxBus get() {
if (instance == null ) {
synchronized (RxBus. class ) {
if (instance == null ) {
instance = new RxBus();
}
}
}
return instance;
}
private RxBus() {
}
private ConcurrentHashMap<Object, List<Subject>> subjectMapper = new ConcurrentHashMap<>();
@SuppressWarnings ( "unchecked" )
public <T> Observable<T> register( @NonNull Object tag, @NonNull Class<T> clazz) {
List<Subject> subjectList = subjectMapper.get(tag);
if ( null == subjectList) {
subjectList = new ArrayList<>();
subjectMapper.put(tag, subjectList);
}
Subject<T, T> subject;
subjectList.add(subject = PublishSubject.create());
if (DEBUG) Log.d(TAG, "[register]subjectMapper: " + subjectMapper);
return subject;
}
public void unregister( @NonNull Object tag, @NonNull Observable observable) {
List<Subject> subjects = subjectMapper.get(tag);
if ( null != subjects) {
if ( observable != null && subjects.contains( observable )){
subjects.remove((Subject) observable);
}
if (isEmpty(subjects)) {
subjectMapper.remove(tag);
}
}
if (DEBUG) Log.d(TAG, "[unregister]subjectMapper: " + subjectMapper);
}
public void post( @NonNull Object content) {
post( content.getClass().getName(), content);
}
@SuppressWarnings ( "unchecked" )
public void post( @NonNull Object tag, @NonNull Object content) {
List<Subject> subjectList = subjectMapper.get(tag);
if (!isEmpty(subjectList)) {
for (Subject subject : subjectList) {
subject.onNext(content);
}
}
if (DEBUG) Log.d(TAG, "[send]subjectMapper: " + subjectMapper);
}
private boolean isEmpty(Collection collection) {
return null == collection || collection.isEmpty();
}
}
|
RxBus的使用
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
package lib.com.myapplication;
import android.os.Bundle;
import android.support.v7.app.AppCompatActivity;
import rx.Observable;
import rx.functions.Action1;
public class Activity1 extends AppCompatActivity {
String tag = "tag" ;
Observable<String> ob ;
@Override
protected void onCreate(Bundle savedInstanceState) {
super .onCreate(savedInstanceState);
setContentView(R.layout.activity1);
//创建被观察者
ob = RxBus.get().register( tag , String. class ) ;
//订阅观察事件
ob.subscribe( new Action1<String>() {
@Override
public void call(String s) {
System.out.println( "fff-- " + s );
}
}) ;
//发送内容
RxBus.get().post( tag , "我是内容" );
}
@Override
protected void onDestroy() {
super .onDestroy();
//取消订阅
RxBus.get().unregister( tag , ob );
}
}
|
- 在Activity销毁的时候,要取消订阅服务 。 否则 post() 次数会随着post()调用逐渐增加
- 除了上面的简单使用外,还可以使用 Schedulers 、AndroidSchedulers 进行线程切换
RxJava 和 RxAndroid 二(操作符的使用)
转载于:https://www.cnblogs.com/ldq2016/p/6594464.html
RxJava 和 RxAndroid 一 (基础)相关推荐
- RxJava 和 RxAndroid 五(线程调度)
对rxJava不了解的同学可以先看 RxJava 和 RxAndroid 一 (基础) RxJava 和 RxAndroid 二(操作符的使用) RxJava 和 RxAndroid 三(生命周期控制 ...
- RxJava 和 RxAndroid 二(操作符的使用)
前言:对Rx不了解的朋友可以先看我的第一篇博文 RxJava 和 RxAndroid 一 (基础),是对Rxjava的基本介绍 1.merge操作符,合并观察对象 19 List<String ...
- RxJava 和 RxAndroid 四(RxBinding的使用)
对Rxjava不熟悉的同学可以先看我之前写的几篇文章 RxJava 和 RxAndroid 一 (基础) RxJava 和 RxAndroid 二(操作符的使用) RxJava 和 RxAndroid ...
- android RxJava(RxAndroid)的简单使用
今天,简单讲讲android里如何使用RxJava(RxAndroid). Android框架系列: 一.android EventBus的简单使用 二.android Glide简单使用 三.and ...
- RxJava和RxAndroid
现在RxJava和RxAndroid越来越火爆,自己在业余时间也学习了一下,感觉确实很好用,之前 为了完成页面刷新,数据请求,组件信息传递的时候,要使用handler,真的是逻辑思路很强,稍微不注意, ...
- 重拾Android之路(五)RxJava和RxAndroid
现在RxJava和RxAndroid越来越火爆,自己在业余时间也学习了一下,感觉确实很好用,之前 为了完成页面刷新,数据请求,组件信息传递的时候,要使用handler,真的是逻辑思路很强,稍微不注意, ...
- RxJava 和 RxAndroid 三(生命周期控制和内存优化)
前言:对Rxjava.Rxandroid不了解的同学可以先看看 RxJava 和 RxAndroid RxJava 和 RxAndroid 二(操作符的使用) RxJava使我们很方便的使用链式编程, ...
- 这样,你才能算会 RxJava、RxAndroid 之取消订阅
一:概述 前几天app 总是空指针奔溃,发现为某个 Fragment 中的控件为null 导致的.而且这个Fragment 是能够正常显示的.那么为什么还会空指针呢? 二:问题排查 这个app使用了 ...
- RxJava和RxAndroid学习记录
目录 1 概念和说明 1.1 响应式编程 1.2 RxJava 1.3 关于RxJava和RxAndroid 1.4 关于响应式编程和普通编程 2. 基本使用 2.1 基本元素关系图 2.2 代码示例 ...
最新文章
- 解决webApiMessageAn error has occurred./Message不能写多个Get方法的问题
- 201621123053《Java程序设计》第十三周学习笔记文章
- opengl从入门到精通
- Java15-day06【Set、HashSet、LinkedHashSet、TreeSet、Comparable、Comparator、泛型类、可变参数的使用】
- 【Tools】Navicat Premium12安装教程
- 【pygame】pygame的init()
- 2018 计蒜之道 复赛
- 关于交换机和路由器的区别介绍
- python连接数据库mysql错误1045_django 连接数据库出现1045错误的解决方式
- unet作为服务器不显示画面,UNet:无法生成服务器对象(不使用NetworkManager)
- python __xxxitem__
- 动态规划问题以及诸多实例分析
- python中凯撒密码_python实现凯撒密码、凯撒加解密算法
- 181028每日一句
- python水仙花数的代码_使用python求水仙花数的代码
- 对话夏琳·查布利斯:Primer.AI机器学习工程师是怎样炼成的?
- 推荐这三款软件让你实现PDF转WORD格式
- 4.Java数组(一)
- android 模拟器介绍
- Excel长串数字显示异常,如2E+13