安卓开源库源码学习Android收藏集RXjava

Android RxJava实际应用教学：你该什么时候使用RxJ

2018-01-25  本文已影响3412人  Carson带你学安卓

前言

Github截图

如果还不了解RxJava，请看文章：Android：这是一篇 清晰 & 易懂的Rxjava 入门教程

  1. 本系列文章主要基于 Rxjava 2.0
  2. 接下来的时间，我将持续推出 Android中 Rxjava 2.0 的一系列文章，包括原理、操作符、应用场景、背压等等 ，有兴趣可以继续关注Carson_Ho的安卓开发笔记！！
示意图

目录

示意图

1. 简介

RxJava的简介如下

示意图

2. 基本使用

3. 实际开发应用场景

示意图

下面实例皆结合常用框架如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();
                    }
                });
    }

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

3.6 合并数据源

示意图

3.7 联合判断

如，填写表单时，需要表单里所有信息（姓名、年龄、职业等）都被填写后，才允许点击 "提交" 按钮

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

3.9 功能防抖

示意图

3.10 联想搜索优化

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

a. 背景

示意图
  1. 发送 & 接收事件速度 = 单位时间内 发送&接收事件的数量
  2. 大多数情况，主要是 被观察者发送事件速度 ＞ 观察者接收事件速度

b. 冲突

  1. 如，点击按钮事件：连续过快的点击按钮10次，则只会造成点击2次的效果；
  2. 解释：因为点击速度太快了，所以按钮来不及响应

下面再举个例子：

即出现发送 & 接收事件严重不匹配的问题

 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事件作出响应");
            }

        });

c. 解决方案
采用 背压策略

至此，关于RxJava常见的实际开发应用场景讲解完毕。

4. 总结

示意图 示意图

请点赞！因为你的鼓励是我写作的最大动力！

相关文章阅读

欢迎关注Carson_Ho的简书！

不定期分享关于安卓开发的干货，追求短、平、快，但却不缺深度。

上一篇下一篇

猜你喜欢

热点阅读