一.RxJava

news2024/10/5 22:22:20

1.RxJava使用场景

RxJava核心思想

Rx思维:响应式编程,从起点到终点,中途不能断掉,并且可以在中途添加拦截.
生活中的例子:
起点(分发事件,我饿了)->下楼->去餐厅->点餐->终点(吃饭,消费事件)
程序中的例子:
起点(分发事件,点击登录)->登录API->请求服务器->获取响应码->终点(更新UI登录成功,消费事件)

总结:
有一个起点和一个终点,起点开始流向我们的“事件”,把事件流向终点,只不过在流向终点的过程中,可以增加拦截,拦截时可以对"事件进行改变",终点只关心他的上一个拦截.

Retrofit配合RxJava使用

Retrofit是对OkHttp网络请求框架的封装,我们将从OkHttp请求到数据的响应给到RxJava进行处理.

防抖

作用:防止重复操作.

举例1:
防止用户一直去请求获取验证码接口,黑客攻击1s内请求100次获取验证码接口;但是我们可以利用防抖思想,对其进行拦截,让他100次只做第一次处理,甚至一天之内最多只能请求5次获取验证码接口.
举例2:
我们点击某个按钮,可能存在重复点击的情况,我们可以利用RxBinding来防止重复点击做重复网络请求.

代码举例:

//TODO 5s内点击按钮只有第1次生效弹出Toast，超过5s后点击按钮才会第二次弹出Toast
RxView.clicks(findViewById(R.id.tv_fangdou))
      .throttleFirst(5, TimeUnit.SECONDS)//表示5s内只有第一次点击生效
      .subscribe(new Consumer<Object>() {
         @Override
         public void accept(Object o) throws Exception {
            Toast.makeText(UseActivity.this, "5s内只有第1次点击生效了", Toast.LENGTH_SHORT).show();
         }
      });
网络嵌套

先请求主数据,然后在根据主数据中的某个字段去请求子数据.
比如:我们先获取到某个用户的朋友列表,然后根据某个朋友的ID(如:张三)去查询朋友的信息.
解决方案:
可以采用flatMap这种方式去做处理,可以实现多个嵌套的网络请求在同一层级上面展示,不会像多层嵌套那样不易阅读.

doOnNext运用

频繁的在主线程与子线程之间切换来完成我们的业务.
举例:
银行项目存在频繁在主线程与子线程之间切换,可以采用doOnNext这种方式来解决.

2.RxJava模式与原理

标准观察者与RxJava观察者

标准观察者:
一个被观察者(Observable),可以有多个观察者(Observer),被观察者发生改变,所有订阅了他的观察者都能收到这个变化消息.
举例:
移动公司给所有用户发送一条短信,移动公司就作为被观察者,而所有的用户就作为观察者.

RxJava观察者流程:

  • 创建Observable
  • 创建Observer
  • 使用subscribe()订阅

分析RxJava观察者流程时,不按照上面的步骤来:

  1. 查看Observer源码
    • 定义了Observer接口的方法,比如:onSubscribe、onNext、onError、onComplete
    • 然后在使用的时候,直接创建自定义观察者,将new新建的Observer传入作为参数,重写实现方法.
  2. 了解Observable创建过程,分析源码
    • 调用create()方法会创建ObservableCreate对象
    • 将自定义(ObservableOnSubscribe)source资源传入ObservableCreate对象,作为一个参数
  3. 了解subscribe订阅过程,分析源码
    • 在订阅的过程中,首先执行观察者中onSubscribe方法,然后执行onNext/onError,最后执行onComplete方法
    • subscribe方法传入的参数是观察者Observer,调用者是被观察者Observable,有一个中间层发射器ObservableEmitter
    • 在执行subscribe方法时,最终会调用到Observable的实现类ObservableCreate的subscribeActual方法

标准观察者设计模式和RxJava观察者设计模式比较:

  • 在标准观察者设计模式中,是一个被观察者,对应多个观察者,并且被观察者发出改变通知后,所有的观察者才能观察到;耦合度高.
  • 在RxJava观察者设计模式中,是多个被观察者,一个观察者,并且需要起点和终点在订阅一次后,才发出改变通知,终点观察者才能观察到;耦合度低,也叫发布/订阅模式,也可以叫作观察者模式.

扩展知识:
RxJavaPlugins.setOnObservableAssembly()可以实现Hook,全局监听整个项目RxJava执行了哪些Observable;RxJavaPlugins就是一个用来做全局监听的工具类,里面包含了多种功能.

map变换操作符原理

map是用来做类型转换的,比如:将String类型转换成Integer类型,也可以将一个对象映射成另外一个对象.
代码举例:

.map(new Function<String, Integer>() {//通过map中传入Function,将String转换成Integer类型
   @Override
   public Integer apply(String s) throws Exception {
         //返回Integer类型
         return 9527;
   }
})

洋葱模型:

  1. 观察者(终点):
    new Observer作为参数传入订阅方法subscribe
  2. 订阅(subscribe(observer)):
    • 这个方法中会调用subscribeActual(observer)方法,由于加入了map拦截,所以由map方法返回的ObservableMap对象来调用subscribeActual方法.
    • ObservableMap.subscribeActual(observer)方法中做了哪些事情:
      public void subscribeActual(Observer<? super U> t) {
   //MapObserver作为Observer的包装(封装/包裹),该类持有了Observer成员变量actual
   //通过MapObserver<T, U>对类型进行转换,将T类型转换成U类型
   //这里的source是上一层传递过来的对象,而MapObserver是封装的是下一层的包裹(Observer)t
  source.subscribe(new MapObserver<T, U>(t, function));
}
    • 第一次包装,采用MapObserver进行包装,这里的参数t就是观察者Observer.
  3. map:
    作用:卡片拦截,在被观察者与观察者之间添加拦截,可以进行类型转换.
    流程分析:
    • 该方法返回包装类ObservableMap<T, U>,这个类可以将T类型转换成U类型并返回;
    • 最终体现在map方法参数Function类的apply方法中,将转换后的U类型返回.
  4. map(多重拦截):
    • 对上一次包裹Observer进行再次包装,采用的MapObserver进行包装.这里的参数t就是上一次包装生成的观察者Observer.
    • 最终由Observable的实现类ObservableCreate来调用该方法;
    • ObservableCreate.subscribeActual(observer)方法中做了哪些事情:
      protected void subscribeActual(Observer<? super T> observer) {
   //1.包装观察者,将观察者作为参数传入创建的发射器对象Emitter
   //由于我们做过拦截,所以这里传入的是包装后的Observer
   CreateEmitter<T> parent = new CreateEmitter<T>(observer);
   //2.调用onSubscribe方法,所以这个方法早于我们的执行流程
   observer.onSubscribe(parent);

   try {
      //3.自定义source开始订阅,并将发射器作为参数传入;
      //这个方法就会执行到我们自定义ObservableOnSubscribe的subscribe方法,这里就会去拆包裹
      source.subscribe(parent);
   } catch (Throwable ex) {
      Exceptions.throwIfFatal(ex);
      //如果报错走最外层包裹的onError方法
      parent.onError(ex);
   }
}
  5. create:
    创建ObservableCreate对象并返回,并将自定义ObservableOnSubscribe作为source参数传入.
    • 最后一次包装,采用CreateEmitter进行包装,代码如下:
      CreateEmitter<T> parent = new CreateEmitter<T>(observer);
  6. 自定义source:
    在自定义ObservableOnSubscribe的subscribe方法中,可以去执行onNext方法.通过查看源码流程走向,调用该方法后,就会依次调用每一个Observable实现类中内部包装类的onNext方法,最终调用到我们通过new创建的Observer中的onNext方法.

总结:

  1. 首先,RxJava的执行流程是从上往下的,依次创建Observable的实现类,最终调用订阅subscribe方法;
  2. 其次,调用完订阅subscribe方法后,就开始从下往上依次对观察者Observer封装包裹.
    说明:(source.subscribe(包装类(observer)),是封装包裹发起者)
    map方法的包装类是MapObserver,返回的实现类是ObservableMap对象;
    create方法的包装类是CreateEmitter,返回的实现类是ObservableCreate对象;
  3. 最后,我们在自定义source(ObservableOnSubscribe)的回调方法subscribe方法中,执行包装类的onNext或onComplete方法时,就会从上往下,依次从外向内开始拆包裹.
    说明:(包装类.onNext和onSubscribe是拆包裹发起者)
    依次执行当前包裹中封装的Observer的onNext或onComplete方法,最终执行到我们自定义Observer的onNext或onComplete方法,至此完成整个流程.

RxJava中map流程图如下:
请添加图片描述

背压

消费的速度跟不上生产的速度时,就存在背压的问题,我们可以采用Flowable替换Observable来解决背压的问题.

3.RxJava原理与自定义操作符

线程切换原理
  • subscribeOn() 给上面的代码分配线程
    Schedulers.io()最终会通过线程池来进行管理,因此后面执行的任务都是在子线程中进行.
    执行步骤:(Schedulers.io() == IoScheduler(持有线程池))
    • Schedulers.io()->(Scheduler)Schedulers.IO->new IOTask()->IOTask.run()->IoHolder.DEFAULT->new IoScheduler()->IoScheduler.start()->new CachedWorkerPool ->CachedWorkerPool类持有线程池变量:ScheduledExecutorService evictorService
      //构造函数中将线程池变量evictor赋值给成员变量evictorService
CachedWorkerPool(long keepAliveTime, TimeUnit unit, ThreadFactory threadFactory) {
         //省略无关代码
         ScheduledExecutorService evictor = null;
         if (unit != null) {
            evictor = Executors.newScheduledThreadPool(1, EVICTOR_THREAD_FACTORY);
         }
         //创建线程池并赋值给evictorService成员变量
         evictorService = evictor;
   }
  • observeOn() 给下面的代码分配线程
    AndroidSchedulers.mainThread()最终是通过Handler来完成子线程到主线程的切换,因此后面的代码可以更新UI.
    执行步骤:(AndroidSchedulers.mainThread() == HandlerScheduler(handler))
    • AndroidSchedulers.mainThread()->(Scheduler)Schedulers.MAIN_THREAD->MainHolder.DEFAULT->new HandlerScheduler(new Handler(Looper.getMainLooper()));
    • 这里传递了主线程的Looper对象给Handler,以确保代码执行在主线程中.

RxJava中onserveOn(AndroidSchedulers.mainThread())流程图:
在这里插入图片描述

扩展知识

观察者Observer的回调方法中会返回一个Disposable对象,我们在页面销毁的时候,需要判断这个对象Disposable是否销毁dispose了,如果没有销毁需要将其销毁.
这样的目的是为了防止内存泄漏,解决在页面销毁的时候,还在执行后面onNext和onComplete的逻辑操作的问题.
代码如下:

//使用结果赋值给一个成员变量,在生命周期结束时销毁他
private Disposable mDisposable;

private void doSomething() {
   disposable = Observable.create((ObservableOnSubscribe<String>) e -> {
      e.onNext("第一步");
      e.onNext("第二步");
      e.onComplete();
   }).subscribe(s -> {

   });
}

@Override
protected void onDestroy() {
   super.onDestroy();

   //结束生命周期销毁disposable
   if (mDisposable != null && !mDisposable.isDisposed()){
      mDisposable.dispose();
   }  
}
自定义RxView操作符

主要是通过自定义Observable继承自Observable,重写subscribeActual(observer)方法,然后在该方法中通过source.subscribe(包装类),将我们封装了下一层Observer的包装类传递进来封装包裹;包装类需要实现Disposable,达到可以被中断的目的,同时需要包含下一层包裹Observer变量,以便一层层调用每一层包裹Observer的方法.

总结:

整体实现流程

  1. 通过由上往下一层一层调用Observable的各种方法,创建出Observable的具体实现类.
    比如:通过调用create()方法,会返回ObservableCreate实现类,通过map()方法会返回ObservableMap实现类,通过observeOn()会返回OnservableObserveOn实现类;总之,就是在Observable后面拼接方法名称构成一个对象.
  2. 通过由下往上调用Observable.subscribe(observer)方法封装包裹,接着调用具体实现类中的subscribeActual(observer)方法来完成,最终将封装的包裹通过这种方式传入:
    source.subscribe(new 包装类(observer);
    参数说明:
    source:表示create方法中通过new传入的ObservableOnSubscribe对象
    observer:表示下一层封装的包裹,每一个包裹都是一个包装类,包装类都实现了Observer接口
    subscribe():方法表示ObservableOnSubscribe重写的subscribe(包装类)方法,里面的参数对应每一层的包装类;一般包装类调用onNext方法时,就会调用到包装类中的Observer对象onNext方法,依次达到一层一层往下拆包裹的目的.
  3. 通过由上往下依次调用每个具体实现类.包装类中的onNext方法时,就会直接调用调用observer.onNext方法,这里observer对象就是下一层包裹,因为每一层包裹都实现了Observer接口,以此达到了一层一层往下调用每一层包裹中onNext方法的目的.

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/553014.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Lucene（3）：Lucene全文检索的流程

Lucene（3）：Lucene全文检索的流程

1 Lucene准备 Lucene可以在官网上下载&#xff1a;Apache Lucene - Welcome to Apache Lucene。我们使用的是7.7.2版本&#xff0c;文件位置如下图&#xff1a; 使用这三个文件的jar包&#xff0c;就可以实现lucene功能 2 开发环境准备 JDK&#xff1a; 1.8 &#xff08;Luce…
阅读更多...
python 面向对象--类,对象,属性,方法,魔法方法

python 面向对象--类,对象,属性,方法,魔法方法

1.理解面向对象思想 面向过程思想: 遇到问题,分析步骤.按照步骤解决问题.(复杂,重复) 面向对象思想: 遇到问题,找到能解决问题的对象去解决.(简单,复用) 2.类和对象 # 定义类的格式: # class 类名(): # 代码 # ......class Student(): ​def study(self):print(学生好…
阅读更多...
【连续介质力学】Voigt符号

【连续介质力学】Voigt符号

Voigt符号 一个对称二阶张量有6个独立的分量&#xff0c;那么就可以将他表示成列向量的形式&#xff1a; 这种表示方式为Voigt符号&#xff0c;也可以将二阶张量表示成&#xff1a; 正如minor对称的四阶张量C&#xff0c; C i j k l C j i k l C i j l k C j i l k C_{ij…
阅读更多...
hive函数

hive函数

函数 Hive的函数分为两大类∶内置函数(Built-in Functions )、用户定义函数UDF (User-Defined Functions ) . 内置函数可分为︰数值类型函数、日期类型函数、字符串类型函数、集合函数、条件函数等; 用户定义函数根据输入输出的行数可分为3类:UDF、UDAF、UDTF。 UDF:普通函…
阅读更多...
一图看懂 charset_normalizer 模块：字符集规范化，真正的第一个通用字符集检测器，资料整理+笔记（大全）

一图看懂 charset_normalizer 模块：字符集规范化，真正的第一个通用字符集检测器，资料整理+笔记（大全）

本文由 大侠(AhcaoZhu)原创&#xff0c;转载请声明。 链接: https://blog.csdn.net/Ahcao2008 一图看懂 charset_normalizer 模块&#xff1a;字符集规范化&#xff0c;真正的第一个通用字符集检测器&#xff0c;资料整理笔记&#xff08;大全&#xff09; &#x1f9ca;摘要&a…
阅读更多...
AI人工智能决策树分类器的原理、优缺点、应用场景和实现方法

AI人工智能决策树分类器的原理、优缺点、应用场景和实现方法

决策树分类器&#xff08;Decision Tree Classifier&#xff09;是一种常用的机器学习算法&#xff0c;它被广泛应用于分类和回归问题中。在人工智能&#xff08;Artificial Intelligence&#xff0c;简称AI&#xff09;领域中&#xff0c;决策树分类器是一种简单而有效的算法&…
阅读更多...
DETR3D 论文学习

DETR3D 论文学习

1. 解决了什么问题&#xff1f; 对于低成本自动驾驶系统&#xff0c;仅凭视觉信息进行 3D 目标检测是非常有挑战性的。目前的多相机 3D 目标检测方法有两类&#xff0c;一类直接对单目图像做预测&#xff0c;没有考虑 3D 场景的结构或传感器配置。这类方法需要多步后处理&…
阅读更多...
tcpdump 抓包和记录、tshark 过滤抓包

tcpdump 抓包和记录、tshark 过滤抓包

目录 tcpdump 一、包名 二、可用参数 tcpdump -nn tcpdump -nn -i 网卡名 —— 指定显示的网卡 tcpdump -nn -i 网卡名 port 端口名 —— 指定显示的端口 tcpdump -nn -i 网卡名 not port 端口名 —— 排除指定的端口不显示 tcpdump -nn -i …
阅读更多...
JavaWeb15 - web 应用常用功能 -文件上传下载

JavaWeb15 - web 应用常用功能 -文件上传下载

1. 基本介绍 文件的上传和下载&#xff0c;是常见的功能。后面项目就使用了文件上传下载。如果是传输大文件&#xff0c;一般用专门工具或者插件文件上传下载需要使用到两个包 , 需要导入说明: 2. 文件上传 2.1 文件上传的基本原理 ● 文件上传原理示意图, 一图胜千言 …
阅读更多...
进程调度策略

进程调度策略

1 先进先出 FIFO 2 最短任务优先 SJF https://blog.51cto.com/u_13064014/5079546?btotalstatistic
阅读更多...
机器学习和大数据：如何利用机器学习算法分析和预测大数据

机器学习和大数据：如何利用机器学习算法分析和预测大数据

第一章&#xff1a;引言 近年来&#xff0c;随着科技的迅速发展和数据的爆炸式增长&#xff0c;大数据已经成为我们生活中无法忽视的一部分。大数据不仅包含着海量的信息&#xff0c;而且蕴含着无数的商机和挑战。然而&#xff0c;如何从这些海量的数据中提取有价值的信息并做…
阅读更多...
【CANN训练营0基础赢满分秘籍】昇腾AI入门课（PyTorch）

【CANN训练营0基础赢满分秘籍】昇腾AI入门课（PyTorch）

1 昇腾AI全栈架构 昇腾计算产业是基于昇腾系列处理器和基础软件构睫的全栈Al计算基础设施&#xff0e;行业应用及服务&#xff0c;包括昇腾系列处理器、Atlas系列硬件、CANN (Compute Architecture for Neural Networks&#xff0c;异构计算架构》、Al计算框架、应用使能、全流…
阅读更多...
LeetCode_Day4 | 好有难度的一个环形链表啊(在最后)！

LeetCode_Day4 | 好有难度的一个环形链表啊(在最后)！

LeetCode_链表 24. 两两交换链表中的节点1.题目描述2.虚拟头节点法1.思路2.代码实现 3.递归法1.思路2.代码实现 19. 删除链表的倒数第n个节点1.题目描述2.思路&#xff1a;双指针法3.代码实现 面试题 02.07. 链表相交1.题目描述2.思路3.代码实现 142. 环形链表 II1. 题目描述2.…
阅读更多...
【SNAT和DNAT的原理与应用】

【SNAT和DNAT的原理与应用】

目录 一、SNAT原理与应用1、SNAT概述2、SNAT的应用环境3、进行SNAT转换后的情况 二、SNAT实验三、DNAT1、DNAT策略概述2、DNAT 实验 一、SNAT原理与应用 1、SNAT概述 SNAT 应用环境&#xff1a;局域网主机共享单个公网IP地址接入Internet&#xff08;私有不能早Internet中正常…
阅读更多...
网络知识点之-静态路由

网络知识点之-静态路由

静态路由&#xff08;英语&#xff1a;Static routing&#xff09;是一种路由的方式&#xff0c;路由项&#xff08;routing entry&#xff09;由手动配置&#xff0c;而非动态决定。与动态路由不同&#xff0c;静态路由是固定的&#xff0c;不会改变&#xff0c;即使网络状况已…
阅读更多...
进程控制(总)

进程控制(总)

目录 进程创建 fork函数初识&#xff1a; 写时拷贝&#xff1a; fork常规用法&#xff1a; fork调用失败的原因&#xff1a; 进程终止 进程退出场景&#xff1a; 进程常见退出方法&#xff1a; _exit函数 exit函数 return退出&#xff1a; 进程等待 进程等待的必…
阅读更多...
UE5实现模型压平效果

UE5实现模型压平效果

文章目录 1.实现目标2.实现过程2.1 实现原理2.2 蓝图实现2.3 闪面问题与压平精度3.参考资料1.实现目标 模型压平功能是GIS系统中的一个常用功能，可以用于模型的替换，数据的对比等。本文在UE5中通过修改材质的方式实现，实现模型压平的功能，包括常规建模的StaticMesh，以及C…
阅读更多...
2023年网络安全竞赛——Windows操作系统渗透测试Server2124

2023年网络安全竞赛——Windows操作系统渗透测试Server2124

任务五：Windows操作系统渗透测试 任务环境说明： 服务器场景：Server2124（关闭链接）服务器场景操作系统：Windows（版本不详）通过本地PC中渗透测试平台Kali对服务器场景Server2124进行系统服务及版本扫描渗透测试，并将该操作显示结果中1433端口对应的服务版本信息作为Fla…
阅读更多...
【C++ 学习 ⑥】- C++ 动态内存管理详解

【C++ 学习 ⑥】- C++ 动态内存管理详解

目录 一、new 表达式和 delete 表达式的工作机理 二、operator new 和 operator delete 函数 2.1 - 标准库定义 2.2 - 重载 三、定位 new 表达式 四、常见面试题 4.1 - malloc/free 和 new/delete 的区别 4.2 - 内存泄漏 在 C 中&#xff0c;new 和 delete 既是关键字&…
阅读更多...
Linux系统c语言socket实现TCP通信

Linux系统c语言socket实现TCP通信

socket通信用到的函数 int socket( int af, int type, int protocol); af&#xff1a;一个地址描述。仅支持AF_INET格式&#xff0c;也就是说ARPA Internet地址格式。 type&#xff1a;指定socket类型。新套接口的类型描述类型&#xff0c;如TCP&#xff08;SOCK_STREAM&#…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023