前言 Rxjava，由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。...功能说明 采用Get方法对 金山词霸API 按规定时间重复发送网络请求，从而模拟 轮询 需求实现 停止轮询的条件 = 当轮询到第4次时 采用 Gson 进行数据解析 3....具体实现 下面，我将结合 Retrofit 与RxJava 实现 有条件的轮询需求 3.1 步骤说明 添加依赖 创建 接收服务器返回数据 的类 创建 用于描述网络请求 的接口（区别于Retrofit传统形式...// Retrofit把网络请求的URL分成了两部分：一部分放在Retrofit对象里，另一部分放在网络请求接口里 // 如果接口里的url是一个完整的网址，那么放在Retrofit对象里的...Demo地址 Carson_Ho的Github地址 = RxJava2实战系列：有条件的轮询 关于无条件的网络请求轮询，具体请看文章Android RxJava 实际应用讲解：网络请求轮询 5.
前言 Rxjava，由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。 ?...功能说明 采用Get方法对 金山词霸API 按规定时间重复发送网络请求，从而模拟 轮询 需求实现 停止轮询的条件 = 当轮询到第4次时 采用 Gson 进行数据解析 ? ---- 3....发送网络请求 对返回的数据进行处理 本实例侧重于说明 RxJava 的轮询需求，关于Retrofit的使用请看文章：这是一份很详细的 Retrofit 2.0 使用教程（含实例讲解） 3.2 步骤实现...Demo地址 Carson_Ho的Github地址 = RxJava2实战系列：有条件的轮询 关于无条件的网络请求轮询，具体请看文章Android RxJava 实际应用讲解：网络请求轮询 ---...总结 本文主要讲解了 Rxjava创建操作符的实际开发需求场景：有条件轮询需求 ，并结合Retrofit 与RxJava 实现 下面我将结合 实际场景应用 & Rxjava的相关使用框架（如Retrofit
Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。...：传统方式采用了 Callback 接口，而RxJava 方式则采用了Observable接口。...基础使用 下面，我将采用最基础的 Retrofit + RxJava 实现 网络请求 的功能 4.1 功能说明 实现功能：将中文翻译成英文 - > 显示到界面 实现方案：采用Get方法对 金山词霸API...实际开发需求案例 下面，我将使用Retrofit & RxJava，并结合实际的开发需求场景进行案例的讲解 讲解的实际开发需求场景包括： 5.1 网络请求轮询（无条件） 需求场景说明 具体实现 具体请看文章...：Android RxJava 实际应用讲解：（无条件）网络请求轮询 5.2 网路请求轮询（有条件） 需求场景 具体实现 具体请看文章：Android RxJava 实际应用讲解：（有条件）网络请求轮询
Retrofit之所以作为现在最流行的网络请求库，其中一个主要原因是：支持RxJava。Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。...两种方式在使用上最大的区别在于：传统方式采用了 Callback 接口，而RxJava 方式则采用了Observable接口。...实际开发需求案例 下面，我将使用Retrofit & RxJava，并结合实际的开发需求场景进行案例的讲解 讲解的实际开发需求场景包括： ? 5.1 网络请求轮询（无条件） 需求场景说明 ?...具体实现 具体请看文章：Android RxJava 实际应用讲解：（无条件）网络请求轮询 ---- 5.2 网路请求轮询（有条件） 需求场景 ?...具体实现 具体请看文章：Android RxJava 实际应用讲解：（有条件）网络请求轮询 ---- 5.3 网络请求嵌套回调 背景 需要进行嵌套网络请求：即在第1个网络请求成功后，继续再进行一次网络请求
前言 Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。...实现方案：采用Get方法对 金山词霸API 发送网络请求 先切换到工作线程 发送网络请求 再切换到主线程进行 UI更新 4.2 步骤说明 添加依赖 创建 接收服务器返回数据 的类 创建 用于描述网络请求...// Retrofit把网络请求的URL分成了两部分：一部分放在Retrofit对象里，另一部分放在网络请求接口里 // 如果接口里的url是一个完整的网址，那么放在Retrofit对象里的...Activity 冲突：此时如果回到主线程更新 UI，App会崩溃 解决方案：当 Activity退出时，调用 Disposable.dispose()切断观察者和被观察者的连接，使得观察者无法收到事件...、Retrofit联合使用汇总(含实例教程) Carson带你学Android：优雅实现网络请求嵌套回调 Carson带你学Android：网络请求轮询(有条件) Carson带你学Android
前言 Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。...如果还不了解RxJava，请看文章：Android：这是一篇 清晰 & 易懂的Rxjava 入门教程 今天，我将为大家带来 Rxjava的的基本使用 & 实际应用案例教学，即常见开发应用场景实现 ，...基本使用 Rxjava的使用方式有两种： 方式1：分步骤实现 方式2：基于事件流的链式调用 具体使用 请看文章Android RxJava：面向初学者的RxJava使用指南 3....Retrofit 、RxBinding、RxBus等 3.1 网络请求轮询（无条件） 需求场景 具体实现 Android RxJava 实际应用讲解：（无条件）网络请求轮询 3.2 网路请求轮询...（有条件） 需求场景 具体实现 Android RxJava 实际应用讲解：（有条件）网络请求轮询 3.3 网络请求出错重连 需求场景 功能需求说明 功能逻辑 具体实现 Android
前言 Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。...基本使用 Rxjava的使用方式有两种： 方式1：分步骤实现 方式2：基于事件流的链式调用 具体使用 请看文章Android RxJava：面向初学者的RxJava使用指南 3....、RxBinding、RxBus等 3.1 网络请求轮询（无条件） 需求场景 具体实现 Android RxJava 实际应用讲解：（无条件）网络请求轮询 3.2 网路请求轮询（有条件）...需求场景 具体实现 Android RxJava 实际应用讲解：（有条件）网络请求轮询 3.3 网络请求出错重连 需求场景 功能需求说明 功能逻辑 具体实现 Android..., 待注册成功后回再继续发送 用户登录 的网络请求 冲突 嵌套实现网络请求较为复杂，即嵌套调用函数 下面展示的是结合 Retrofit 与 RxJava的基本用法，即未用操作符前 // 发送注册网络请求的函数方法
前言 Rxjava，由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。 ?...如果还不了解 RxJava，请看文章：Android：这是一篇 清晰 & 易懂的Rxjava 入门教程 RxJava如此受欢迎的原因，在于其提供了丰富 & 功能强大的操作符，几乎能完成所有的功能需求...3.6 重复发送 需求场景 重复不断地发送被观察者事件 对应操作符类型 repeat（） & repeatWhen（） repeat（） 作用 无条件地、重复发送 被观察者事件 具备重载方法...下面，我将结合 Retrofit 与RxJava 用一个具体实例来实现轮询需求 具体请看文章：Android RxJava 实际应用讲解：（有条件）网络请求轮询 ---- 4.3 发送网络请求时的差错重试机制...下面我将结合 Retrofit 与RxJava 用一个具体实例来实现 发送网络请求时的 差错重试机制需求 具体请看文章：Android RxJava 实际应用讲解：网络请求出错重连（结合Retrofit
这个 Scheduler 使用的固定的线程池，大小为 CPU 核数。...(…); filter 条件过滤，去除不符合某些条件的事件。...4.建议使用 compose 代替 flatMap。 First 只发送符合条件的第一个事件。可以与contact操作符，做网络缓存。...例子：依次检查Disk与Network，如果Disk存在缓存，则不做网络请求，否则进行网络请求。...的一些使用场景 场景1： 取数据，首先检查内存是否有缓存 然后检查文件缓存中是否有 最后才从网络中取 前面任何一个条件满足，就不会执行后面的 final Observable memory
前言 Rxjava由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。...(含实例教程) Carson带你学RxJava实战：优雅实现网络请求嵌套回调 Carson带你学RxJava实战：网络请求轮询(有条件) Carson带你学RxJava实战：网络请求轮询(无条件)...& Consumer的RxJava类型，可轻易在non-Rx api 和 Rx api 之间搭起桥梁,而不必要担心下游触发的终止状态（onComplete 或 onError） RxKotlin 将RxJava...总结 本文主要对 Rxjava 的所有知识进行讲解，如果你将该系列文章理解读懂，那么，我相信你对于 Rxjava 的使用可以说是非常熟悉了 Carson带你学RxJava系列文章： 入门 Carson...、Retrofit联合使用汇总(含实例教程) Carson带你学Android：优雅实现网络请求嵌套回调 Carson带你学Android：网络请求轮询(有条件) Carson带你学Android
2，具有相对较少的二进制不兼容更改 提供Java 8 lambda友好的API 关于并发源（线程，池，事件循环，光纤，演员等）的不同意见 异步或同步执行 参数化并发的虚拟时间和调度程序 为测试schedulers...例如在Android访问网络时，需要将线程切换到子线程。多次指定只有第一次有效。 doOnEach 数据源（Observable）每发送一次数据，就调用一次。...发射数据源第一个数据，如果没有则发送默认值。...: Hello 11RxJava: world 12RxJava: Git 13RxJava: Code 14RxJava: 8 merge在合并数据源时，如果一个合并发生异常后会立即调用观察者的onError...onErrorReturn发生异常时，回调onComplete()函数后不再往下执行，而onExceptionResumeNext则是要在处理异常的时候返回一个数据源，然后继续执行，如果返回null，则调用观察者的
什么是背压（Backpressure） 在RxJava中，可以通过对Observable连续调用多个Operator组成一个调用链，其中数据从上游向下游传递。...但这两种策略在令牌数为0的时候有一点微妙的区别：onBackpressureDrop直接丢弃数据，不缓存任何数据；而onBackpressureLatest则缓存最新的一条数据，这样当上游接到新令牌的时候...何时用Observable 当上游在一段时间发送的数据量不大（以1000为界限）的时候优先选择使用Observable； 在处理GUI相关的事件，比如鼠标移动或触摸事件，这种情况下很少会出现backpressured...当你从本地磁盘某个文件或者数据库读取数据时（这个数据量往往也很大），应当使用Flowable，这样下游可以根据需求自己控制一次读取多少数据； 以读取数据为主且有阻塞线程的可能时用Flowable，下游可以根据某种条件自己主动读取数据...在RxJava2.0中，Transformer划分的更加细致了，每一种“Observable”都对应的有自己的Transformer，相关API如下所示： 这里以FlowableTransformer
（多一次请求意味着多一次网络开销，不方便实时调整） 多次调用过程中偶尔有一次调用出现异常(接口报错，网络异常)，如果没有异常处理就会影响剩下次数的调用，无法保证高可用 多线程情况下上面的代码会出现并发问题...，设置重试次数为5次，每次调用间隔为2秒，如果调用过程中出现异常或结果满足重试条件的则再次调用直到最大次数(抛出异 常)： // 重试条件 Predicate condition = response...，只需要按照业务改下重试条件和重试任务以及重试间隔和次数即可： /** * 根据输入的condition重复做task,在规定的次数内达到condition则返回, * 如果超过retryTimes...则返回null, 重试次数,整个重试时间以及retry exception都会记录log * * @param condition 重试条件,比如接口返回errorCode为处理中,或不是最终需要的结果...还有RxJava里有个retry的api也能实现类似的用法，感兴趣的同学可以研究下。 ? 点个在看支持我吧，转发就更好了
上篇文章《RxJava从入门到不离不弃（一）——基本概念和使用》，介绍了RxJava的概念和优点，也详细介绍了Observer、Observable和Subscriber等常见概念，相信大家对RxJava...使用just( )，将为你创建一个Observable并自动为你调用onNext( )发射数据。...range( ),创建一个发射特定整数序列的Observable，第一个参数为起始值，第二个为发送的个数，如果为0则不发送，负数则抛异常。...Observable timeObservable = Observable.timer(3, TimeUnit.SECONDS); //3秒后发射一个值 repeat 使用repeat( ),创建一个重复发射特定数据的...事实上，虽然 Action0 和 Action1 在 API 中使用最广泛，但 RxJava 是提供了多个 ActionX 形式的接口 (例如 Action2, Action3) 的，它们可以被用以包装不同的无返回值的方法
但是有人说在Android中已经有很多异步操作的API，比如Handler，AsyncTask等，这些都能满足基本的异步操作，为什么还要使用Rxjava呢？ ...Rxjava的变化 以上内容都是基于Rxjava比较旧的API介绍的，目前Rxjava 1 已经更新到了1.3 使用最新的Rxjava 1需要引入以下依赖： compile 'io.reactivex...简单看一下也能知道，这段代码就是做一些参数校验，baseUrl不能为空否则会抛异常，至于其他的参数如果为null则会创建默认的对象。...>对象，如果没有，则构建ServiceMethod重复的网络请求 ......
如果使用常规的方法来实现，肯定是要写得欲仙欲死，然而在使用 RxJava 的情况下，依然只是一条链式调用就完成了。它很长，但很清晰。 所以， RxJava 好在哪？...而前面提到的由图片 id 取得图片并显示的例子，如果也加上这两句： ? 那么，加载图片将会发生在 IO 线程，而设置图片则被设定在了主线程。...---- 四、RxJava 的适用场景和使用方式 1. 与 Retrofit 的结合 Retrofit 是 Square 的一个著名的网络请求库。...而使用 RxJava 形式的 API，定义同样的请求是这样的： ? 使用的时候是这样的： ? 看到区别了吗？...而如果你有某些异步操作无法用这些库来自动生成Observable，也完全可以自己写。
OkHttp HTTP是现代网络的通讯方式。决定我们如何交换数据和媒体。 如果有效地执行HTTP通讯会使您的内容加载更快，并且节省带宽。...（2）通过连接池降低请求延迟（如果HTTP / 2不可用）。 （3）透明GZIP压缩下载大小。 （4）对响应进行 缓存 ，可以完全避免重复请求的网络。 ?...RxJava - JVM的反应式扩展Reactive Extension -使用可观察序列来组合异步和基于事件的程序。...RxJava的一个常见用例是在后台线程上运行一些计算，比如网络请求，并在UI线程上显示结果（或错误）： ? MBassador MBassador是一种轻量级，高性能的事件总线，实现发布订阅模式。...另一方面，对于独立应用程序使用SLF4J并不一定有意义。独立应用程序可以直接调用他们选择的日志框架。
前言 Rxjava，由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。...需求场景 重复不断地发送被观察者事件 对应操作符类型 repeat（） & repeatWhen（） repeat（） 作用 无条件地、重复发送 被观察者事件 具备重载方法，可设置重复创建次数...实例讲解） 4.2 轮询 需求场景说明 下面，我将结合 Retrofit 与RxJava 用一个具体实例来实现轮询需求 具体请看文章：Android RxJava 实际应用讲解：（有条件）网络请求轮询...4.3 发送网络请求时的差错重试机制 需求场景说明 功能说明 下面我将结合 Retrofit 与RxJava 用一个具体实例来实现 发送网络请求时的 差错重试机制需求 具体请看文章...：Android RxJava 实际应用讲解：网络请求出错重连（结合Retrofit） 5.
为达到这个目的，你定义一种获取和变换数据的机制，而不是调用一个方法。...extends R>> mapper) Type ambiguities 类型歧义： 尽管某些运算符在类型擦除方面没有问题，但它们的签名可能会变得模棱两可，特别是如果使用 java8 和 lambdas...' 官方 API Docs (此处以3.0.8版本为例) http://reactivex.io/RxJava/3.x/javadoc/3.0.8/ 核心类 Flowable io.reactivex.rxjava3...repeat 操作符重复整个序列重新订阅观察，而不是重复上一个映射操作符，并且在序列重复操作符中使用的位置无关紧要（参见 DEMO2）。...如果你将第二个参数设为0，将导致Observable不发射任何数据（如果设置为负数，会抛异常）。
前言 Rxjava，由于其基于事件流的链式调用、逻辑简洁 & 使用简单的特点，深受各大 Android开发者的欢迎。 ?...如果还不了解RxJava，请看文章：Android：这是一篇 清晰 & 易懂的Rxjava 入门教程 RxJava如此受欢迎的原因，在于其提供了丰富 & 功能强大的操作符，几乎能完成所有的功能需求...功能说明 本文将采用Get方法对 金山词霸API 按规定时间 重复发送网络请求，从而模拟 轮询 需求实现 采用 Gson 进行数据解析 ? ---- 3....RxJava 的轮询需求，关于Retrofit的使用请看文章：这是一份很详细的 Retrofit 2.0 使用教程（含实例讲解） 3.2 步骤实现 步骤1： 添加依赖 a....// Retrofit把网络请求的URL分成了两部分：一部分放在Retrofit对象里，另一部分放在网络请求接口里 // 如果接口里的url是一个完整的网址，那么放在Retrofit对象里的
云服务器
ICP备案
对象存储
实时音视频
云直播
