Rxjava源码解析笔记 | Rxjava基本用法详析(附示例代码)

本文涉及的产品
云解析 DNS,旗舰版 1个月
全局流量管理 GTM,标准版 1个月
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
简介: Rxjava源码解析笔记 | Rxjava基本用法详析(附示例代码)

Rxjava四要素

  1. 被观察者

**在Rxjava当中,
决定什么时候触发事件,
决定触发什么样的事件;**

  1. 观察者

    • 决定事件触发的时候将产生什么样的行为;
    • 类似于传统观察者模式

观察者会随着被观察者的状态变化而发生相应的操作;

  1. 订阅

    • 区别于传统观察者模式
    • 观察者被观察者需要通过订阅来联系;
    • 通过subscribe()方法完成这个订阅关系;
    • 完成订阅关系后,

即可令被观察者(Observable)在需要的时候,
发出事件来通知观察者(Observer)

  1. 事件

    • 区别于传统观察者模式

(下面详说)

事件

  • 响应式编程中的核心概念
  • 响应式编程乃基于异步数据流概念的编程模式;
理解响应式编程
  • 场景举例:客户端服务端获取到最新的数据时,

需要通知客户端本身相关模块进行更新(如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()方法,

在其中根据被观察者状态变化而做出反应/改变;**

2. **而在Rxjava中,框架给出了三个方法;**

**其中onCompleted()onError()两个方法就是对传统观察者模式做出的改变/区别,
onNext()其实就是传统观察者模式当中的update();**

- ```onCompleted()```:当```不再有新的事件```通过```被观察者``` ```发出```的时候```回调```;
- ```onError()```:  在处理异常框架时```回调```;
- ```onNext()```:同理```传统观察者模式```当中的```update()```,

即编写 当被观察者发生状态改变时,观察者的处理逻辑;

   //第二步:创建观察者
    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);
    }

}




参考自 慕课网

相关文章
|
16天前
|
监控 Java 应用服务中间件
高级java面试---spring.factories文件的解析源码API机制
【11月更文挑战第20天】Spring Boot是一个用于快速构建基于Spring框架的应用程序的开源框架。它通过自动配置、起步依赖和内嵌服务器等特性,极大地简化了Spring应用的开发和部署过程。本文将深入探讨Spring Boot的背景历史、业务场景、功能点以及底层原理,并通过Java代码手写模拟Spring Boot的启动过程,特别是spring.factories文件的解析源码API机制。
45 2
|
2月前
|
存储 算法 Java
解析HashSet的工作原理,揭示Set如何利用哈希算法和equals()方法确保元素唯一性,并通过示例代码展示了其“无重复”特性的具体应用
在Java中,Set接口以其独特的“无重复”特性脱颖而出。本文通过解析HashSet的工作原理,揭示Set如何利用哈希算法和equals()方法确保元素唯一性,并通过示例代码展示了其“无重复”特性的具体应用。
47 3
|
17天前
|
存储 安全 Linux
Golang的GMP调度模型与源码解析
【11月更文挑战第11天】GMP 调度模型是 Go 语言运行时系统的核心部分,用于高效管理和调度大量协程(goroutine)。它通过少量的操作系统线程(M)和逻辑处理器(P)来调度大量的轻量级协程(G),从而实现高性能的并发处理。GMP 模型通过本地队列和全局队列来减少锁竞争,提高调度效率。在 Go 源码中,`runtime.h` 文件定义了关键数据结构,`schedule()` 和 `findrunnable()` 函数实现了核心调度逻辑。通过深入研究 GMP 模型,可以更好地理解 Go 语言的并发机制。
|
29天前
|
消息中间件 缓存 安全
Future与FutureTask源码解析,接口阻塞问题及解决方案
【11月更文挑战第5天】在Java开发中,多线程编程是提高系统并发性能和资源利用率的重要手段。然而,多线程编程也带来了诸如线程安全、死锁、接口阻塞等一系列复杂问题。本文将深度剖析多线程优化技巧、Future与FutureTask的源码、接口阻塞问题及解决方案,并通过具体业务场景和Java代码示例进行实战演示。
43 3
|
1月前
|
Dart 安全 编译器
Flutter结合鸿蒙next 中数据类型转换的高级用法:dynamic 类型与其他类型的转换解析
在 Flutter 开发中,`dynamic` 类型提供了灵活性,但也带来了类型安全性问题。本文深入探讨 `dynamic` 类型及其与其他类型的转换,介绍如何使用 `as` 关键字、`is` 操作符和 `whereType&lt;T&gt;()` 方法进行类型转换,并提供最佳实践,包括避免过度使用 `dynamic`、使用 Null Safety 和异常处理,帮助开发者提高代码的可读性和可维护性。
78 1
|
2月前
|
存储
让星星⭐月亮告诉你,HashMap的put方法源码解析及其中两种会触发扩容的场景(足够详尽,有问题欢迎指正~)
`HashMap`的`put`方法通过调用`putVal`实现,主要涉及两个场景下的扩容操作:1. 初始化时,链表数组的初始容量设为16,阈值设为12;2. 当存储的元素个数超过阈值时,链表数组的容量和阈值均翻倍。`putVal`方法处理键值对的插入,包括链表和红黑树的转换,确保高效的数据存取。
59 5
|
2月前
|
机器学习/深度学习 算法 Python
深度解析机器学习中过拟合与欠拟合现象:理解模型偏差背后的原因及其解决方案,附带Python示例代码助你轻松掌握平衡技巧
【10月更文挑战第10天】机器学习模型旨在从数据中学习规律并预测新数据。训练过程中常遇过拟合和欠拟合问题。过拟合指模型在训练集上表现优异但泛化能力差,欠拟合则指模型未能充分学习数据规律,两者均影响模型效果。解决方法包括正则化、增加训练数据和特征选择等。示例代码展示了如何使用Python和Scikit-learn进行线性回归建模,并观察不同情况下的表现。
347 3
|
2月前
|
Java Spring
Spring底层架构源码解析(三)
Spring底层架构源码解析(三)
120 5
|
2月前
|
XML Java 数据格式
Spring底层架构源码解析(二)
Spring底层架构源码解析(二)
|
2月前
|
前端开发 JavaScript UED
axios取消请求CancelToken的原理解析及用法示例
axios取消请求CancelToken的原理解析及用法示例
118 0

推荐镜像

更多