Rxjava源码解析笔记 | Rxjava基本用法
时间:2022-06-23
本文章向大家介绍Rxjava源码解析笔记 | Rxjava基本用法,主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
Rxjava四要素
- 被观察者
在Rxjava当中,
决定
什么时候
触发事件, 决定触发什么样
的事件; - 观察者
- 决定事件触发的时候将产生什么样的行为;
- 类似于
传统观察者模式
,观察者
会随着被观察者
的状态变化而发生相应的操作;
- 订阅
- 区别于传统
观察者模式
; -
观察者
和被观察者
需要通过订阅
来联系; - 通过
subscribe()
方法完成这个订阅关系; - 完成订阅关系后,
即可令
被观察者(Observable)
在需要的时候, 发出事件
来通知观察者(Observer)
- 区别于传统
- 事件
- 区别于传统
观察者模式
; (下面详说)
- 区别于传统
事件
- 乃
响应式编程
中的核心概念
; -
响应式编程
乃基于异步数据流概念
的编程模式;
理解响应式编程
- 场景举例:
客户端
从服务端
获取到最新的数据时, 需要通知客户端
本身相关模块进行更新(如UI变换显示等); 这其实便是一种响应式编程
——客户端
根据服务端的变化
做出相应;
生活中的例子
- 天气冷了我们就要多穿件衣服。
天气冷了
,就是一种事件
;要多穿件衣服
,就是基于事件做出
的响应
; - 饿了要吃饭。
饿了
,就是一种事件
;吃饭
,就是基于事件做出
的响应
;
代码分析
-
第一步,
(通过
create()
)创建被观察者(Observable),即第一个基本要素, 其中注意OnSubscribe<String>()
对象, 记住它是存储在Observable
当中的; 当Observable
订阅之后, 它会启动OnSubscribe<String>()
对象中的回调方法call()
, 同时运行call()
方法体中写好的反应序列
;
//第一步:创建被观察者:create
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello");
subscriber.onNext("Imooc");
subscriber.onCompleted();
}
});
- .
- 其中,其实
Subscriber
就是我们的观察者
; 后面的Rxjava源码阅读中, 我们会发现Observer
在源码中也会被转换成Subscriber
来进行相应的处理, 所有才说其实Subscriber
就是我们的观察者
; - 以上我们可以看到,在
create
一个被观察者
时, 我们new
了一个OnSubscribe<String>()
, 并在其中实现了回调方法call()
,回调方法
中调用了观察者的方法
—— 在创建被观察者时
,使用了调用了观察者方法
的回调方法
, 这其实就是一种事件的传递
; 最后将这个OnSubscribe<String>()
赋给被观察者
的创建方法create()
; 如此便跟传统观察者模式
联系起来了; (只不过这里Rxjava给我们做好了更好的封装)
- 其中,其实
- 以上是
创建被观察者的一种方法
, 事实上还有其他两种
:- 第二种,通过
just()
方法创建, 只要把参数
放到just()
方法中,以逗号
分隔开来即可, 而just()
其实就是将参数
依次
通过事件
发送
出来, 这种写法其实是跟上面的两个onNext()、一个onCompleted()
的写法是一样的; - 第三种,通过
from()
方法, 类似于第二种方法,只是把传给just
的参数
组合成一个String数组
在传给from()
; 这种写法其实是跟上面的两个onNext()、一个onCompleted()
的写法是一样的;
- 第二种,通过
- 以上三种方法其实都是等价的,其最终目的都是
创建被观察者
;
//通过just方法来创建被观察者
Observable observableJust = Observable.just("hello", "Imooc");
//通过from方法来创建被观察者
String[] parameters = {"hello", "Imooc"};
Observable observableFrom = Observable.from(parameters);
- 第二步,
创建
观察者Observer/Subscriber
,即第二个要素, 1.在传统的观察者模式当中,观察者只有一个update()
方法, 在其中根据被观察者
的状态变化
而做出反应/改变
;- 而在Rxjava中,框架给出了三个方法;
其中
onCompleted()
和onError()
两个方法就是对传统观察者模式
做出的改变/区别, 而onNext()
其实就是传统观察者模式
当中的update()
;
-
onCompleted()
:当不再有新的事件
通过被观察者
发出
的时候回调
; -
onError()
: 在处理异常框架时回调
; -
onNext()
:同理传统观察者模式
当中的update()
, 即编写 当被观察者
发生状态改变时,观察者
的处理逻辑;
- 而在Rxjava中,框架给出了三个方法;
其中
//第二步:创建观察者
Observer<Object> observer = new Observer<Object>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Object s) {
}
};
-
被观察者Observable
是用过链式调用
来执行的; 为的是让后面的操作符
、线程控制
等能够跟流式OPI
来完善, 而不是其他方式
如观察者去订阅被观察者(非链式)
—— 这样从意思上容易理解,但在API调用上很不方便; - 链式调用:理解比较绕,但能跟
流式OPI
来完善,API调用上非常方便
; - 非链式调用:意思上容易理解,但在API调用上很不方便;
- 第三步,订阅:
前面我们说概念的时候,都是
观察者
订阅被观察者
的, 可是这里代码中, “奇怪”的是“被观察者(Observable)
去订阅(subscribe)观察者(Observer)
”, 这里就是上面说的, 为了后面能够通过流式OPI, 使进行操作符
、线程控制
等操作时能够通过链式调用
来完善; 所以这里Rxjava中把订阅设计成“被观察者(Observable)去订阅(subscribe)观察者(Observer)”
public void doRxjava(){
//第三步:订阅
observable.subscribe(observer);
}
- 本节完整代码如下:
这里其实只是
Rxjava
的一种简单的使用, 主要是理解一下Rxjava
对传统观察者设计模式
的拓展
和改进
; 实际情况当中,其实它还包括了很多操作符
, 以及Rxjava最核心的线程控制调度
, 这两部分是Rxjava的核心
.
package com.example.jiajiemu.a11.rxjava;
import rx.Observable;
import rx.Observer;
import rx.Subscriber;
/**
* Created by Mjj on 2017/10/6.
*/
public class RxjavaCreateDemo {
//第一步:创建被观察者:create
Observable observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("Hello");
subscriber.onNext("Imooc");
subscriber.onCompleted();
}
});
//通过just方法来创建被观察者
Observable observableJust = Observable.just("hello", "Imooc");
//通过from方法来创建被观察者
String[] parameters = {"hello", "Imooc"};
Observable observableFrom = Observable.from(parameters);
//第二步:创建观察者
Observer<Object> observer = new Observer<Object>() {
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(Object s) {
}
};
public void doRxjava(){
//第三步:订阅
observable.subscribe(observer);
}
}
参考自 慕课网
- java教程
- Java快速入门
- Java 开发环境配置
- Java基本语法
- Java 对象和类
- Java 基本数据类型
- Java 变量类型
- Java 修饰符
- Java 运算符
- Java 循环结构
- Java 分支结构
- Java Number类
- Java Character类
- Java String类
- Java StringBuffer和StringBuilder类
- Java 数组
- Java 日期时间
- Java 正则表达式
- Java 方法
- Java 流(Stream)、文件(File)和IO
- Java 异常处理
- Java 继承
- Java 重写(Override)与重载(Overload)
- Java 多态
- Java 抽象类
- Java 封装
- Java 接口
- Java 包(package)
- Java 数据结构
- Java 集合框架
- Java 泛型
- Java 序列化
- Java 网络编程
- Java 发送邮件
- Java 多线程编程
- Java Applet基础
- Java 文档注释
- Backtracking - 47. Permutations II
- Backtracking - 46. Permutations
- Dynamic Programming - 377. Combination Sum IV
- Backtracking - 216. Combination Sum III
- Backtracking - 40. Combination Sum II
- Backtracking - 39. Combination Sum
- Backtracking - 77. Combinations
- Backtracking - 90. Subsets II
- Backtracking - 78. Subsets
- Tree - 331. Verify Preorder Serialization of a Binary Tree
- Tree - 95. Unique Binary Search Trees II
- Tree - 96. Unique Binary Search Trees
- Tree - 116. Populating Next Right Pointers in Each Node
- Tree - 297. Serialize and Deserialize Binary Tree
- 使用 shell 脚本批量创建用户详解讲解