RxJava2 实战知识梳理(4) - 结合 Retrofit 请求新闻资讯

前言

如何通过结合Retrofit框架来进行网络请求,也是RxJava的学习过程中必须要掌握的一环。网上已经有很多开源项目和文章介绍了,今天这篇文章,我们就通过一个简单的例子,通过RxJava + Retrofit的方式实现网络请求。

这个例子很简单,我们通过 干货集中营 提供的接口,分别请求Android类和iOS类的资讯,并将这两个接口所返回的数据在界面上进行展示。

通过该例子,可以学习如何将RetrofitRxJava结合,并通过zip操作符实现等待多个网络请求完成。

示例

2.1 接口介绍

首先来熟悉一下所用到的测试接口,其数据来自于 干货集中营,这里选择AndroidiOS两类的资讯,通过接口的描述,可以知道发起请求时的变量包含三个:

  • 分类
  • 请求个数
  • 请求页数

返回的数据格式如下:

2.2 编写 Entity 类

根据分析好的数据格式,我们编写对应的Entity类:

  • 单次返回结果的数据结构:
  • 单条资讯的数据结构:

2.3 引入 Retrofit 依赖

接下来,在build.gradle文件中,引入必要的依赖,以下三个依赖包的作用分别为:

  • Retrofit的核心库
  • 将返回的Call<Response>转换成Call<NewsEntity>
  • Call<NewsEntity>转换成Observable<NewsEntity>

2.4 定义 Retrofit 需要的请求接口

按照Retrofit的使用介绍,我们需要定义一个接口类,这个接口类的返回值为Observable<NewsEntity>,也就是我们之前定义好的数据结构。而这个接口接收三个参数:请求类型、请求个数、请求所在页数。

当我们需要请求数据时,就应当像下面这样构造一个Observable<NewsEntity>

  • baseUrl:定义请求链接的前缀
  • addConverterFactory:将OKHttp返回的标准Response解析成我们所需要的数据类型NewsEntity
  • addCallAdapterFactory:将Call<NewsEntity>转换成Observable<NewsEntity>,这样才能真正将RetrofitRxJava结合起来。

2.5 发起请求

以上就是所有的准备工作,回顾一下我们主要做了以下四步,这也是今后我们使用其它任意接口时的标准流程:

  • 熟悉接口
  • 根据接口返回的数据,定义Entity
  • 根据接口的url组成方式定义Retrofit所需要的接口声明,接口函数的返回类型为Observable<Entity>,其中Entity就是第二步中定义好的返回数据类型。
  • 通过Retrofit,根据第三步的接口定义,返回真正的Observable

其实经过以上的四步,我们的工作就基本上完成了,只需要把上面第四步中返回的Observable<XXXEntity>当做一个发送数据的普通数据源就可以了。

示例代码如下,我们请求了AndroidiOS两个接口,并且使用zip操作符让两个接口都返回之后,才将数据呈现给用户,同时每次点击刷新资讯之后,我们将页数增加一以请求新的资讯。

示例解析

关于如何使用Retrofit + RxJava前面已经说得比较清楚了,下面我们重点介绍一下新接触的两个操作符,flatMapzip

3.1 flatMap

flatMap的原理图如下所示:

它接收一个Function函数,对于上游发送的每个事件它都会应用该函数,这个函数返回一个新的Observable,如果有多个Observable,那么他会发送合并后的结果。

在上面的例子中,上游的just发送一个请求的所在页数,我们根据这个页数再去创建一个新的Observable来发送数据。

3.2 zip

zip操作符的原理图如下所示:

它接收多个Observable,以及一个函数,该函数的形参为这些Observable发送的数据,并且要等所有的Observable都发射完会后才会回调该函数。

通过zip操作符,我们就可以实现等待多个网络请求完成再返回的需求,例如在上面的例子中,我们会等待AndroidiOS类的资讯请求都返回之后,再合并它们的结果发送给下游,在界面上展示。

最后

关于rxjava更多的实战,推荐此文:

Novate 一款Android RxStyle的网络框架

原文发布于微信公众号 - 我就是马云飞(coding_ma)

原文发表时间:2017-09-25

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏前端下午茶

JS 状态模式

状态模式(State)允许一个对象在其内部状态改变的时候改变它的行为,对象看起来似乎修改了它的类。 其实就是用一个对象或者数组记录一组状态,每个状态对应一个实现...

40440
来自专栏互扯程序

毕业季,跳槽季,不刷点面试题怎么能行?

现在是资源共享的时代,同样也是知识分享的时代,如果你觉得本文能学到知识,请把知识与别人分享。 前言 马上就是一年一度的毕业季 跳槽季,找工作三大要素,简...

36250
来自专栏听雨堂

将一段复杂文本变成字符串的赋值语句

        因为需要在C#的代码中,写入一大段的js代码和网页代码,试验已经没有问题了。实现时却碰到一个小问题,就是大段的js和html代码,应该以什么方式...

20370
来自专栏斑斓

漂亮的with,鱼与熊掌可以兼得

假设要加载磁盘上的一个文件,并以二进制形式读取文件的数据。若要从健壮性的角度考虑,需得考虑两种异常情况: 加载文件失败,例如给定的文件路径并不存在该文件 读取文...

39180
来自专栏一个番茄说

函数响应式编程框架RxSwift 学习——Observable

最近开始研究RxSwift,网上能查到的资料太有限,边学边记录,有不对的地方欢迎大家指正。

11610
来自专栏calvin

centos7 lldb 调试netcore应用的内存泄漏和死循环示例(dump文件调试)

lldb工具的安装,linux下netcore如何生成dump文件,查看下文 centos7使用lldb调试netcore应用转储dump文件

31530
来自专栏青蛙要fly的专栏

项目需求讨论-APP手势解锁及指纹解锁

好久没写文章了,最近也比较偷懒,今天继续讨论我实际开发中遇到的需求,那就是关于APP解锁,大家都知道。现在越来越多的APP在填入账号密码后,第二次登录后,基本不...

26720
来自专栏Android常用基础

Rxjava2-小白入门(三)

继续上篇的Rxjava2的入门实例,把剩下的运用Rxjava的实例讲下,首先要说名下本文会用到Rxbinding的知识,他相当于Rxjava的辅助工具,在引入他...

21020
来自专栏超然的博客

JSON 和 JSONP 两兄弟

  但说到AJAX就会不可避免的面临两个问题,第一个是AJAX以何种格式来交换数据?第二个是跨域的需求如何解决?

15730
来自专栏数据和云

中文命名可能有什么坏处?

在最近的一个报告分析中,再次遭遇到全中文的数据结构设计。从图示中可以看到,所有的表名、索引名等,都是用中文命名的。 我们不考虑面向对象、方法那回事,单纯从技术角...

39150

扫码关注云+社区

领取腾讯云代金券