Retrofit+Flow网络请求与Android网络请求的演变

news/2025/3/13 4:04:18/

Retrofit网络请求我想大家都不陌生,今天我就来梳理一下技术是如何一步一步进步,逼格是如何一步一步变高的。

Retrofit使用方式演变

萌新

刚开始接触Retrofit的时候是从okhttp和volley以及android系统源码里面那个HttpPost与HttpGet切换过来的。

public interface AuthService {@POST("v1/login")@FormUrlEncodedResponseBody login(@Field("username") String username, @Field("password") String password);
}

那个时候市面上主流还是用的Java,也不知道从哪天开始,突然发现Retrofit这种代理接口的方式用着很爽。于是用着用着就上瘾了,甚至都不知道Retrofit是使用的动态代理的方式。这种方式是通过responseBody.body().string()拿到json字符串,然后再自己通过json解析库解析出数据的。

小白

然后有一天到处看博客或技术文章,于是就发现了Retrofit的返回值原来不仅仅可以是ResponseBody,还可以是T。

public interface AuthService {@POST("v2/login")@FormUrlEncodedLoginResponse login(@Field("username") String username, @Field("password") String password);
}

这时已经意识到可以json解析的过程交给retrofit框架。

implementation(‘com.squareup.retrofit2:converter-gson:2.8.1’)

加了个gson转换器的依赖,对吧?

新手

后来,为了满足对更高逼格的追求,返回值直接跟OkHttp的Call结合,然后使用enqueue的方式进行请求,于是就变成了Call。

public interface AuthService {@POST("v3/login")@FormUrlEncodedCall<LoginResponse> login(@Field("username") String username, @Field("password") String password);
}
初级

再后来,发现市面上RxJava的热度突然飙升,于是乎,就开始研究起了RxJava,这时候,功力开始有所长进。

public interface AuthService {@POST("v4/login")@FormUrlEncodedObservable<LoginResponse> login(@Field("username") String username, @Field("password") String password);
}

这时你可能就需要依赖这几个库了,版本号偏高暂且不去计较,也有可能用的是rxjava第一代。

implementation ‘com.squareup.retrofit2:adapter-rxjava2:2.8.1’
implementation ‘io.reactivex.rxjava2:rxjava:2.0.1’
implementation ‘io.reactivex.rxjava2:rxandroid:2.0.1’
中级

随着Kotlin的兴起,市面上对网络请求的写法也是大相径庭,网络框架也开始演变出自己的风格,甚至有些公司自己封装网络请求库,没有什么问题啊,反正主要思路就是动态代理。百花齐放的时代来临。

interface AuthService {@POST("v5/login")fun login(@Body body: RequestBody): Observable<BaseResponse<LoginUser>>
}

为了追求更加新颖的写法,将@Field换成了@Body,返回值模型增加了公共的code、msg等。

高级一阶

由于经验逐渐变得丰富,你开始使用Kotlin的协程,因为你对更牛逼技术的追求一直没有停止过。

interface AuthService {@POST("v6/login")suspend fun login(@Body body: RequestBody): BaseResponse<LoginUser>
}

这个时候retrofit的写法就已经进入到了第6代,你问为什么是第6代?这个不是重点,我编的。你直接将API接口中定义的函数变成了suspend函数,方便在协程作用域发起。同时你去掉了Observable这个RxJava的产物,返回值又回到了最初的状态。你不禁感慨,从哪里来,到哪里去。返璞归真了!

高级二阶

你以为到这就结束了?随着Flow的问世,网络请求就进入到了第七世代。Flow是基于协程的产物,可以不用挂起函数了。而且Flow具备RxJava的优良特性,可以对数据流进行变换,也可以监听函数执行的生命周期。这样就方便添加显示加载中对话框和隐藏加载中对话框,以及加载进度了。

interface AuthService {@POST("v7/login")fun login(@Body body: RequestBody): Flow<BaseResponse<LoginUser>>
}

dcache框架如何支持协程和Flow

我的dcache框架1.x的稳定版本,不支持flow。

implementation("com.github.dora4:dcache-android:1.8.5")

你需要使用2.0.12及以上版本,对flow请求有很好的支持。

implementation("com.github.dora4:dcache-android:2.0.12")

接下来我们简单阅读下DoraHttp.kt的源代码。

/*** 将一个普通的api接口包装成Flow返回值的接口。*/
suspend fun <T> flowResult(requestBlock: suspend () -> T,loadingBlock: ((Boolean) -> Unit)? = null,errorBlock: ((String) -> Unit)? = null,
) : Flow<T> {return flow {// 设置超时时间为10秒val response = withTimeout(10 * 1000) {requestBlock()}emit(response)}.flowOn(Dispatchers.IO).onStart {loadingBlock?.invoke(true)}.catch { e ->errorBlock?.invoke(e.toString())}.onCompletion {loadingBlock?.invoke(false)}
}

这个函数建议在net作用域内执行,net协程作用域的定义请参见DoraHttp.kt的详细源代码,github.com/dora4/dcach… 。高阶函数的block参数定义中,如果加suspend关键字,则可以传入suspend块,也可以传入普通的方法块。如果不加suspend关键字,则只能传入普通方法块。这个函数对应第6代的写法,可以翻看前面的内容。Flow最终调用collect {} 来处理业务逻辑。


/*** 直接发起Flow请求,如果你使用框架内部的[dora.http.retrofit.RetrofitManager]的话,需要开启* [dora.http.retrofit.RetrofitManager]的flow配置选项[dora.http.retrofit.RetrofitManager.Config.useFlow]* 为true。*/
suspend fun <T> flowRequest(requestBlock: () -> Flow<T>,successBlock: ((T) -> Unit),failureBlock: ((String) -> Unit)? = null,loadingBlock: ((Boolean) -> Unit)? = null
) {requestBlock().flowOn(Dispatchers.IO).onStart {loadingBlock?.invoke(true)}.catch { e ->failureBlock?.invoke(e.toString())}.onCompletion {loadingBlock?.invoke(false)}.collect {successBlock(it)}
}

这个源码对应第7代的写法。

Android 学习笔录

Android 性能优化篇:https://qr18.cn/FVlo89
Android Framework底层原理篇:https://qr18.cn/AQpN4J
Android 车载篇:https://qr18.cn/F05ZCM
Android 逆向安全学习笔记:https://qr18.cn/CQ5TcL
Android 音视频篇:https://qr18.cn/Ei3VPD
Jetpack全家桶篇(内含Compose):https://qr18.cn/A0gajp
OkHttp 源码解析笔记:https://qr18.cn/Cw0pBD
Kotlin 篇:https://qr18.cn/CdjtAF
Gradle 篇:https://qr18.cn/DzrmMB
Flutter 篇:https://qr18.cn/DIvKma
Android 八大知识体:https://qr18.cn/CyxarU
Android 核心笔记:https://qr21.cn/CaZQLo
Android 往年面试题锦:https://qr18.cn/CKV8OZ
2023年最新Android 面试题集:https://qr18.cn/CgxrRy
Android 车载开发岗位面试习题:https://qr18.cn/FTlyCJ
音视频面试题锦:https://qr18.cn/AcV6Ap


http://www.ppmy.cn/news/1167608.html

相关文章

shell_38.Linux读取脚本名

读取脚本名 (1)示例 $ cat positional0.sh #!/bin/bash # Handling the $0 command-line parameter # echo This script name is $0. exit $ $ bash positional0.sh This script name is positional0.sh. $ (2)如果使用另一个命令来运行 shell 脚本&#xff0c;则命令…

2023年中国预缩机产量、需求量及市场规模分析[图]

预缩机是一种用于压缩气体的机械设备&#xff0c;通过减小气体的体积&#xff0c;增加气体的压力。预缩机通常由压缩机、电机、冷却系统和控制系统等组成&#xff0c;广泛应用于空调、制冷、工业生产等领域。 预缩机行业分类 资料来源&#xff1a;共研产业咨询&#xff08;共研…

前端数据可视化之【Echarts下载使用】

目录 &#x1f31f;下载&#x1f31f;浏览器引入&#x1f31f;模块化引入 &#x1f31f;使用&#x1f31f;基本使用步骤 &#x1f31f;绘制一个简单的图表&#x1f31f;写在最后 &#x1f31f;下载 &#x1f31f;浏览器引入 官网下载界面&#xff1a;官方网站 或 Echarts中文…

冒泡排序、插入排序、选择排序和快速排序的原理

下面是对冒泡排序、插入排序、选择排序和快速排序的原理的简要解释&#xff1a; 冒泡排序&#xff08;Bubble Sort&#xff09;&#xff1a;冒泡排序是一种简单的排序算法。它通过多次迭代比较相邻的元素&#xff0c;并交换它们的位置&#xff0c;使得较大&#xff08;或较小&…

2023年最新版CorelDraw(cdr)软件下载安装教程

CorelDRAW 2023是Corel公司推出的最新版本的图形设计软件。CorelDRAW是一款功能强大的矢量图形编辑工具&#xff0c;被广泛用于图形设计、插图、页面布局、照片编辑和网页设计等领域。 1. 新增的设计工具&#xff1a;CorelDRAW 2023引入了一些全新的设计工具&#xff0c;使用户…

Spring Boot配置多个Kafka数据源

一、配置文件 application.properties配置文件如下 #kafka多数据源配置 #kafka数据源一&#xff0c;日志审计推送 spring.kafka.one.bootstrap-servers172.19.12.109:32182 spring.kafka.one.producer.retries0 spring.kafka.one.producer.properties.max.block.ms5000 #kafk…

再谈配置maven镜像

之前写过两篇 2016年写的 maven的settings.xml配置maven的settings.xml配置-CSDN博客 2018年写的 配置同济的maven镜像 配置同济的maven镜像_maven gsls200808-CSDN博客 为什么要再谈&#xff0c;因为又出幺蛾子了。spring初始化工具会默认生成带Maven Wrapper的项目结构。让…

微信小程序开发之自定义组件(会议OA项目其他页面搭建)

目录 前言 一、WeChat中的自定义组件 1. 基本概述 2. 包含文件及作用 3. 自定义组件的作用 4.使用步骤&#xff1a; 二、tabs组件及会议管理布局 tabs组件 1. 创建组件 准备 创建 使用组件 会议管理布局 tabs.wxml指定组件模版 tabs.wxss完成样式设计 tabs.js定义属…