RxJava简单入门
2024-05-18 06:19:57
前言之前
首先来认识一下接下来我们将要接触的关键单词，Observeable,Observer,subscrib国内基本都翻译成，被观察者，观察者，订阅。如果你按照这样的中文意思来理解，是怎么也理解不了的，普遍认为是观察者订阅了被观察者，但是你怎么理解observable.subscribe(observer);按照上边的名词翻译，被观察者订阅了观察者？！理解不了！报纸订阅了你？
我粗浅的认为，able是表示能力的意思，er表示xx样的对象，xx者。而仔细观察：订阅和被订阅者，存在主动改变（自变量）和被动应变（应变量）的区别，这样就好解释报纸订阅了你：主动改变者，往自己里边塞了一个被动应变者，来监听观察自己的变化（在敌方安插一个我们的间谍）。主动改变者，有很多发射，合并，等等的事件发生的方法；而被动变化者，只有相对固定的流程方法，onSubscribe(),onNext(),onComplete()，onError()等等。
RxJava很早之前就接触了，一直没太明白，现在才算理解通了。不是人家这东西烧脑，是我们一些翻译者，不够专业，或者说翻译词不达意造成歧义。
这就是对RxJava的前置了解。
前言
Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大Android开发者的欢迎。
- 本文主要：
- 面向 刚接触
Rxjava的初学者 - 提供了一份 清晰、简洁、易懂的
Rxjava入门教程 >涵盖 基本介绍、原理 & 具体使用等 - 解决的是初学者不理解
Rxjava原理 & 不懂得如何使用的问题
- 面向 刚接触
希望你们会喜欢。
- 本文主要基于
Rxjava 2.0 - 如果读者还没学习过
Rxjava 1.0也没关系，因为Rxjava 2.0只是在Rxjava 1.0上增加了一些新特性，本质原理 & 使用基本相同 - 接下来的时间，我将持续推出
Android中Rxjava 2.0的一系列文章，包括原理、操作符、应用场景、背压等等 ，有兴趣可以继续关注Carson_Ho的安卓开发笔记！！
目录
1. 定义
RxJava在GitHub的介绍：RxJava：a library for composing asynchronous and event-based programs using observable sequences for the Java VM // 翻译：RxJava 是一个在 Java VM 上使用可观测的序列来组成异步的、基于事件的程序的库- 总结：
RxJava是一个 基于事件流、实现异步操作的库
2. 作用
实现异步操作
类似于
Android中的AsyncTask、Handler作用
3. 特点
由于 RxJava的使用方式是：基于事件流的链式调用，所以使得 RxJava： - 逻辑简洁 - 实现优雅 - 使用简单
更重要的是，随着程序逻辑的复杂性提高，它依然能够保持简洁 & 优雅
4. 原理
4.1 生活例子引入
- 我用一个生活例子引入 & 讲解
Rxjava原理： 顾客到饭店吃饭
4.2 Rxjava原理介绍
Rxjava原理 基于 一种扩展的观察者模式Rxjava的扩展观察者模式中有4个角色：
|
角色 |
作用 |
类比 |
|---|---|---|
|
被观察者（Observable） |
产生事件 |
顾客 |
|
观察者（Observer） |
接收事件，并给出响应动作 |
厨房 |
|
订阅（Subscribe） |
连接 被观察者 & 观察者 |
服务员 |
|
事件（Event） |
被观察者 & 观察者 沟通的载体 |
菜式 |
- 具体原理
请结合上述 顾客到饭店吃饭 的生活例子理解：
即RxJava原理可总结为：被观察者 （Observable） 通过 订阅（Subscribe） 按顺序发送事件 给观察者 （Observer）， 观察者（Observer） 按顺序接收事件 & 作出对应的响应动作。具体如下图：
至此，RxJava原理讲解完毕。
5. 基本使用
- 本文只关注
RxJava的基本使用，更深入的RxJava使用请继续关注Carson_Ho的安卓开发笔记 Rxjava的使用方式有两种：- 分步骤实现：该方法主要为了深入说明
Rxjava的原理 & 使用，主要用于演示说明 - 基于事件流的链式调用：主要用于实际使用
- 分步骤实现：该方法主要为了深入说明
5.1 方式1：分步骤实现
5.1.1 使用步骤
5.1.2 步骤详解
步骤1：创建被观察者 （Observable ）& 生产事件
- 即 顾客入饭店 - 坐下餐桌 - 点菜
- 具体实现
// 1. 创建被观察者 Observable 对象Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() {// create() 是 RxJava 最基本的创造事件序列的方法// 此处传入了一个 OnSubscribe 对象参数// 当 Observable 被订阅时，OnSubscribe 的 call() 方法会自动被调用，即事件序列就会依照设定依次被触发// 即观察者会依次调用对应事件的复写方法从而响应事件// 从而实现被观察者调用了观察者的回调方法 & 由被观察者向观察者的事件传递，即观察者模式// 2. 在复写的subscribe（）里定义需要发送的事件@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {// 通过 ObservableEmitter类对象产生事件并通知观察者// ObservableEmitter类介绍// a. 定义：事件发射器// b. 作用：定义需要发送的事件 & 向观察者发送事件emitter.onNext(1);emitter.onNext(2);emitter.onNext(3);emitter.onComplete();}});<--扩展：RxJava 提供了其他方法用于 创建被观察者对象Observable -->// 方法1：just(T...)：直接将传入的参数依次发送出来Observable observable = Observable.just("A", "B", "C");// 将会依次调用：// onNext("A");// onNext("B");// onNext("C");// onCompleted();// 方法2：from(T[]) / from(Iterable<? extends T>) : 将传入的数组 / Iterable 拆分成具体对象后，依次发送出来String[] words = {"A", "B", "C"};Observable observable = Observable.from(words);// 将会依次调用：// onNext("A");// onNext("B");// onNext("C");// onCompleted();步骤2：创建观察者 （Observer ）并 定义响应事件的行为
- 即 开厨房 - 确定对应菜式
- 发生的事件类型包括：
Next事件、Complete事件 &Error事件。具体如下：
- 具体实现
<--方式1：采用Observer 接口 -->// 1. 创建观察者 （Observer ）对象Observer<Integer> observer = new Observer<Integer>() {// 2. 创建对象时通过对应复写对应事件方法 从而 响应对应事件// 观察者接收事件前，默认最先调用复写 onSubscribe（）@Overridepublic void onSubscribe(Disposable d) {Log.d(TAG, "开始采用subscribe连接");}// 当被观察者生产Next事件 & 观察者接收到时，会调用该复写方法 进行响应@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件作出响应" + value);}// 当被观察者生产Error事件& 观察者接收到时，会调用该复写方法 进行响应@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}// 当被观察者生产Complete事件& 观察者接收到时，会调用该复写方法 进行响应@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}};<--方式2：采用Subscriber 抽象类 -->// 说明：Subscriber类 = RxJava 内置的一个实现了 Observer 的抽象类，对 Observer 接口进行了扩展// 1. 创建观察者 （Observer ）对象Subscriber<String> subscriber = new Subscriber<Integer>() {// 2. 创建对象时通过对应复写对应事件方法 从而 响应对应事件// 观察者接收事件前，默认最先调用复写 onSubscribe（）@Overridepublic void onSubscribe(Subscription s) {Log.d(TAG, "开始采用subscribe连接");}// 当被观察者生产Next事件 & 观察者接收到时，会调用该复写方法 进行响应@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件作出响应" + value);}// 当被观察者生产Error事件& 观察者接收到时，会调用该复写方法 进行响应@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}// 当被观察者生产Complete事件& 观察者接收到时，会调用该复写方法 进行响应@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}};<--特别注意：2种方法的区别，即Subscriber 抽象类与Observer 接口的区别 -->// 相同点：二者基本使用方式完全一致（实质上，在RxJava的 subscribe 过程中，Observer总是会先被转换成Subscriber再使用）// 不同点：Subscriber抽象类对 Observer 接口进行了扩展，新增了两个方法：// 1. onStart()：在还未响应事件前调用，用于做一些初始化工作// 2. unsubscribe()：用于取消订阅。在该方法被调用后，观察者将不再接收 & 响应事件// 调用该方法前，先使用 isUnsubscribed() 判断状态，确定被观察者Observable是否还持有观察者Subscriber的引用，如果引用不能及时释放，就会出现内存泄露步骤3：通过订阅（Subscribe）连接观察者和被观察者
- 即 顾客找到服务员 - 点菜 - 服务员下单到厨房 - 厨房烹调
- 具体实现
observable.subscribe(observer);// 或者 observable.subscribe(subscriber)；- 扩展说明
<-- Observable.subscribe(Subscriber) 的内部实现 -->public Subscription subscribe(Subscriber subscriber) {subscriber.onStart();// 步骤1中 观察者 subscriber抽象类复写的方法，用于初始化工作onSubscribe.call(subscriber);// 通过该调用，从而回调观察者中的对应方法从而响应被观察者生产的事件// 从而实现被观察者调用了观察者的回调方法 & 由被观察者向观察者的事件传递，即观察者模式// 同时也看出：Observable只是生产事件，真正的发送事件是在它被订阅的时候，即当 subscribe() 方法执行时}5.2 方式2：优雅的实现方法 - 基于事件流的链式调用
- 上述的实现方式是为了说明
Rxjava的原理 & 使用 - 在实际应用中，会将上述步骤&代码连在一起，从而更加简洁、更加优雅，即所谓的
RxJava基于事件流的链式调用
// RxJava的链式操作Observable.create(new ObservableOnSubscribe<Integer>() {// 1. 创建被观察者 & 生产事件@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {emitter.onNext(1);emitter.onNext(2);emitter.onNext(3);emitter.onComplete();}}).subscribe(new Observer<Integer>() {// 2. 通过通过订阅（subscribe）连接观察者和被观察者// 3. 创建观察者 & 定义响应事件的行为@Overridepublic void onSubscribe(Disposable d) {Log.d(TAG, "开始采用subscribe连接");}// 默认最先调用复写的 onSubscribe（）@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件"+ value +"作出响应" );}@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}});}}注：整体方法调用顺序：观察者.onSubscribe（）> 被观察者.subscribe（）> 观察者.onNext（）>观察者.onComplete() 这种 基于事件流的链式调用，使得RxJava： - 逻辑简洁 - 实现优雅 - 使用简单
更重要的是，随着程序逻辑的复杂性提高，它依然能够保持简洁 & 优雅。所以，一般建议使用这种基于事件流的链式调用方式实现RxJava。
特别注意
RxJava 2.x 提供了多个函数式接口 ，用于实现简便式的观察者模式。具体如下：
以 Consumer为例：实现简便式的观察者模式
Observable.just("hello").subscribe(new Consumer<String>() {// 每次接收到Observable的事件都会调用Consumer.accept（）@Overridepublic void accept(String s) throws Exception {System.out.println(s);}});6. 实例说明
我将用一个实际工程实例来演示 Rxjava的使用
6.1 方式1：分步骤实现
步骤1：加入依赖xml compile 'io.reactivex.rxjava2:rxjava:2.0.1' compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
步骤2：直接在MainActivity.java中实现下述步骤 1. 创建被观察者 （Observable ）& 生产事件 2. 创建观察者 （Observer ）并 定义响应事件的行为 3. 通过订阅（Subscribe）连接观察者和被观察者
public class MainActivity extends AppCompatActivity {private static final String TAG = "Rxjava";@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);// 步骤1：创建被观察者 Observable & 生产事件// 即 顾客入饭店 - 坐下餐桌 - 点菜// 1. 创建被观察者 Observable 对象Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() {// 2. 在复写的subscribe（）里定义需要发送的事件@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {// 通过 ObservableEmitter类对象产生事件并通知观察者// ObservableEmitter类介绍// a. 定义：事件发射器// b. 作用：定义需要发送的事件 & 向观察者发送事件emitter.onNext(1);emitter.onNext(2);emitter.onNext(3);emitter.onComplete();}});// 步骤2：创建观察者 Observer 并 定义响应事件行为// 即 开厨房 - 确定对应菜式Observer<Integer> observer = new Observer<Integer>() {// 通过复写对应方法来 响应 被观察者@Overridepublic void onSubscribe(Disposable d) {Log.d(TAG, "开始采用subscribe连接");}// 默认最先调用复写的 onSubscribe（）@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件"+ value +"作出响应" );}@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}};// 步骤3：通过订阅（subscribe）连接观察者和被观察者// 即 顾客找到服务员 - 点菜 - 服务员下单到厨房 - 厨房烹调observable.subscribe(observer);- 测试结果
6.2 方式2：基于事件流的链式调用方式
public class MainActivity extends AppCompatActivity {private static final String TAG = "Rxjava";@Overrideprotected void onCreate(Bundle savedInstanceState) {super.onCreate(savedInstanceState);setContentView(R.layout.activity_main);// RxJava的流式操作Observable.create(new ObservableOnSubscribe<Integer>() {// 1. 创建被观察者 & 生产事件@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {emitter.onNext(1);emitter.onNext(2);emitter.onNext(3);emitter.onComplete();}}).subscribe(new Observer<Integer>() {// 2. 通过通过订阅（subscribe）连接观察者和被观察者// 3. 创建观察者 & 定义响应事件的行为@Overridepublic void onSubscribe(Disposable d) {Log.d(TAG, "开始采用subscribe连接");}// 默认最先调用复写的 onSubscribe（）@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件"+ value +"作出响应" );}@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}});}}- 测试效果 实现效果同上
- Demo 下载地址 Carson_Ho的Github地址 = RxJava2系列：基础使用
7. 额外说明
7.1 观察者 Observer的subscribe()具备多个重载的方法
public final Disposable subscribe() {}// 表示观察者不对被观察者发送的事件作出任何响应（但被观察者还是可以继续发送事件）public final Disposable subscribe(Consumer<? super T> onNext) {}// 表示观察者只对被观察者发送的Next事件作出响应public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError) {} // 表示观察者只对被观察者发送的Next事件 & Error事件作出响应public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) {}// 表示观察者只对被观察者发送的Next事件、Error事件 & Complete事件作出响应public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) {}// 表示观察者只对被观察者发送的Next事件、Error事件 、Complete事件 & onSubscribe事件作出响应public final void subscribe(Observer<? super T> observer) {}// 表示观察者对被观察者发送的任何事件都作出响应7.2 可采用 Disposable.dispose() 切断观察者 与 被观察者 之间的连接
- 即观察者 无法继续 接收 被观察者的事件，但被观察者还是可以继续发送事件
- 具体使用
// 主要在观察者 Observer中 实现Observer<Integer> observer = new Observer<Integer>() {// 1. 定义Disposable类变量private Disposable mDisposable;@Overridepublic void onSubscribe(Disposable d) {Log.d(TAG, "开始采用subscribe连接");// 2. 对Disposable类变量赋值mDisposable = d;}@Overridepublic void onNext(Integer value) {Log.d(TAG, "对Next事件"+ value +"作出响应" );if (value == 2) {// 设置在接收到第二个事件后切断观察者和被观察者的连接mDisposable.dispose();Log.d(TAG, "已经切断了连接：" + mDisposable.isDisposed());}}@Overridepublic void onError(Throwable e) {Log.d(TAG, "对Error事件作出响应");}@Overridepublic void onComplete() {Log.d(TAG, "对Complete事件作出响应");}};- 效果图
8. 总结
- 本文主要对
Rxjava的入门知识进行讲解，包括基本介绍、原理 & 具体使用等 - 接下来，我将持续推出
Android中Rxjava 2.0的一系列文章，包括原理、操作符、应用场景、背压等等 ，有兴趣可以继续关注Carson_Ho的安卓开发笔记！！
RxJava简单入门相关推荐
- RxJava学习入门
RxJava是什么 一个词:异步. RxJava 在 GitHub 主页上的自我介绍是 "a library for composing asynchronous and event-bas ...
- BizTalk 2006 简单入门示例程序（附源项目文件下载）
BizTalk 2006 简单入门示例程序(附源项目文件下载) 为初学BizTalk Server 2006的开发人员,提供一个简单入门的示例程序,包括一个Receive Port.Send Port ...
- python如何读取mat文件可视化_python Matplotlib数据可视化（1）：简单入门
1 matplot入门指南 matplotlib是Python科学计算中使用最多的一个可视化库,功能丰富,提供了非常多的可视化方案,基本能够满足各种场景下的数据可视化需求.但功能丰富从另一方面来说也意 ...
- ARM NEON 编程简单入门1
原文:http://blog.csdn.net/silentob/article/details/72954618 ARM NEON 编程简单入门1 NEON简介 NEON是适用于ARM Corte ...
- Python 简单入门指北(二)
Python 简单入门指北(二) 2 函数 2.1 函数是一等公民 一等公民指的是 Python 的函数能够动态创建,能赋值给别的变量,能作为参传给函数,也能作为函数的返回值.总而言之,函数和普通变量 ...
- EChart.js 简单入门
EChart.js 简单入门 最近有一个统计的项目要做,在前端的数据需要用图表的形式展示.网上搜索了一下,发现有几种统计图库. MSChart 这个是Visual Studio里的自带控件,使用比 ...
- 【我的区块链之路】- Hyperledger fabric的简单入门（四）链码的编写及调试
[我的区块链之路]- Hyperledger fabric的简单入门(四)链码的编写及调试 之前的文章中我们有讲过了fabric的一些核心的配置文件的选项说明,讲过fabric 的网络启动 ...
- 基于vue-cli、elementUI的Vue超简单入门小例子
基于vue-cli.elementUI的Vue超简单入门小例子 这个例子还是比较简单的,独立完成后,能大概知道vue是干嘛的,可以写个todoList的小例子. 开始写例子之前,先对环境的部署做点简单 ...
- 【java开发系列】—— spring简单入门示例
回顾 1 JDK安装 2 Struts2简单入门示例 前言 作为入门级的记录帖,没有过多的技术含量,简单的搭建配置框架而已.这次讲到spring,这个应该是SSH中的重量级框架,它主要包含两个内容:控 ...
最新文章
- Shell字符串截取——获取oracle group名字
- MongoDb Windows linux平台环境及主流编程语言驱动安装同时配置mongoDb的远程连接
- java追加一个sheet_（二）POI-创建一个sheet页，并添加行列数据
- java常见的报错_Java中常见的错误有哪些?
- @transactional 接口_Spring事物（@transactional注解）在什么情况下会失效，为什么？...
- 添加防火墙策略_网络安全文章基础篇（第5张）防火墙项目实战笔记
- mac os maven_如何在Mac OS上安装Maven
- 【Tensorflow2.x】设置GPU（内存自增长、指定GPU）
- 如何将内网ip映射到外网
- 汽车电子开发设计常用软件工具有哪些
- 六西格玛dfss_六西格玛设计(DFSS)的方法和知识
- 推荐系统中的选择偏差及处理
- kotlin用it还是this?
- 玩转华为ENSP模拟器系列 | 配置OSPF多进程
- SpringSecurity如何处理logout注销操作
- CTFshow入门命令执行30
- 第三方支付平台结算流程是什么样的？
- Python pdf 去水印
- 计算CSV Python中有多少行？
- W ndowS无法自动修此计算机,系统引导怎么修复？电脑手动修复Windows系统引导文件...