RxJava 2.x 之图解创建、订阅、发射流程

2024-02-19 06:10

本文主要是介绍RxJava 2.x 之图解创建、订阅、发射流程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

  • 从一个例子开始
  • 创建过程
  • 订阅过程
  • 发射过程
  • 小结
从一个例子开始
Observable.create(new ObservableOnSubscribe<Integer>() {@Overridepublic void subscribe(ObservableEmitter<Integer> emitter) throws Exception {for (int i = 0; i < 3; i++) {emitter.onNext(i);}emitter.onComplete();Log.d(TAG, "subscribe " + Thread.currentThread().getName());}}).subscribeOn(Schedulers.newThread()).map(new Function<Integer, String>() {@Overridepublic String apply(Integer value) throws Exception {Log.d(TAG, "apply " + Thread.currentThread().getName());return "apply " + value;}}).observeOn(AndroidSchedulers.mainThread()).subscribeWith(new ResourceObserver<String>() {@Overridepublic void onNext(String value) {Log.d(TAG, "onNext " + value);}@Overridepublic void onError(Throwable e) {Log.d(TAG, "onError");}@Overridepublic void onComplete() {Log.d(TAG, "onComplete " + Thread.currentThread().getName());}});

来看看输出:

10-26 16:55:17.418 32696-561/com.onzhou.study D/MainActivity: apply RxNewThreadScheduler-1
10-26 16:55:17.418 32696-561/com.onzhou.study D/MainActivity: apply RxNewThreadScheduler-1
10-26 16:55:17.418 32696-561/com.onzhou.study D/MainActivity: create RxNewThreadScheduler-1
10-26 16:55:17.427 32696-32696/com.onzhou.study D/MainActivity: onNext apply 0
10-26 16:55:17.427 32696-32696/com.onzhou.study D/MainActivity: onNext apply 1
10-26 16:55:17.427 32696-32696/com.onzhou.study D/MainActivity: onNext apply 2
10-26 16:55:17.427 32696-32696/com.onzhou.study D/MainActivity: onComplete main

可以看到创建发送转换过程都在子线程中,而最后的回调是在主线程中

整个过程笔者整理成一张图,一步一步来跟进分析

创建过程
  • 第一步:通过create操作符创建了一个ObservableCreate类型的Observable,由于是基于匿名内部类创建的,因此持有的是实现了ObservableOnSubscribe接口的HomeActivity实例

  • 第二步:通过subscribeOn操作符创建了一个ObservableSubscribeOn类型的Observable,且其内部的source持有上个步骤的ObservableCreate实例

  • 第三步:通过map操作符创建了一个ObservableMap类型的Observable,且其内部持有上个步骤传入的ObservableSubscribeOn实例

  • 第四步:通过observeOn操作符创建了一个ObservableObserveOn类型的Observable,且其内部持有上个步骤的ObservableMap实例

  • 第五步:通过subscribeWith方法完成订阅,由于是基于匿名内部类创建的,因此传入的实际上是实现了ResourceObserverHomeActivity实例

订阅过程

上述的几个步骤其实已经完成的基本的创建过程了,最后我们拿到的实际是ObservableObserveOn的实例,下面开始订阅流程。

  • 第一步:subscribeWith方法,传入的observer是实现了ResourceObserver接口HomeActivity实例,通过subscribeActual发起订阅,内部实际调用的是source.subscribe方法,由于source持有的是上面传入的ObservableMap实例,因此这一步骤实际调用的是,ObservableMap实例中的subscribe方法,传入的参数就是ObserveOnObserver实例(构造参数主要是实现了ResourceObserver的实例即:HomeActivity)

  • 第二步:进入ObservableMap实例subscribe方法中,通过subscribeActual发起订阅,实际调用的是source.subscribe方法,传入的是MapObserver实例(构造参数为之前传递的ObserveOnObserver实例),由于source持有的是ObservableSubscribeOn的实例,因此最终调用的其实是ObservableSubscribeOn实例中的subscribe方法

  • 第三步:进入ObservableSubscribeOn实例subscribe方法中,通过subscribeActual发起订阅,完成MapObserver实例对SubscribeOnObserver的订阅,接着由NewThreadScheduler线程调度器完成对应的任务(该任务的执行是在线程中执行的),SubscribeTask实现了Runnable接口,最终会回调run方法,执行source.subscribe方法,这里的source持有的就是最开始的ObservableCreate实例

@Overridepublic void subscribeActual(final Observer<? super T> s) {final SubscribeOnObserver<T> parent = new SubscribeOnObserver<T>(s);//这里的s就是上个步骤的MapObserver实例s.onSubscribe(parent);//这里的scheduler就是我们最开始指定的Schedulers.newThread 即NewThreadScheduler线程调度器parent.setDisposable(scheduler.scheduleDirect(new SubscribeTask(parent)));
}

  • 第四步:进入ObservableCreate实例subscribe方法中,通过subscribeActual发起订阅,这里的source持有的是HomeActivity实例,直接调用subscribe方法,传入参数是构建的最顶层的发射器CreateEmitter实例

  • 第五步:上述的几个过程实际已经完成了订阅的过程,最后经过层层传递,持有的最顶层的是CreateEmitter实例,即我们最终的被观察者
发射过程

上述的过程已经完成了订阅过程,在最后订阅完成之后,最终会通过source.subscribe方法,其实就是调用HomeActivity实例的subscribe方法,完成元素发射

@Override
public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {for (int i = 0; i < 3; i++) {emitter.onNext(i);}emitter.onComplete();Log.d(TAG, "subscribe " + Thread.currentThread().getName());
}

我们在最顶层的被观察者里通过ObservableEmitter实例onNext方法完成元素的发射,最终又会通过一层一层的Observer转发到最原始的实现了ResourceObserver接口观察者中来

注意:

  • 这里的被观察者里的所有发射过程实际上都是在NewThreadScheduler线程调度器分配的线程里完成的
  • 发射的元素被传递到下层的ObservableObserveOn类中的ObserveOnObserver实例onNext方法,实际执行的是HandlerScheduler.HandlerWorkerschedule方法,最终就是通过我们持有的主线程的handler切换到主线程中

小结

整个创建过程订阅过程发射过程看起来山路十八弯,但是如果你一步一步跟进查看,会发现整个流程实际上是很清晰的,整个过程起点终点很明确,
而中间产生的一系列ObservableObserver你都可以看作是代理类,用来转发订阅以及最终的元素发射

这篇关于RxJava 2.x 之图解创建、订阅、发射流程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/723731

相关文章

JAVA封装多线程实现的方式及原理

《JAVA封装多线程实现的方式及原理》:本文主要介绍Java中封装多线程的原理和常见方式,通过封装可以简化多线程的使用,提高安全性,并增强代码的可维护性和可扩展性,需要的朋友可以参考下... 目录前言一、封装的目标二、常见的封装方式及原理总结前言在 Java 中,封装多线程的原理主要围绕着将多线程相关的操

Java进阶学习之如何开启远程调式

《Java进阶学习之如何开启远程调式》Java开发中的远程调试是一项至关重要的技能,特别是在处理生产环境的问题或者协作开发时,:本文主要介绍Java进阶学习之如何开启远程调式的相关资料,需要的朋友... 目录概述Java远程调试的开启与底层原理开启Java远程调试底层原理JVM参数总结&nbsMbKKXJx

Spring Cloud之注册中心Nacos的使用详解

《SpringCloud之注册中心Nacos的使用详解》本文介绍SpringCloudAlibaba中的Nacos组件,对比了Nacos与Eureka的区别,展示了如何在项目中引入SpringClo... 目录Naacos服务注册/服务发现引⼊Spring Cloud Alibaba依赖引入Naco编程s依

java导出pdf文件的详细实现方法

《java导出pdf文件的详细实现方法》:本文主要介绍java导出pdf文件的详细实现方法,包括制作模板、获取中文字体文件、实现后端服务以及前端发起请求并生成下载链接,需要的朋友可以参考下... 目录使用注意点包含内容1、制作pdf模板2、获取pdf导出中文需要的文件3、实现4、前端发起请求并生成下载链接使

Java springBoot初步使用websocket的代码示例

《JavaspringBoot初步使用websocket的代码示例》:本文主要介绍JavaspringBoot初步使用websocket的相关资料,WebSocket是一种实现实时双向通信的协... 目录一、什么是websocket二、依赖坐标地址1.springBoot父级依赖2.springBoot依赖

如何用java对接微信小程序下单后的发货接口

《如何用java对接微信小程序下单后的发货接口》:本文主要介绍在微信小程序后台实现发货通知的步骤,包括获取Access_token、使用RestTemplate调用发货接口、处理AccessTok... 目录配置参数 调用代码获取Access_token调用发货的接口类注意点总结配置参数 首先需要获取Ac

Java逻辑运算符之&&、|| 与&、 |的区别及应用

《Java逻辑运算符之&&、||与&、|的区别及应用》:本文主要介绍Java逻辑运算符之&&、||与&、|的区别及应用的相关资料,分别是&&、||与&、|,并探讨了它们在不同应用场景中... 目录前言一、基本概念与运算符介绍二、短路与与非短路与:&& 与 & 的区别1. &&:短路与(AND)2. &:非短

Java的volatile和sychronized底层实现原理解析

《Java的volatile和sychronized底层实现原理解析》文章详细介绍了Java中的synchronized和volatile关键字的底层实现原理,包括字节码层面、JVM层面的实现细节,以... 目录1. 概览2. Synchronized2.1 字节码层面2.2 JVM层面2.2.1 ente

什么是 Java 的 CyclicBarrier(代码示例)

《什么是Java的CyclicBarrier(代码示例)》CyclicBarrier是多线程协同的利器,适合需要多次同步的场景,本文通过代码示例讲解什么是Java的CyclicBarrier,感... 你的回答(口语化,面试场景)面试官:什么是 Java 的 CyclicBarrier?你:好的,我来举个例

Java使用Mail构建邮件功能的完整指南

《Java使用Mail构建邮件功能的完整指南》JavaMailAPI是一个功能强大的工具,它可以帮助开发者轻松实现邮件的发送与接收功能,本文将介绍如何使用JavaMail发送和接收邮件,希望对大家有所... 目录1、简述2、主要特点3、发送样例3.1 发送纯文本邮件3.2 发送 html 邮件3.3 发送带