Rx思维:响应式编程,从起点到终点,中途不能断掉,并且可以在中途添加拦截.
生活中的例子:
起点(分发事件,我饿了)->下楼->去餐厅->点餐->终点(吃饭,消费事件)
程序中的例子:
起点(分发事件,点击登录)->登录API->请求服务器->获取响应码->终点(更新UI登录成功,消费事件)
总结:
有一个起点和一个终点,起点开始流向我们的“事件”,把事件流向终点,只不过在流向终点的过程中,可以增加拦截,拦截时可以对"事件进行改变",终点只关心他的上一个拦截.
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
这种方式来解决.
标准观察者:
一个被观察者(Observable
),可以有多个观察者(Observer
),被观察者发生改变,所有订阅了他的观察者都能收到这个变化消息.
举例:
移动公司给所有用户发送一条短信,移动公司就作为被观察者,而所有的用户就作为观察者.
RxJava观察者流程:
分析RxJava观察者流程时,不按照上面的步骤来:
标准观察者设计模式和RxJava观察者设计模式比较:
扩展知识:
RxJavaPlugins.setOnObservableAssembly()
可以实现Hook
,全局监听整个项目RxJava
执行了哪些Observable
;RxJavaPlugins
就是一个用来做全局监听的工具类,里面包含了多种功能.
map是用来做类型转换的,比如:将String类型转换成Integer类型,也可以将一个对象映射成另外一个对象.
代码举例:
.map(new Function<String, Integer>() {
//通过map中传入Function,将String转换成Integer类型
@Override
public Integer apply(String s) throws Exception {
//返回Integer类型
return 9527;
}
})
洋葱模型:
观察者
(终点
):new Observer
作为参数传入订阅方法subscribe
订阅(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
.map
:ObservableMap<T, U>
,这个类可以将T
类型转换成U
类型并返回;map
方法参数Function
类的apply
方法中,将转换后的U
类型返回.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);
}
}
create
:ObservableCreate
对象并返回,并将自定义ObservableOnSubscribe
作为source
参数传入.
CreateEmitter
进行包装,代码如下:CreateEmitter<T> parent = new CreateEmitter<T>(observer);
自定义source
:ObservableOnSubscribe
的subscribe
方法中,可以去执行onNext
方法.通过查看源码流程走向,调用该方法后,就会依次调用每一个Observable
实现类中内部包装类的onNext
方法,最终调用到我们通过new
创建的Observer
中的onNext
方法.总结:
- 首先,RxJava的执行流程是从上往下的,依次创建Observable的实现类,最终调用订阅subscribe方法;
- 其次,调用完订阅subscribe方法后,就开始从下往上依次对观察者Observer封装包裹.
说明:(source.subscribe(包装类(observer)),是封装包裹发起者
)
map方法的包装类是MapObserver,返回的实现类是ObservableMap对象;
create方法的包装类是CreateEmitter,返回的实现类是ObservableCreate对象;- 最后,我们在自定义source(
ObservableOnSubscribe
)的回调方法subscribe方法中,执行包装类的onNext或onComplete方法时,就会从上往下,依次从外向内开始拆包裹.
说明:(包装类.onNext和onSubscribe是拆包裹发起者
)
依次执行当前包裹中封装的Observer的onNext或onComplete方法,最终执行到我们自定义Observer的onNext或onComplete方法,至此完成整个流程.
RxJava中map流程图如下:
消费的速度跟不上生产的速度时,就存在背压的问题,我们可以采用Flowable
替换Observable
来解决背压的问题.
subscribeOn()
给上面的代码分配线程Schedulers.io()
最终会通过线程池来进行管理,因此后面执行的任务都是在子线程中进行.Schedulers.io() == IoScheduler(持有线程池)
)
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)
)
HandlerScheduler(new Handler(Looper.getMainLooper()))
;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();
}
}
主要是通过自定义Observable
继承自Observable
,重写subscribeActual(observer)
方法,然后在该方法中通过source.subscribe(包装类)
,将我们封装了下一层Observer
的包装类
传递进来封装包裹;包装类需要实现Disposable
,达到可以被中断的目的,同时需要包含下一层包裹Observer
变量,以便一层层调用每一层包裹Observer
的方法.
总结:
整体实现流程
- 通过由上往下一层一层调用Observable的各种方法,创建出Observable的具体实现类.
比如:通过调用create()方法,会返回ObservableCreate实现类,通过map()方法会返回ObservableMap实现类,通过observeOn()会返回OnservableObserveOn实现类;总之,就是在Observable后面拼接方法名称构成一个对象.- 通过由下往上调用Observable.subscribe(observer)方法封装包裹,接着调用具体实现类中的subscribeActual(observer)方法来完成,最终将封装的包裹通过这种方式传入:
source.subscribe(new 包装类(observer);
参数说明:
source:
表示create方法中通过new传入的ObservableOnSubscribe对象
observer:
表示下一层封装的包裹,每一个包裹都是一个包装类,包装类都实现了Observer接口
subscribe():
方法表示ObservableOnSubscribe重写的subscribe(包装类
)方法,里面的参数对应每一层的包装类;一般包装类调用onNext方法时,就会调用到包装类中的Observer对象onNext方法,依次达到一层一层往下拆包裹的目的.- 通过由上往下依次调用每个
具体实现类
.包装类
中的onNext方法时,就会直接调用调用observer.onNext方法,这里observer对象就是下一层包裹,因为每一层包裹都实现了Observer接口,以此达到了一层一层往下调用每一层包裹中onNext方法的目的.
文章浏览阅读8k次,点赞2次,收藏6次。QT设置QLabel中字体的颜色其实,这是一个比较常见的问题。大致有几种做法:一是使用setPalette()方法;二是使用样式表;三是可以使用QStyle;四是可以在其中使用一些简单的HTML样式。下面就具体说一下,也算是个总结吧。第一种,使用setPalette()方法如下:QLabel *label = new QLabel(tr("Hello Qt!"));QP_qolable 字体颜色
文章浏览阅读3.7k次。使用C# 作为开发语言,将pb文件转换为cs文件的时候相信很多人都会遇到一个很棘手的问题,那就是protoc3环境下,import Timestamp的问题,在头部 import “google/protobuf/timestamp.proto”;的时候会抛异常:google/protobuf/timestamp.proto" was not found or had errors;解决办法【博主「pamxy」的原创文章的分享】:(注:之后才发现,不需要添加这个目录也可以,因为timestamp.p_import "google/protobuf/timestamp.proto" was not found or had errors.
文章浏览阅读4.1w次,点赞9次,收藏98次。一、准备工具: 1. app:VNET(抓包用)、京东; 安卓手机需要下载VNET软件。下载官网:https://www.vnet-tech.com/zh/ 2. 已安装部署好的青龙面板;二、抓包wskey: 1. 打开已下载的VNET软件,第一步先安装CA证书; 点击右下角三角形按钮(开始抓包按钮),会提示安装证书,点击确定即可,app就会将CA证书下载至手机里,随后在手机设置里进行安装,这里不同手机可能安装位置不同,具体..._jd_wsck
文章浏览阅读2.9k次,点赞7次,收藏3次。本文针对mybatis-plus自动填充第一次更新能正常填充,第二次更新无法自动填充问题。????mybatis-plus自动填充:当要填充的字段不为空时,填充无效问题的解决????先上一副官方的图:取自官方:https://mp.baomidou.com/guide/auto-fill-metainfo.html第三条注意事项为自动填充失效原因:MetaObjectHandler提供的默认方法的策略均为:如果属性有值则不覆盖,如果填充值为null则不填充以官方案例为例:```java_mybatisplus插入不放为空的字段
文章浏览阅读1w次,点赞25次,收藏94次。利用 Application Complier 完成MATLAB转exe文件_matlab exe
文章浏览阅读137次。近期项目需要研究paypal支付,官网上的指导写的过于复杂,可能是老外的思维和中国人不一样吧。难得是发现下面这篇文章:http://www.androidhive.info/2015/02/Android-integrating-paypal-using-PHP-MySQL-part-1/在这篇文章的基础上,查看SDK简化了代码,给出下面这个例子,..._paypal支付集成到anroid应用中
文章浏览阅读2.3k次,点赞29次,收藏52次。nuScenes 数据集 (pronounced /nu:ːsiː:nz/) 是由 Motional (以前称为 nuTonomy) 团队开发的自动驾驶公共大型数据集。nuScenes 数据集的灵感来自于开创性的 KITTI 数据集。nuScenes 是第一个提供自动驾驶车辆整个传感器套件 (6 个摄像头、1 个 LIDAR、5 个 RADAR、GPS、IMU) 数据的大型数据集。与 KITTI 相比,nuScenes 包含的对象注释多了 7 倍。_nuscense数据集
文章浏览阅读535次。我正在实现一个程序,该程序可以侦听特定主题,并在ESP8266发布新消息时对此做出反应.从ESP8266收到新消息时,我的程序将触发回调并执行一系列任务.我在回调函数中发布了两条消息,回到了Arduino正在侦听的主题.但是,仅在函数退出后才发布消息.谢谢您的所有宝贵时间.我试图在回调函数中使用loop(1),超时为1秒.该程序将立即发布该消息,但似乎陷入了循环.有人可以给我一些指针如何在我的回调..._python 函数里面 mqtt调用publish方法 没有效果
文章浏览阅读3.4w次,点赞16次,收藏81次。微软出来了win11预览版系统,很多网友给自己的电脑下载安装尝鲜,不过因为是测试版可能会有比较多bug,又只有英文,有些网友使用起来并不顺畅,因此想要将win11退回win10系统。那么win11怎么装回win10系统呢?今天小编就教下大家win11退回win10系统的方法。方法一:1、首先点击开始菜单,在其中找到“设置”2、在设置面板中,我们可以找到“更新和安全”3、在更新和安全中,找到点击左边栏的“恢复”4、恢复的右侧我们就可以看到“回退到上版本的win10”了。方法二:_安装win10后卸载win11
文章浏览阅读3.3k次,点赞2次,收藏3次。数据定义_sql server菜鸟教程
文章浏览阅读1.9k次。1. 两数之和给定一个整数数组 nums 和一个目标值 target,请你在该数组中找出和为目标值的那 两个 整数,并返回他们的数组下标。你可以假设每种输入只会对应一个答案。但是,你不能重复利用这个数组中同样的元素。示例:给定 nums = [2, 7, 11, 15], target = 9因为 nums[0] + nums[1] = 2 + 7 = 9所以返回 [0, 1]方法一..._给定一个浮点数数组nums(逗号分隔)和一个浮点数目标值target(与数组空格分隔),请
文章浏览阅读152次。提高性能有如下方法1、Cython,用于合并python和c语言静态编译泛型2、IPython.parallel,用于在本地或者集群上并行执行代码3、numexpr,用于快速数值运算4、multiprocessing,python内建的并行处理模块5、Numba,用于为cpu动态编译python代码6、NumbaPro,用于为多核cpu和gpu动态编译python代码为了验证相同算法在上面不同实现..._np.array 测试gpu性能