在开发中很多时候会有这样的场景，同一个界面有多个请求，而且要在这几个请求都成功返回的时候再去进行下一操作，对于这种场景，如何来设计请求操作呢？今天我们就来讨论一下有哪几种方案。...分析： 在网络请求的开发中，经常会遇到两种情况，一种是多个请求结束后统一操作，在一个界面需要同时请求多种数据，比如列表数据、广告数据等，全部请求到后再一起刷新界面。...很多开发人员为了省事，对于网络请求必须满足一定顺序这种情况，一般都是嵌套网络请求，即一个网络请求成功之后再请求另一个网络请求，虽然采用嵌套请求的方式能解决此问题，但存在很多问题，如：其中一个请求失败会导致后续请求无法正常进行...、多个请求在时间上没有复用，即无并发性。...结论 在开发过程中，我们应尽量避免发送同步请求；假设我们一个页面需要同时进行多个请求，他们之间倒是不要求顺序关系，但是要求等他们都请求完毕了再进行界面刷新或者其他什么操作。
该例子将结合Retrofit 和 RxJava 进行讲解 具体请看文章：Android RxJava 实际应用讲解：（无条件）网络请求轮询 3.2 变换操作符 作用 对事件序列中的事件 / 整个事件序列...该例子将结合Retrofit 和 RxJava 进行讲解 具体请看文章：Android RxJava 实际应用讲解：网络请求嵌套回调 3.3 组合 / 合并操作符 作用 组合 多个被观察者（Observable...） & 合并需要发送的事件 应用场景 组合多个被观察者 合并多个事件 发送事件前追加发送事件 统计发送事件数量 类型 根据上述应用场景，常见的组合 / 合并操作符 主要有： 具体操作符...中，条件 / 布尔操作符的类型包括： 具体操作符详解 Android RxJava：详解 条件 / 布尔操作符 至此，关于RxJava 2 中的操作符讲解完毕。...总结 本文主要对 RxJava2 中常用的所有类型操作符进行了详细介绍，下面用1张图进行总结
该例子将结合Retrofit 和 RxJava 进行讲解 具体请看文章：Android RxJava 实际应用讲解：（无条件）网络请求轮询 3.2 变换操作符 作用 对事件序列中的事件 /...该例子将结合Retrofit 和 RxJava 进行讲解 具体请看文章：Android RxJava 实际应用讲解：网络请求嵌套回调 3.3 组合 / 合并操作符 作用 组合 多个被观察者（...Observable） & 合并需要发送的事件 应用场景 组合多个被观察者 合并多个事件 发送事件前追加发送事件 统计发送事件数量 类型 根据上述应用场景，常见的组合 / 合并操作符 主要有：...中，条件 / 布尔操作符的类型包括： 具体操作符详解 Android RxJava：详解 条件 / 布尔操作符 至此，关于RxJava 2 中的操作符讲解完毕。...总结 本文主要对 RxJava2 中常用的所有类型操作符进行了详细介绍，下面用1张图进行总结 接下来的时间，我将持续推出 Android中 Rxjava 2.0 的一系列文章，包括原理、操作符、应用场景
Subscription s) { System.out.println("onSubscribe"); // 在onSubscribe中，...我们需要调用request去请求资源，参数就是要请求的数量，一般如果不限制请求数量，可以 // 写成Long.MAX_VALUE。...A 和发射器 B 各取出一个事件来组合，并且一个事件只能被使用一次，组合的顺序是严格按照事件发送的顺序来进行的，所以上面截图中，可以看到，1 永远是和 A 结合的，2 永远是和 B 结合的。...最终接收器收到的事件数量是和发送器发送事件最少的那个发送器的发送事件数目相同，所以如截图中，5 很孤单，没有人愿意和它交往，孤独终老。...它可以把一个发射器 Observable 通过某种方法转换为多个 Observables，然后再把这些分散的 Observables装进一个单一的发射器 Observable。
目前有两个版本RxJava1和RxJava2,推荐使用RxJava2,RxJava1已经停止支持了 ReactiveX即Reactive Extensions，它通过可观测的序列，实现了组合异步和事件驱动...初识命令式编程和响应式编程 实际项目中希望数据一发生变化就通知需要知道这个变化的对象，这可以通过观察者模式实现，数据变化观察者立马就可以对变化做出"响应" 初识函数式编程 从java8中的...void call(User user) { LOG.info("justVerify just user age:{}", user.getAge()); } }); 复制代码 RxJava2...中的部分案例 Observable.just(1).subscribe(new Consumer() { @Override public void accept...可以反过来限制生产的速度，比如把所有生产的数据都缓存起来，消费者自己来取，比如只有有请求的时候才给数据，没有请求的数据全部扔掉
本系列文章主要基于 Rxjava 2.0 接下来的时间，我将持续推出 Android中 Rxjava 2.0 的一系列文章，包括原理、操作符、应用场景、背压等等 ，有兴趣可以继续关注Carson_Ho...2个服务器获取数据 & 统一展示 3.1 采用 Merge（）操作符 具体实现 关于操作符Merge（） 的使用请看文章：Android RxJava：组合 / 合并操作符 详细教程 // 用于存放最终展示的数据...实战系列：合并数据源 3.2 采用Zip（）操作符 关于操作符Zip（） 的使用请看文章：Android RxJava：组合 / 合并操作符 详细教程 功能说明 在该例中，我将结合结合 Retrofit...总结 本文主要讲解了 Rxjava的实际开发需求场景：合并数据源需求 ，并结合Retrofit 与RxJava 实现 下面我将结合 实际场景应用 & Rxjava的相关使用框架（如Retrofit、Eventbus...） ，继续对 Android中 Rxjava 的实际开发需求场景进行深入讲解 ，有兴趣可以继续关注Carson_Ho的安卓开发笔记 请帮顶 / 评论点赞！
MVVM数据持久化 之前我们分别介绍了MVVM框架的悲剧，项目搭建以及网络请求，接下来在这篇文章当中，我们来聊一聊MVVM数据持久化的问题，也就是我们常说的缓存 Room Room持久库提供了一个SQLite...在注释中包含与数据库相关联的实体列表。 包含一个具有0个参数的抽象方法，并返回用@Dao注释的类。...三者关系图 加入依赖 以上简单的介绍了一下Room 下面我们着重介绍如何在我们的框架当中使用 首先加入依赖 implementation 'android.arch.persistence.room...如果你的entity有一个组合主键，你可以使用@Entity注解的primaryKeys属性。 2.tableName Room默认把类名作为数据库的表名。...要为一个entity添加索引，在@Entity注解中添加indices属性，列出你想放在索引或者组合索引中的字段。 有时候，某个字段或者几个字段必须是唯一的。
allOf()方法所返回的CompletableFuture，并不能组合前面多个CompletableFuture的计算结果。...于是我们借助Java 8的Stream来组合多个future的结果。...anyOf 和 acceptEither、applyToEither的区别在于，后两者只能使用在两个future中，而anyOf可以使用在多个future中。...) 支持 支持 支持 支持 支持 支持 不支持 Flowable(RxJava2) 支持 支持 支持 支持 支持 支持 支持 五....productid=xxx），需要调用多个服务来处理这一个请求并返回结果。这里可能会涉及到并发编程，我们完全可以使用Java 8的CompletableFuture或者RxJava来实现。
同样的我们来看看如果你升级到RxJava2，改如果写呢？...image.png 3.3组合操作符 含义：将多个被观察组合 & 将它们需要发送的事件合拼。...应用种类 组合多个被观察者，合并事件 concatArray()(发送事件--串行) concatDelayError() mergeArray()(发送事件--并发) mergeArrayDelayError...() 组合多个被观察者，组合为一个被观察者 zip() combinelatest() 发送事件前追加其他事件 startWithArray() startWith() 组合多个事件为一个事件...reduce collect() 汇总发送事件数量 count() concatArray() concatArray可以将多个观察者组合在一起，然后按照之前发送顺序发送事件。
也就是说多个观察者对应一个被观察者。字看累了来看图： ? 其实在android中也有很多自带的观察者模式。最明显的莫过于点击事件。说个最简单的例子，点击按钮后弹一个吐司。...但这在rxjava2中是不存在的。不信你试试？分分钟给你来一个NullPointerExpection。 Function相关的在rxjava1中，我们有各种Func1，Func2.........我们知道在Rxjava1中Observable对backpressure是支持的。但在Rxjava2中Observable取消了对backpressure的支持。...组合操作符 merge merge是将多个操作符合并到一个Observable中进行发射，merge可能让合并到Observable的数据发生错乱。...那么怎么通过链式调用实现网络请求呢？不急，我们喝杯茶，接着往下看。
如果后发出去的’AB’请求先返回, ‘A’请求后返回,那么’A’请求后的结果将会覆盖’AB’请求的结果. 从而导致搜索结果不正确....这是官方文档给出的解释，从解释中我们也不难看出他的用法。那么下面我在实例中去使用吧！...---- 防止按钮重复(连续)点击 在实际应用中可能在提交信息，登录的时候每次点击按钮就会发送网络请求，当网络比较慢的时候或是其他原因已经请求网路只是返回的数据比较慢，当我们连续点击就会连续的发送请求，...user); mList.add(user1); return Observable.just(mList); } /** * web数据(从网络中请求...推荐文章： Rxjava2 RxJava2操作符 RxJava/RxAndroid 使用实例实践 Rxjava2我觉得关于rxjava2这个系列真的非常好很值得学习 代码地址
2个服务器获取数据 & 统一展示 3.1 采用 Merge（）操作符 具体实现 关于操作符Merge（） 的使用请看文章：Android RxJava：组合 / 合并操作符 详细教程 // 用于存放最终展示的数据...Log.d(TAG, result ); } }); 测试结果 Demo地址 Carson_Ho的Github地址 = RxJava2...实战系列：合并数据源 3.2 采用Zip（）操作符 关于操作符Zip（） 的使用请看文章：Android RxJava：组合 / 合并操作符 详细教程 功能说明 在该例中，我将结合结合 Retrofit...在 Gradle加入Retrofit库的依赖 build.gradle dependencies { // Android 支持 Rxjava // 此处一定要注意使用RxJava2的版本 compile...Android 支持 Retrofit compile 'com.squareup.retrofit2:retrofit:2.1.0' // 衔接 Retrofit & RxJava // 此处一定要注意使用RxJava2
感兴趣的同学可以阅读上一篇文章 RxJava2 实战知识梳理(5) - 简单及进阶的轮询操作。...1.2 示例代码 在下面的例子中，我们一共发起了五次请求，也就是subscribe中的代码，其中前四次请求都调用onError方法通知下游请求失败，同时带上了自定义的错误信息wait_short...和wait_long，第五次才返回正确的数据。...在Function函数中，必须对输入的 Observable进行处理，这里我们使用的是flatMap操作符接收上游的数据，对于flatMap的解释，大家可以参考 RxJava2 实战知识梳理...2.2 retryWhen 和 repeatWhen 对比 在 RxJava2 实战知识梳理(5) - 简单及进阶的轮询操作 中我们已经对repeatWhen进行了介绍，让我们再来看一下它的原理图
RxJava 实际应用讲解：网络请求出错重连（结合Retrofit） 3.4 网络请求嵌套回调 背景 需要进行嵌套网络请求：即在第1个网络请求成功后，继续再进行一次网络请求 如 先进行 用户注册 的网络请求...中的变换操作符FlatMap（）实现嵌套网络请求 具体实现 Android RxJava 实际应用讲解：网络请求嵌套回调 3.5 从磁盘 / 内存缓存中 获取缓存数据 需求场景 功能说明...对于从磁盘 / 内存缓存中 获取缓存数据 的功能逻辑如下： 具体实现 Android RxJava 实际应用讲解：从磁盘 / 内存缓存中 获取缓存数据 3.6 合并数据源 需求场景...功能说明 即，同时向2个数据源获取数据 -> 合并数据 -> 统一展示到客户端 具体实现 Android RxJava 实际应用讲解：合并数据源 3.7 联合判断 需求场景 需要同时对多个事件进行联合判断...总结 本文主要对 RxJava2 中常用的实际开发应用场景讲解进行了详细介绍，下面用1张图进行总结
：网络请求出错重连（结合Retrofit） 3.4 网络请求嵌套回调 背景 需要进行嵌套网络请求：即在第1个网络请求成功后，继续再进行一次网络请求 如 先进行 用户注册 的网络请求, 待注册成功后回再继续发送...中的变换操作符FlatMap（）实现嵌套网络请求 具体实现 Android RxJava 实际应用讲解：网络请求嵌套回调 3.5 从磁盘 / 内存缓存中 获取缓存数据 需求场景 功能说明...对于从磁盘 / 内存缓存中 获取缓存数据 的功能逻辑如下： 具体实现 Android RxJava 实际应用讲解：从磁盘 / 内存缓存中 获取缓存数据 3.6 合并数据源 需求场景 功能说明...即，同时向2个数据源获取数据 -> 合并数据 -> 统一展示到客户端 具体实现 Android RxJava 实际应用讲解：合并数据源 3.7 联合判断 需求场景 需要同时对多个事件进行联合判断...总结 本文主要对 RxJava2 中常用的实际开发应用场景讲解进行了详细介绍，下面用1张图进行总结 接下来，我将持续推出 Android中 Rxjava 2.0 的一系列文章，包括原理、操作符、应用场景
作用 组合 多个被观察者（Observable） & 合并需要发送的事件 2. 类型 RxJava 2 中，常见的组合 / 合并操作符 主要有： 下面，我将对每个操作符进行详细讲解 3....，即依赖不能同时存在 } 3.1 组合多个被观察者 该类型的操作符的作用 = 组合多个被观察者 concat（） / concatArray（） 作用 组合多个被观察者一起发送数据，合并后 按发送顺序串行执行...该类型的操作符主要是对多个被观察者中的事件进行合并处理。...4.1 获取缓存数据 即从缓存中（磁盘缓存 & 内存缓存）获取数据；若缓存中无数据，才通过网络请求获取数据 具体请看文章：Android RxJava 实际应用讲解：从磁盘 / 内存缓存中 获取缓存数据...总结 下面，我将用一张图总结 RxJava2 中常用的组合 / 合并操作符
} else if (this is ParseException) { // ParseException异常表明请求成功，但是数据不正确 this.message.../串行 5.1、协程串行多个请求 假设，我们有这么一种场景，首先获取Student对象，随后通过studentId获取学生的家庭成员列表，后者依赖于前者，这是典型的串行场景 看看通过协程如何解决这个问题...串行请求中，只要其中一个请求出现异常，协程便会关闭（同时也会关闭请求），停止执行剩下的代码，接着走异常回调 5.2、协程并行多个请求 请求并行，在现实开发中，也是家常便饭，在一个Activity中，我们往往需要拿到多种数据来展示给用户...如果想多个请求互不影响，就可以使用上面介绍的onErrorReturn、onErrorReturnItem操作符，出现异常时，给出一个默认对象，又或者使用tryAwait操作符获取返回值，出现异常时，返回...RxHttp + RxJava方式发送请求，就可以在annotationProcessorOptions标签中的rxhttp_rxjava参数来配置RxJava大版本，可传入RxJava2或RxJava3
需求场景 1.1 背景 需要进行嵌套网络请求：即在第1个网络请求成功后，继续再进行一次网络请求 如 先进行 用户注册 的网络请求, 待注册成功后回再继续发送 用户登录 的网络请求 1.2 冲突 嵌套实现网络请求较为复杂...中的变换操作符FlatMap（）实现嵌套网络请求 关于该操作符的使用具体请看文章：Android RxJava：图文详解 变换操作符 2....在 Gradle加入Retrofit库的依赖 build.gradle dependencies { // Android 支持 Rxjava // 此处一定要注意使用RxJava2的版本 compile...Android 支持 Retrofit compile 'com.squareup.retrofit2:retrofit:2.1.0' // 衔接 Retrofit & RxJava // 此处一定要注意使用RxJava2...Demo地址 Carson_Ho的Github地址 = RxJava2实战系列：网络请求嵌套回调 喜欢的麻烦点个star！ 5.
这个功能有如下几个优势: 数据请求消耗更少的网络带宽和系统资源. 即使在数据更新期间, 应用依然对用户输入响应迅速....; 设备可能联接了慢的或者弱的网络; 应用应该检查每一个请求是否成功, 并且在网络不可用的情形下, 尽可能快地恢复....如下代码展示了如何在应用的ViewModel类中使用Room的DataSource.Factory构建能力创建新的LiveData<PagedaList 实例: ConcertDao.kt: interface...LivePagedListBuilder(myConcertDataSource, myPagingConfig) .setFetchExecutor(myExecutor) .build() 选择正确的数据源类型...如果你需要从数据商店中的任意位置拉取分页数据的话, 使用PositionalDataSource. 这个类支持请求任意位置开始的数据集. 比如, 请求也许返回从位置1200开始的20条数据.
作用 组合 多个被观察者（`Observable`） & 合并需要发送的事件 ---- 2. 类型 RxJava 2 中，常见的组合 / 合并操作符 主要有： ?...，即依赖不能同时存在 } 3.1 组合多个被观察者 该类型的操作符的作用 = 组合多个被观察者 concat（） / concatArray（） 作用 组合多个被观察者一起发送数据，合并后 按发送顺序串行执行...特别注意： 事件组合方式 = 严格按照原先事件序列 进行对位合并 最终合并的事件数量 = 多个被观察者（Observable）中数量最少的数量 即如下图 ?...4.1 获取缓存数据 即从缓存中（磁盘缓存 & 内存缓存）获取数据；若缓存中无数据，才通过网络请求获取数据 具体请看文章：Android RxJava 实际应用讲解：从磁盘 / 内存缓存中 获取缓存数据...总结 下面，我将用一张图总结 RxJava2 中常用的组合 / 合并操作符 ?
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
