1.认识 rxjava
RxJava是 ReactiveX 在JVM上的一个实现，ReactiveX使用Observable序列组合异步和基于事件的程序。Observable（观察者） 和 Subscriber（订阅者）是两个主要的类。在 RxJava 上，一个 Observable 是一个发出数据流或者事件的类，Subscriber 是一个对这些发出的 items （数据流或者事件）进行处理（采取行动）的类。一个 Observable 的标准流发出一个或多个 item，然后成功完成或者出错。一个 Observable 可以有多个 Subscribers，并且通过 Observable 发出的每一个 item，该 item 将会被发送到 Subscriber.onNext() 方法来进行处理。一旦 Observable 不再发出 items，它将会调用 Subscriber.onCompleted() 方法，或如果有一个出错的话 Observable 会调用 Subscriber.onError() 方法。
2.rxjava在android项目的引用
2.1：添加引用
compile 'io.reactivex:rxjava:1.1.6'
compile 'io.reactivex:rxandroid:1.2.1'
2.2. compile 'io.reactivex:rxandroid:1.2.1 ' 在androidn项目中切换到主线程的时候需要用到这个外部库，如果不需要切换可以不用引入
图片.png
3.rxjava用法简介
3.1 rxjava基本实现案例---create操作符----指定观察者为Observer对象
//创建一个Observable对象，同时也是可观察对象
Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
//onNext可以调用多次
try {
subscriber.onNext("Hellow Rxjava");
subscriber.onNext("Hellow Rxjava");
//时间序列结束标记
subscriber.onCompleted();
}catch (Exception e){
subscriber.onError(e);
}
}
}).subscribe(new Observer<String>() {//被观察者必须指定观察者，整个事件才可以
@Override
public void onCompleted() {
Log.i(TAG,"onCompleted:");
}
@Override
public void onError(Throwable e) {
Log.i(TAG,"onError:"+e);
}
@Override
public void onNext(String s) {
Log.i(TAG,"onNext:"+s);
}
});
打印结果如下：
图片.png
3.2 rxjava基本实现案例---create操作符----指定观察者为Subscriber对象
Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
//onNext可以调用多次
try {
subscriber.onNext("Hellow Rxjava");
subscriber.onNext("Hellow Rxjava");
subscriber.onNext("Hellow Rxjava");
subscriber.onNext("Hellow Rxjava");
//时间序列结束标记
subscriber.onCompleted();
}catch (Exception e){
subscriber.onError(e);
}
}
}).subscribe(new Subscriber<String>() {//被观察者必须指定观察者，整个事件才可以
@Override
public void onCompleted() {
Log.i(TAG,"onCompleted:");
}
@Override
public void onError(Throwable e) {
Log.i(TAG,"onError:"+e);
}
@Override
public void onNext(String s) {
Log.i(TAG,"onNext:"+s);
}
});
打印结果如下：
图片.png
3.3 rxjava基本实现案例---just操作符
Observable.just(1,2,3,4,5).subscribe(new Subscriber<Integer>() {
@Override
public void onCompleted() {
Log.i(TAG,"onCompleted:");
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Integer integer) {
Log.i(TAG,"onNext:"+integer);
}
});
打印结果如下：
图片.png
3.4 rxjava基本实现案例---form操作符
subscriber=new Subscriber<String>() {
@Override
public void onCompleted() {
Log.i(TAG,"onCompleted:");
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
Log.i(TAG,"onNext:"+s);
}
};
Observable.from(new String[]{"url1","url2"}).subscribe(subscriber);
//解除绑定，防止内存泄露
@Override
protected void onStop() {
super.onStop();
//解除订阅
if(subscriber!=null&&!subscriber.isUnsubscribed()){
subscriber.unsubscribe();
}
}
打印结果如下：
图片.png
3.5 rxjava基本实现案例---Action接口
注意：Action接口可以选择性的实现
//一个Action实现，call()方法相当于Subscriber中onNext()方法
Observable.from(new String[]{"AAA","BBB","CCC"}).subscribe(new Action1<String>() {
@Override
public void call(String s) {
Log.i(TAG, "onNext:" + s);
}
});
打印结果如下：
图片.png
二个Action实现，第一call()方法相当于Subscriber中onNext()方法，第二call方法相当于Subscriber中的onError()
Observable.from(new String[]{"AAA","BBB","CCC"}).subscribe(new Action1<String>() {
@Override
public void call(String s) {
Log.i(TAG, "onNext:" + s);
}
}, new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
Log.i(TAG, "onError:" + throwable);
}
});
打印结果如下：
图片.png
三个Action实现，第一call()方法相当于Subscriber中onNext()方法，第二call方法相当于Subscriber中的onError(),第3个call方法，相当于Subscriber中的onCompleted()方法
Observable.from(new String[]{"AAA","BBB","CCC"}).subscribe(new Action1<String>() {
@Override
public void call(String s) {
Log.i(TAG, "onNext:" + s);
}
}, new Action1<Throwable>() {
@Override
public void call(Throwable throwable) {
Log.i(TAG, "onError:" + throwable);
}
}, new Action0() {
@Override
public void call() {
Log.i(TAG, "onCompleted:");
}
});
图片.png
3.6 rxjava基本实现案例---map操作转换
将int类型的666---->String类型----->long类型------输出
Observable.just(666).map(new Func1<Integer, String>() {
@Override
public String call(Integer integer) {//Integer---->String
return integer+"";
}
}).map(new Func1<String, Long>() {
@Override
public Long call(String s) {
return Long.parseLong(s);
}
}).subscribe(new Action1<Long>() {
@Override
public void call(Long aLong) {
Log.i(TAG,"call:"+aLong);
}
});
3.7rxjava基本实现案例---线程调度
Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
Log.i(TAG,"call:"+Thread.currentThread().getName());
subscriber.onNext("AAAAAAA");
subscriber.onNext("itcast");
subscriber.onCompleted();
}
}).subscribeOn(Schedulers.io())//让subscribe的操作执行在异步线程
.observeOn(AndroidSchedulers.mainThread()).//让订阅者代码运行在主线程
subscribe(new Subscriber<String>() {
@Override
public void onCompleted() {
Log.i(TAG,"onCompleted");
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
Log.i(TAG,"onNext:"+Thread.currentThread().getName());
Log.i(TAG,"onNext:"+s);
}
});
打印结果如下：
图片.png
如果使用map来实现的代码是这样的：
Action1<List<Course>> action1 = new Action1<List<Course>>() {
@Override
public void call(List<Course> courses) {
//遍历courses，输出cuouses的name
for (int i = 0; i < courses.size(); i++){
Log.i(TAG, courses.get(i).getName());
}
}
};
Observable.from(students)
.map(new Func1<Student, List<Course>>() {
@Override
public List<Course> call(Student student) {
//返回coursesList
return student.getCoursesList();
}
})
.subscribe(action1);
//来这里在订阅之前如果继续用map处理则只能得到每个学生的一门所修的课程，只能循环遍历
flatMap实现的代码是这样的：
Observable.from(students)
.flatMap(new Func1<Student, Observable<Course>>() {
@Override
public Observable<Course> call(Student student) {
return Observable.from(student.getCoursesList());
}
})
.subscribe(new Action1<Course>() {
@Override
public void call(Course course) {
Log.i(TAG, course.getName());
}
});
//首先一旦订阅，通过flatmap根据from将所有传递过来的student包装到另一个observable中，然后一一发送事件（student）执行return Observable.from(student.getCoursesList());
//一旦事件发送完毕调用call，一一执行
好了，Rxjava学习笔记就先记录到这里了，end
