【免费】RxJava2.0（初学者教程+实用操作符总结及原理简析）资源-CSDN文库

课程资源

RxJava2.0

需积分: 0 39 浏览量 2023-06-21 20:12:16 上传评论收藏 36KB DOCX 举报

资源推荐

资源详情

资源评论

给初学者的 RxJava2.0 教程

前言

上个月 RxJava2 正式版发布了，但目前国内的资料还比较少，以前使用过 RxJava1 只需要看

看更新文档就知道怎么使用了，但还有一些以前没用过 RxJava 的朋友可能就不知道怎么办

了，不知道该看 RxJava1 还是直接跳到 RxJava2。所以写下这个教程，帮助那些没有用过

RxJava 的朋友入门。

注：如果你觉得写得不好，请直接批评指出。

我先回答这个问题：学习 RxJava2 需要先学习 RxJava1 吗？

这个问题就像论坛经常问学 Java 前需要先学习 C 语言吗，这里就不引战了！（PHP 是世界

上最好的语言！！）

答案明显不是，如果你以前学过 RxJava1，那么对于 RxJava2 只需要看看更新了哪些东西就

行了，其最核心的思想并没有变化，如果你没学过 RxJava1，没有关系，直接学习 RxJava2。

所以作为一个 RxJava2 的教程，本文中所有的名词都属于 RxJava2 中，并不涉及 RxJava1。

要在 Android 中使用 RxJava2, 先添加 Gradle 配置:

compile 'io.reactivex.rxjava2:rxjava:2.0.1'

compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

正题

在开始学习之前，先来介绍点原理性的东西。

网上也有很多介绍 RxJava 原理的文章，通常这些文章都从观察者模式开始，先讲观察者，

被观察者，订阅关系巴拉巴拉一大堆，说实话，当我第一次看到这些文章的时候已经被这些

名词给绕晕了，用了很长的时间才理清楚它们之间的关系。可能是我太蠢了，境界不够，领

会不到那么多高大上的名词.

今天我用两根水管代替观察者和被观察者, 试图用通俗易懂的话把它们的关系解释清楚, 在

这里我将从事件流这个角度来说明 RxJava 的基本工作原理。

先假设有两根水管：

RxJava

上面一根水管为事件产生的水管，叫它上游吧，下面一根水管为事件接收的水管叫它下游吧。

两根水管通过一定的方式连接起来，使得上游每产生一个事件，下游就能收到该事件。注意

这里和官网的事件图是反过来的, 这里的事件发送的顺序是先 1,后 2,后 3 这样的顺序, 事件

接收的顺序也是先 1,后 2,后 3 的顺序, 我觉得这样更符合我们普通人的思维, 简单明了.

这里的上游和下游就分别对应着 RxJava 中的 Observable 和 Observer，它们之间的连接就对

应着 subscribe()，因此这个关系用 RxJava 来表示就是：

//创建一个上游 Observable：

Observable<Integer> observable = Observable.create(new

ObservableOnSubscribe<Integer>() {

@Override

public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {

emitter.onNext(1);

emitter.onNext(2);

emitter.onNext(3);

emitter.onComplete();

}

}).subscribe(new Observer<Integer>() {

@Override

public void onSubscribe(Disposable d) {

Log.d(TAG, "subscribe");

}

@Override

public void onNext(Integer value) {

Log.d(TAG, "" + value);

}

@Override

public void onError(Throwable e) {

Log.d(TAG, "error");

}

@Override

public void onComplete() {

Log.d(TAG, "complete");

}

});

接下来解释一下其中两个陌生的玩意：ObservableEmitter 和 Disposable.

ObservableEmitter： Emitter 是发射器的意思，那就很好猜了，这个就是用来发出事件的，

它可以发出三种类型的事件，通过调用 emitter 的 onNext(T value) 、 onComplete() 和

onError(Throwable error)就可以分别发出 next 事件、complete 事件和 error 事件。

但是，请注意，并不意味着你可以随意乱七八糟发射事件，需要满足一定的规则：

上游可以发送无限个 onNext, 下游也可以接收无限个 onNext.

当上游发送了一个 onComplete 后, 上游 onComplete 之后的事件将会继续发送, 而下游收到

onComplete 事件之后将不再继续接收事件.

当上游发送了一个 onError 后, 上游 onError 之后的事件将继续发送, 而下游收到 onError 事

件之后将不再继续接收事件.

上游可以不发送 onComplete 或 onError.

最为关键的是 onComplete 和 onError 必须唯一并且互斥, 即不能发多个 onComplete, 也不能

发多个 onError, 也不能先发一个 onComplete, 然后再发一个 onError, 反之亦然

注: 关于 onComplete 和 onError 唯一并且互斥这一点, 是需要自行在代码中进行控制, 如果

你的代码逻辑中违背了这个规则, 并不一定会导致程序崩溃. 比如发送多个 onComplete 是

可以正常运行的, 依然是收到第一个 onComplete 就不再接收了, 但若是发送多个 onError,

则收到第二个 onError 事件会导致程序会崩溃.

剩余64页未读，继续阅读

评论收藏

内容反馈

Andy&lin

粉丝: 97
资源: 214

RxJava2.0（初学者教程+实用操作符总结及原理简析）

struts2.0+hibernate3.0+spring3.5框架搭建

精通ASP.NET2.0的Web2.0+电子教程.rar

Struts2.0+Spring2.0+Hibernate3.1登录及增删改查的完整演示示例

集成TC2.0和TC++3.0的虚拟DOS环境

Struts2.0做的注册+验证

Material Design + MVP + RxJava2 + Retrofit + Dagger2 + Realm + Glide

struts2.0+hibernate3.0+spring2.0整合登录系统

struts2.0+hibernate3.1+spring2.0实例源码

struts2.0+spring2.0+hibernate3.0

spring2.0+struts2.0+hibernate3.rar

struts2.0+spring2+hibernate3

TC2.0初学者开发工具

vite2.0+react17+mobx+antd带登录，tabs多开窗口的应用系统框架

Struts2.0+spring+hibernate的小例子,初学者可以看看

asp.net2.0(C#)+SQL2005学生信息管理系统

体育赛事发布系统struts2.0+hibernate+spring+mysql

ASP.NET2.0(C#)大学实用教程(电子教案0)

seatunnel v2.0 初学极速安装包-源码+文档+发布包+flink+依赖

vue2.0+node.js+MongoDB全栈打造商城-源码.zip

Java第十五届蓝桥杯大赛软件JavaB组真题

SwitchHosts

安卓期末大作业（AndroidStudio开发），垃圾分类助手app，分为前台后台，代码有注释，均能正常运行

Notepad++安装包

2024北森能力测评题库.7z

微信小程序源码-合集1.rar

Java面试八股文2023最新版

Linux Centos7 升级最新版OpenSSH-9.6p1 有脚本（支持离线）

JDK1.8 windows 64位

ruoyi-vue-pro 芋道源码项目的表结构

最新资源