RxJava + Retrofit 前言 本文基于RxJava、Retrofit的使用，若是对RxJava或Retrofit还不了解的简友可以先了解RxJava、Retrofit的用法再来看这篇文章。...Observable...是不是觉得很熟悉，这货不就是之前在RxJava使用到的被监听者？ 3、使用Observable完成一个网络请求，登录成功后保存数据到本地。...+ Retrofit 形式的时候，Retrofit 把请求封装进 Observable ，在请求结束后调用 onNext() 或在请求失败后调用 onError()。...使用RxJava + Retrofit来完成这样的请求（借用抛物线的例子，稍微做了点改动） //登录，获取token @GET("/login") public Observable...RxJava的使用就暂时介绍到这里吧，使用过程中遇到好用的再出来跟大家分享。 以上有错误之处感谢指出 参考：给 Android 开发者的 RxJava 详解 （本文部分内容引用自该博客）
今天，我将为大家带来 Rxjava中的常见开发应用场景：从磁盘、内存缓存中获取缓存数据 ，希望大家会喜欢。...功能说明 对于从磁盘 / 内存缓存中 获取缓存数据 的功能逻辑如下： 3....= "从磁盘缓存中获取数据"; /* * 设置第1个Observable：检查内存缓存是否有该数据的缓存 **/ Observable...Demo地址 Carson_Ho的Github地址 = RxJava2实战系列：从磁盘 / 内存缓存中 获取缓存数据 5....总结 本文主要讲解了 Rxjava的实际开发需求场景：从磁盘 / 内存缓存中 获取缓存数据
RxJava 不仅把每个事件单独处理，还会把它们看做一个队列。没有新的onNext()之后，调用此方法。 onError()：事件队列异常。...onCompleted() 和 onError()还是互斥的，只能调用其中一个 回顾Retrofit 上篇博文我们使用Retrofit实现对网络的访问以及返回数据的解析，详情请见Android 初探Retrofit2.0.1...（最新版），在这里我们再简单温习下 创建WeatherInfoService，并制定请求数据的方式以及需要的查询参数 创建相应的WeatherInfoBean 创建Retrofit对象并使用GSON解析数据...调用 weatherInfoService#getWeatherInfo(FORMAT, CITYNAME, KEY)，获取call 插入队列，并展示数据 RxJava/RxAndroid结合Retrofit...(today)); } }); } 在.map()方法中我们获取WeatherInfo中Today属性，并且返回Today
中完成，使用时通过Application获取到Retrofit。...{ //可以在这里对获取到的数据进行处理 } override fun onError(e: Throwable?)...{ //可以在这里对获取到的数据进行处理 } override fun onError(e: Throwable?)...接下来看看效果： runRxLambda(retrofit().load(),{ //我们在这里的操作就相当于在onNext中的操作，参数可以通过it获取 },{ //这里就是onError的实现...，参数也可以通过it获取 }) runRxLambda(retrofit().load(),{ //我们在这里的操作就相当于在onNext中的操作，参数可以通过it获取 },{ //这里就是onError
各自的职责：Retrofit 负责请求的数据和请求的结果，使用接口的方式呈现，OkHttp 负责请求的过程，RxJava 负责异步，各种线程之间的切换。...请求数据封装 1.参数 首先需要封装的使我们的数据类，在数据类中需要封装请求中用到的相关数据的设置，比如请求参数、方法、加载框显示设置等等 public abstract class BaseApi<...3.结果判断 这里结合RxJava的map方法在服务器返回数据中，统一处理数据处理，所以BaseApi<T implements Func1<BaseResultEntity<T , T ，后边结合结果处理链接起来使用...处理，成功则将用户关心的数据传给Gson解析返回 5.泛型传递 BaseResultEntity<T 中的泛型T也就是我们所关心的回调数据，同样也是Gson最后解析返回的数据，传递的过程根节点是通过定义...<T 类返回的onNext(T t)成功数据或者onError(Throwable e)数据。
下面我用对比的方式来介绍 Retrofit 的 RxJava 版 API 和传统版本的区别。 以获取一个 MovieEntity 对象的接口作为例子。...和Rxjava的结合，大家可以自己进行封装；那么用上了RxJava,我们就可以用它强大的操作符来对数据进行处理和操作，各位看官可以具体去实现，我在这里不做多做赘述。...由于 RxJava Observable 订阅后（调用 subscribe 函数），一般会在后台线程执行一些操作（比如访问网络请求数据），当后台操作返回后，调用 Observer 的 onNext 等函数...在Android 6.0中，系统新增了部分权限的运行时动态获取。而不再是在以前的版本中安装的时候授予权限。...，你就会发现RxJava的魅力所在；如果看一遍没有看懂的童鞋，建议多看几次；动手写写代码，我想信本文可以给到你们一些帮助；你们真正的体会到什么是 从入门到放弃再到不离不弃 ；这就是RxJava的魅力所在
今天，我将为大家带来 Rxjava中的常见开发应用场景：从磁盘、内存缓存中获取缓存数据 ，希望大家会喜欢。...功能说明 对于从磁盘 / 内存缓存中 获取缓存数据 的功能逻辑如下： ? ---- 3....= "从磁盘缓存中获取数据"; /* * 设置第1个Observable：检查内存缓存是否有该数据的缓存 **/ Observable...Demo地址 Carson_Ho的Github地址 = RxJava2实战系列：从磁盘 / 内存缓存中 获取缓存数据 ---- 5....总结 本文主要讲解了 Rxjava的实际开发需求场景：从磁盘 / 内存缓存中 获取缓存数据 下面我将结合 实际场景应用 & Rxjava的相关使用框架（如Retrofit、Eventbus） ，继续对
下面我用对比的方式来介绍 Retrofit 的 RxJava 版 API 和传统版本的区别。 以获取一个 User 对象的接口作为例子。... callback); 在程序的构建过程中， Retrofit 会把自动把方法实现并生成代码，然后开发者就可以利用下面的方法来获取特定用户并处理响应： getUser(userId, new...当 RxJava 形式的时候，Retrofit 把请求封装进 Observable ，在请求结束后调用 onNext() 或在请求失败后调用 onError()。...比如： 假设这么一种情况：你的程序取到的 User 并不应该直接显示，而是需要先与数据库中的数据进行比对和修正后再显示。...数据库的操作很重，一次读写操作花费 10~20ms 是很常见的，这样的耗时很容易造成界面的卡顿。所以通常情况下，如果可以的话一定要避免在主线程中处理数据库。
众所周知，rxjava+retrofit是目前网上最流行的网络解析框架。而目前网络上的文章大多还是关于rxjava1的。关于RxJava2的少之又少，于是，便有了此文。 此文的目的有三个： 1....Function相关的在rxjava1中，我们有各种Func1，Func2......，但在rxjava2中只有Function了。依旧记得看凯哥的文章的时候把我整蒙了。...我们知道在Rxjava1中Observable对backpressure是支持的。但在Rxjava2中Observable取消了对backpressure的支持。...仔细看，map()方法中，我们把一个integer对象转换成了一个String对象。然后当map()调用结束时，事件的参数类型也从integer转换成了String。这就是最常见的变换操作。...skip 、take skip操作符将源Observable发射过的数据过滤掉前n项，而take操作则只取前n项；另外还有skipLast和takeLast则是从后往前进行过滤。
简要介绍 Retrofit是当前应用非常广泛的网络请求框架,通常结合RxJava来进行网络请求,本文将展示一个采用RxJava+Retrofit的网络请求demo....集成步骤 1、app工程的build.gradle中添加依赖 //retrofit2 implementation 'com.google.code.gson:gson:2.8.5' implementation...中添加权限 <uses-permission android:name="android.permission.INTERNET"/ 3、添加数据类Task data class Task(var id...()) .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) .build() //获取UserMsgService...Demo源代码 https://github.com/cxyzy1/rxjava_retrofit_demo 以上就是本文的全部内容，希望对大家的学习有所帮助。
添加依赖 compile 'com.squareup.retrofit2:retrofit:2.0.0-beta4' compile 'io.reactivex:rxjava:1.1.1'...rxandroid:1.1.0' //rxjava中用到的AndroidSchedulers.mainThread() compile 'com.squareup.retrofit2:...adapter-rxjava:2.0.0-beta4' 这里使用的是retrofit2.0,默认为okhttp3.0 二....简单说就是将 一个List 或者数组中的每一条数据都 转换成一个 Observable对象。...这里结合了retrofit 在flatMap中通过一个城市的str,返回一个Observable,这个Observable的参数是一些获取到的天气信息结构WeatherData，这样在后面subscrib
本文主要讲解的是： 线程控制（也称为调度 / 切换），即讲解功能性操作符中的：subscribeOn（） & observeOn（） Carson带你学RxJava系列文章，包括 原理、操作符、应用场景...，需要在子线程中实现耗时的操作；然后回到主线程实现 UI操作 应用到 RxJava模型中，可理解为： 被观察者 （Observable） 在 子线程 中生产事件（如实现耗时操作等等） 观察者（Observer...的接口（区别于传统形式） 创建 Retrofit 实例 创建 网络请求接口实例 并 配置网络请求参数（区别于传统形式） 发送网络请求（区别于传统形式） 发送网络请求 对返回的数据进行处理 本实例侧重于说明...compile 'com.squareup.retrofit2:retrofit:2.1.0' // 衔接 Retrofit & RxJava // 此处一定要注意使用RxJava2的版本 compile...Carson带你学Android：功能防抖 Carson带你学Android：从磁盘/内存缓存中获取缓存数据 Carson带你学Android：联合判断
前言 Retrofit 和RxJava已经出来很久了，很多前辈写了很多不错的文章，在此不得不感谢这些前辈无私奉献的开源精神，能让我们站在巨人的肩膀上望得更远。...Retrofit的使用可以 加QQ群：668041364 本文内容是基于Retrofit + RxJava做的一些巧妙的封装。参考了很多文章加入了一些自己的理解，请多指教。...RxJava永远比你想象的强大。RxJava中那么多操作符看到我身体不适，有个操作符compose。...处理ProgressDialog 在Rxjava中我们什么时候来显示Dialog呢。一开始觉得是放在Subscriber的onStart中。onStart可以用作流程开始前的初始化。...要实现上面的功能其实很简单，两部分 随时监听Activity(Fragment)的生命周期并对外发射出去； 在我们的网络请求中，接收生命周期 并进行判断，如果该生命周期是自己绑定的，如Destory，那么就断开数据向下传递的过程
因此这篇文章只是简单的通过两个例子介绍了RxJava在生产环境中的使用。不过本篇中的每个例子我都配上了完整的代码。...首选我们需要调用系统api来获取所有已安装的app，所以在OnSubscribe的call方法中调用getApplicationInfoList()。...并不是我们所需要的类型，因此需要通过map操作符将其转换为AppInfo； 由于获取ApplicationInfo、过滤数据、转换数据相对比较耗时，因此需要通过subscribeOn操作符将这一系列操作放到子线程中来处理...源码地址：https://github.com/BaronZ88/HelloRxAndroid 示例二、RxJava+Retrofit2实现获取天气数据 RxJava + Retrofit2几乎是Android...所以就需要我们先访问服务器，拿到对应城市名的cityId，然后通过这个cityId再去获取天气数据。
今天，我将为大家带来 Rxjava的的基本使用 & 实际应用案例教学，即常见开发应用场景实现 ，并结合常用相关框架如Retrofit等，希望大家会喜欢。...实际开发应用场景 RxJava的实际开发应用场景 与 其对应的操作符息息相关 常见的RxJava实际开发应用场景有如下： 下面，我将对每个实际开发应用场景进行实例讲解教学 下面实例皆结合常用框架如Retrofit...中的变换操作符FlatMap（）实现嵌套网络请求 具体实现 Android RxJava 实际应用讲解：网络请求嵌套回调 3.5 从磁盘 / 内存缓存中 获取缓存数据 需求场景 功能说明...对于从磁盘 / 内存缓存中 获取缓存数据 的功能逻辑如下： 具体实现 Android RxJava 实际应用讲解：从磁盘 / 内存缓存中 获取缓存数据 3.6 合并数据源 需求场景...功能说明 即，同时向2个数据源获取数据 -> 合并数据 -> 统一展示到客户端 具体实现 Android RxJava 实际应用讲解：合并数据源 3.7 联合判断 需求场景 需要同时对多个事件进行联合判断
' ---- 基理 Observable和Observer通过subscribe()方法实现订阅关系； Rxjava中是自动发送事件的， 一旦订阅就开始发送； ---- 基本使用三个步骤 ?...()三个方法分别对应着第一步中Observable的onNext()、onComplete()、onError()三个方法， 只要Observable发出（调用）对应的方法， Observer对应的方法就会被调用...； 由Observable通过自身ObservableOnSubscribe中的subscribe()中的 onNext()等方法自动发出信息， observer接收到信息后执行对应的onNext...()等方法； 在订阅之后，Observer中， onSubscribe()是每次接收数据之前必须要调用的方法； onNext()则是对应Observable调用的次数去调用相应的次数； onComplete...用法示例 （用于监听Observable发送的数据， 如果Observable发送的数据等于某个值， 就断绝订阅关系）： ?
前言 在Andrroid开发中，网络请求十分常用，而在Android网络请求库中，Retrofit是当下最热的一个网络请求库 Retrofit之所以作为现在最流行的网络请求库，其中一个主要原因是：支持...URL地址 // getCall()是接受网络请求数据的方法 } // RxJava 方式：Observable<.....实例 创建 网络请求接口实例 并 配置网络请求参数（区别于传统形式） 发送网络请求（区别于传统形式） 发送网络请求 对返回的数据进行处理 本实例侧重于说明 RxJava 的线程控制，关于Retrofit...中的变换操作符FlatMap（）实现嵌套网络请求 具体实现 具体请看文章： Android RxJava 实际应用讲解：网络请求嵌套回调 5.4 网络请求出错重连 需求场景 功能需求说明...2个服务器发送网络请求 ->> 获取数据 ->> 合并数据 ->> 统一展示到客户端 具体实现 具体请看文章：Android RxJava 实际应用讲解：合并数据源 至此，关于Retrofit
今天，我将为大家带来 Rxjava创建操作符的常见开发应用场景：轮询需求 ，并结合Retrofit 与RxJava 实现，希望大家会喜欢。...需求场景 注：关于 Rxjava中的延时创建操作符interval（） 和 intervalRange（）的使用请看文章Android RxJava：最基础的操作符详解 - 创建操作符 2....具体实现 下面我将结合 Retrofit 与RxJava 实现轮询需求 3.1 步骤说明 添加依赖 创建 接收服务器返回数据 的类 创建 用于描述网络请求 的接口（区别于传统Retrofit形式） 创建...Retrofit 实例 创建 网络请求接口实例 并 配置网络请求参数（区别于传统Retrofit形式） 发送网络请求（区别于传统Retrofit形式） 发送网络请求 对返回的数据进行处理 本实例侧重于说明...RxJava 的轮询需求，关于Retrofit的使用请看文章：这是一份很详细的 Retrofit 2.0 使用教程（含实例讲解） 3.2 步骤实现 步骤1： 添加依赖 a.
去年的时候学习了Rxjava和Retrofit的基本用法，但一直没有在实际项目中运用。今年开做新项目，果断在新项目中引入了RxJava和Retrofit。...： 服务器响应数据的基类BasicResponse 构建初始化Retrofit的工具类IdeaApi 通过GsonConverterFactory获取真实响应数据 封装DefaultObserver处理服务器响应...Retrofit将请求到json数据直接转换成了实体类，但有时候我们需要查看json数据，Retrofit并没有提供直接获取json数据的功能。...我们可以直接从Retrofit的源码中copy出GsonConverterFactory的三个相关类来做修改。...1.在服务器返回数据成功的情况下会回调到onNext方法。
本系列文章主要基于 Rxjava 2.0 接下来的时间，我将持续推出 Android中 Rxjava 2.0 的一系列文章，包括原理、操作符、应用场景、背压等等 ，有兴趣可以继续关注Carson_Ho...注：关于 Rxjava中的延时创建操作符interval（） 和 intervalRange（）的使用请看文章Android RxJava：最基础的操作符详解 - 创建操作符 ---- 2....具体实现 下面我将结合 Retrofit 与RxJava 实现轮询需求 3.1 步骤说明 添加依赖 创建 接收服务器返回数据 的类 创建 用于描述网络请求 的接口（区别于传统Retrofit形式） 创建...Retrofit 实例 创建 网络请求接口实例 并 配置网络请求参数（区别于传统Retrofit形式） 发送网络请求（区别于传统Retrofit形式） 发送网络请求 对返回的数据进行处理 本实例侧重于说明...总结 本文主要讲解了 Rxjava创建操作符的实际开发需求场景：轮询需求 ，并结合Retrofit 与RxJava 实现 接下来的时间，我将持续推出 Android中 Rxjava 2.0 的一系列文章
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
