网上是有很多RxJava的博客..但是- -也许是我太笨吧 , 光看博客并学不会怎么用.于是就现在慕课网上看了视频 , 完事再学习大神的经验 , 这样一来才搞懂了部分RxJava的使用.接下来从自己的角度来谈一谈RxJava吧
首先 , 贴上慕课网视频还有大神的博客, 感谢大神们的经验了.
先添加依赖吧:
compile "io.reactivex:rxjava:1.0.0"
compile "io.reactivex:rxandroid:1.0.0"
前言:为什么要使用RxJava
a library for composing asynchronous and event-based programs using observable sequences for the Java VM
emmm, 这句话确实挺难理解的 , 简单来说 , 就是两个关键词: 异步.简洁，在使用RxJava的逻辑中，我们只需要链式调用，就可以清楚的知道每个步骤都做了什么，而不是去找if或者for对应的缩进，再去看复杂的逻辑。
在安卓中，我们实现异步可以使用Handler和AsyncTask，但多个异步任务嵌套，或者频繁的更改需求的时候，再次修改Handler和AsyncTask的代码，你确定你不会哭么？所以，我们是有必要学习一下RxJava的
1. 概念
- Observable:可观察的 , 被观察者 , 数据提供者
- Observer: 观察员, 观察者 , 数据的接收者
- Subscriber:订阅者 , 接收数据并使用. 一般情况下，建议使用Subscriber作为接收源；
RxJava的基本套路就是:订阅者接收被观察者获取的数据并使用 , 看下面的代码
首先写被观察者Observable
Observable<String> observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
//这里模拟接收数据
subscriber.onNext("hello world");
}
});
然后 , 写订阅者以及相应的数据使用subscribe
Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
//使用数据
Log.e("onNext: ",s);
}
};
最后 , 让订阅者观察被观察者
observable.subscribe(subscriber);
这样就完成了最基本的RxJava的一套流程 , 基本使用了解了之后 , 我们细看一下
2. 创建Observable
不是只有create一种方法可以创建被观察者:
- create 最基本的创建方式, 需手动调用onNext发射数据
Observable<String> observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
//这里模拟接收数据
subscriber.onNext("hello world1");
subscriber.onNext("hello world2");
subscriber.onNext("hello world3");
}
});
- just 方法 , 创建一个Observable并自动调用onNext方法
observable = Observable.just("hello world1",""hello world2");//依次发送两个数据
- from 遍历集合，发送每个item
List<String> list = new ArrayList<>();
list.add("1");
list.add("2");
list.add("3");
observable = Observable.from(list);
//遍历list 每次发送一个 /** 注意，just()方法也可以传list，但是发送的是整个list对象，而from（）发送的是list的一个item** /
- interval 按固定时间间隔发射整数序列的Observable, 可用于动态更新App的时间
observable = Observable.interval(1, TimeUnit.SECONDS);//每隔一秒发送一次 - timer 给定的延迟后发射值
observable = Observable.timer(3, TimeUnit.SECONDS); //3秒后发射一个值 - repeat 重复请求ing发送特定数据
observable = Observable.just("repeatObservable").repeat(3);//重复发射3次
3. Subscribe的创建
Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onCompleted() {
//
}
@Override
public void onError(Throwable e) {
//异常捕获
}
@Override
public void onNext(String s) {
//使用数据
Log.e("onNext: ", s);
}
};
4. 关联订阅者与被观察者
observable.subscribe(subscriber);
总结
基本使用就是这些了 , 以后再来谈谈强大的操作符
