Android RxJava实际应用案例讲解：使用RxJava的最佳开发场景

前言

Rxjava

Android

Rxjava

Retrofit

Rxjava 2.0

Android

Rxjava 2.0

目录

1. 简介

RxJava

2. 基本使用

Rxjava

3. 实际开发应用场景

RxJava

RxJava

Retrofit

RxBinding

RxBus

3.1 网络请求轮询（无条件）

3.2 网路请求轮询（有条件）

3.3 网络请求出错重连

3.4 网络请求嵌套回调

Retrofit

RxJava

// 发送注册网络请求的函数方法
private void register() {
api.register(new RegisterRequest())
.subscribeOn(Schedulers.io())               //在IO线程进行网络请求
.observeOn(AndroidSchedulers.mainThread())  //回到主线程去处理请求结果
.subscribe(new Consumer<RegisterResponse>() {
@Override
public void accept(RegisterResponse registerResponse) throws Exception {
Toast.makeText(MainActivity.this, "注册成功", Toast.LENGTH_SHORT).show();
login();   //注册成功, 调用登录的方法
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
Toast.makeText(MainActivity.this, "注册失败", Toast.LENGTH_SHORT).show();
}
});
}

// 发送登录网络请求的函数方法
private void login() {
api.login(new LoginRequest())
.subscribeOn(Schedulers.io())               //在IO线程进行网络请求
.observeOn(AndroidSchedulers.mainThread())  //回到主线程去处理请求结果
.subscribe(new Consumer<LoginResponse>() {
@Override
public void accept(LoginResponse loginResponse) throws Exception {
Toast.makeText(MainActivity.this, "登录成功", Toast.LENGTH_SHORT).show();
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
Toast.makeText(MainActivity.this, "登录失败", Toast.LENGTH_SHORT).show();
}
});
}

RxJava2

FlatMap（）

3.5 从磁盘 / 内存缓存中 获取缓存数据

3.6 合并数据源

3.7 联合判断

3.8 线程控制（切换 / 调度 ）

UI

3.9 功能防抖

3.10 联想搜索优化

3.11 控制被观察者发送事件 & 观察者接收事件速度：背压

Observable.create(new ObservableOnSubscribe<Integer>() {
// 1. 创建被观察者 & 生产事件
@Override
public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {

for (int i = 0; ; i++) {
Log.d(TAG, "发送了事件"+ i );
Thread.sleep(10);
// 发送事件速度：10ms / 个
emitter.onNext(i);

}

}
}).subscribeOn(Schedulers.io()) // 设置被观察者在io线程中进行
.observeOn(AndroidSchedulers.mainThread()) // 设置观察者在主线程中进行
.subscribe(new Observer<Integer>() {
// 2. 通过通过订阅（subscribe）连接观察者和被观察者

@Override
public void onSubscribe(Disposable d) {
Log.d(TAG, "开始采用subscribe连接");
}

@Override
public void onNext(Integer value) {

try {
// 接收事件速度：5s / 个
Thread.sleep(5000);
Log.d(TAG, "接收到了事件"+ value  );
} catch (InterruptedException e) {
e.printStackTrace();
}

}

@Override
public void onError(Throwable e) {
Log.d(TAG, "对Error事件作出响应");
}

@Override
public void onComplete() {
Log.d(TAG, "对Complete事件作出响应");
}

});

OOM

RxJava

4. 总结

RxJava2

Android

Rxjava 2.0

帮顶 / 评论点赞！因为你的鼓励是我写作的最大动力！