两种方式封装Retrofit+协程，实现优雅快速的网络请求
作者：零先生 链接：https://juejin.cn/post/6993294489125126151
目的
- 简单调用、少写重复代码
- 不依赖第三方库（只含Retrofit+Okhttp+协程）
- 完全不懂协程也能立马上手（模板代码）
用Kotlin的方式写Kotlin代码，什么意思呢？对比一下下面2个代码就知道了：
mViewModel.wxArticleLiveData.observe(this, object : IStateObserver<List<WxArticleBean>>() {
overridefunonSuccess(data: List<WxArticleBean>?) {
}
overridefunonError() {
}
})
mViewModel.wxArticleLiveData.observeState(this) {
onSuccess { data: List<WxArticleBean>? ->
}
onError {
}
}
既然是用Kotlin了，就不要用Java的方式写接口回掉了，DSL表达式不香么？
提供两种方式实现：
- 方式一代码量更少，网络请求自带Loading，不需要手动调用Loading
- 方式二解耦更彻底
两种方式设计思路在解耦这一块存在差异，看具体需求，没有谁好谁差，依照自己的项目，哪个更方便用哪个。
基于官方架构的封装：
一、封装一
Activity中的代码示例
点击请求网络
mViewModel.getArticleData()
设置监听，只监听成功的结果，使用默认异常处理
mViewModel.wxArticleLiveData.observeState(this) {
onSuccess { data ->
Log.i("wutao","网络请求的结果是：$data")
}
}
如果需要单独处理每一个回调
这些回调都是可选的，不需要可不实现
mViewModel.wxArticleLiveData.observeState(this) {
onSuccess { data ->
Log.i("wutao","网络请求的结果是：$data")
}
onEmpty{
Log.i("wutao", "返回的数据是空，展示空布局")
}
onFailed {
Log.i("wutao", "后台返回的errorCode: $it")
}
onException { e ->
Log.i("wutao","这是非后台返回的异常回调")
}
onShowLoading {
Log.i("wutao","自定义单个请求的Loading")
}
onComplete {
Log.i("wutao","网络请求结束")
}
}
请求自带Loading
很多网络请求都需要Loading，不想每次都写
onShowLoading{}方法，也so easy。mViewModel.wxArticleLoadingLiveData.observeState(this, this) {
onSuccess { data ->
Log.i("wutao","网络请求的结果是：$data")
}
}
observeState()第二个方法传入ui的引用就可，这样单个网络请求之前会自动加载Loading，成功或者失败自动取消Loading。上面代码都是Activity中，我们来看下
ViewModel中。ViewModel中代码示例
classMainViewModel{
privateval repository by lazy { WxArticleRepository() }
val wxArticleLiveData = StateLiveData<List<WxArticleBean>>()
funrequestNet() {
viewModelScope.launch {
repository.fetchWxArticle(wxArticleLiveData)
}
}
}
很简单，引入对应的数据仓库Repo，然后使用协程执行网络请求方法。来看下Repo中的代码。
Repository中代码示例
classWxArticleRepository : BaseRepository() {
privateval mService by lazy { RetrofitClient.service }
suspendfunfetchWxArticle(stateLiveData: StateLiveData<List<WxArticleBean>>) {
executeResp(stateLiveData, mService::getWxArticle)
}
}
interfaceApiService{
@GET("wxarticle/chapters/json")
suspendfungetWxArticle(): BaseResponse<List<WxArticleBean>>
}
获取一个
Retrofit实例，然后调用ApiService接口方法。封装一的优势
- 代码很简洁，不需要手写线程切换代码，没有很多的接口回调。
- 自带Loading状态，不需要手动启用Loading和关闭Loading。
- 数据驱动ui，以
LiveData为载体，将页面状态和网络结果通过在LiveData返回给ui。
项目地址：
https://github.com/ldlywt/FastJetpack (分支名字是：withLoading)
封装一的不足
- 封装一的核心思想是：一个LiveData贯穿整个网络请求链。这是它的优势，也是它的劣势。
- 解耦不彻底，违背了"在应用的各个模块之间设定明确定义的职责界限"的思想
- LiveData监听时，如果需要Loading，
BaseActivity都需要实现带有Loading方法接口。 obserState()方法第二个参数中传入了UI引用。- 不能达到"看方法如其意"，如果是刚接触，会有很多疑问：为什么需要一个livedata作为方法的参数。网络请求的返回值去哪了？
- 封装一还有一个最大的缺陷：对于是多数据源，封装一就展示了很不友好的一面。
Repository是做一个数据仓库，项目中获取数据的方式都在这里同意管理，网络获取数据只是其中一个方式而已。
如果想加一个从数据库或者缓存中获取数据，封装一想改都不好改，如果强制改就破坏了封装，侵入性很大。
针对封装一的不足，优化出了封装二。
二、封装二
思路
- 想要解决上面的不足，不能以
LiveData为载体贯穿整个网络请求。 Observe()方法中去掉ui引用，不要小看一个ui引用，这个引用代表着具体的Activity跟Observe耦合起来了，并且Activity还要实现IUiView接口。- 网络请求跟Loading状态分开了，需要手动控制Loading。
- Repository中的方法都有返回值，会返回结果，也不需要用livedata作为方法参数。
LiveData只存在于ViewModel中，LiveData不会贯穿整个请求链。Repository中也不需要LiveData的引用，Repository的代码就是单纯的获取数据。- 针对多数据源，也非常好处理。
- 跟ui没任何关系，可以完全作为一个独立的Lib使用。
Activity中代码
// 请求网络
mViewModel.login("username", "password")
// 注册监听
mViewModel.userLiveData.observeState(this) {
onSuccess {data ->
mBinding.tvContent.text = data.toString()
}
onComplete {
dismissLoading()
}
}
observeState()中不再需要一个ui引用了。ViewModel中
classMainViewModel{
val userLiveData = StateLiveData<User?>()
funlogin(username: String, password: String) {
viewModelScope.launch {
userLiveData.value = repository.login(username, password)
}
}
}
通过
livedata的setValue或者postValue方法将数据发送出去。Repository中
suspendfunlogin(username: String, password: String): ApiResponse<User?> {
return executeHttp {
mService.login(username, password)
}
}
Repository中的方法都返回请求结果，并且方法参数不需要livedata。Repository完全可以独立出来了。针对多数据源
// WxArticleRepository
classWxArticleRepository : BaseRepository() {
privateval mService by lazy {
RetrofitClient.service
}
suspendfunfetchWxArticleFromNet(): ApiResponse<List<WxArticleBean>> {
return executeHttp {
mService.getWxArticle()
}
}
suspendfunfetchWxArticleFromDb(): ApiResponse<List<WxArticleBean>> {
return getWxArticleFromDatabase()
}
}
// MainViewModel.kt
privateval dbLiveData = StateLiveData<List<WxArticleBean>>()
privateval apiLiveData = StateLiveData<List<WxArticleBean>>()
val mediatorLiveDataLiveData = MediatorLiveData<ApiResponse<List<WxArticleBean>>>().apply {
this.addSource(apiLiveData) {
this.value = it
}
this.addSource(dbLiveData) {
this.value = it
}
}
可以看到，封装二更符合职责单一原则，Repository单纯的获取数据，ViewModel对数据进行处理和发送。
项目地址：
https://github.com/ldlywt/FastJetpack (Master分支)
三、实现原理
数据来源于鸿洋大神的玩Android 开放API
回数据结构定义:
{
"data": ...,
"errorCode": 0,
"errorMsg": ""
}
封装一和封装二的代码差距很小，主要看封装二。
定义数据返回类
openclassApiResponse<T>(
openvaldata: T? = null,
openval errorCode: Int? = null,
openval errorMsg: String? = null,
openval error: Throwable? = null,
) : Serializable {
val isSuccess: Boolean
get() = errorCode == 0
}
dataclassApiSuccessResponse<T>(val response: T) : ApiResponse<T>(data = response)
classApiEmptyResponse<T> : ApiResponse<T>()
dataclassApiFailedResponse<T>(overrideval errorCode: Int?, overrideval errorMsg: String?) : ApiResponse<T>(errorCode = errorCode, errorMsg = errorMsg)
dataclassApiErrorResponse<T>(val throwable: Throwable) : ApiResponse<T>(error = throwable)
基于后台返回的基类，根据不同的结果，定义不同的状态数据类。
网络请求统一处理：
BaseRepositoryopenclassBaseRepository{
suspendfun<T>executeHttp(block: suspend () -> ApiResponse<T>): ApiResponse<T> {
runCatching {
block.invoke()
}.onSuccess { data: ApiResponse<T> ->
return handleHttpOk(data)
}.onFailure { e ->
return handleHttpError(e)
}
return ApiEmptyResponse()
}
/**
* 非后台返回错误，捕获到的异常
*/
privatefun<T>handleHttpError(e: Throwable): ApiErrorResponse<T> {
if (BuildConfig.DEBUG) e.printStackTrace()
handlingExceptions(e)
return ApiErrorResponse(e)
}
/**
* 返回200，但是还要判断isSuccess
*/
privatefun<T>handleHttpOk(data: ApiResponse<T>): ApiResponse<T> {
returnif (data.isSuccess) {
getHttpSuccessResponse(data)
} else {
handlingApiExceptions(data.errorCode, data.errorMsg)
ApiFailedResponse(data.errorCode, data.errorMsg)
}
}
/**
* 成功和数据为空的处理
*/
privatefun<T>getHttpSuccessResponse(response: ApiResponse<T>): ApiResponse<T> {
returnif (response.data == null || response.datais List<*> && (response.dataas List<*>).isEmpty()) {
ApiEmptyResponse()
} else {
ApiSuccessResponse(response.data!!)
}
}
}
Retrofit协程的错误码处理是通过异常抛出来的，所以通过
try...catch来捕捉非200的错误码。包装成不同的数据类对象返回。扩展LiveData和Observer
在LiveData的
Observer()来判断是哪种数据类，进行相应的回调处理：abstractclassIStateObserver<T> : Observer<ApiResponse<T>> {
overridefunonChanged(apiResponse: ApiResponse<T>) {
when (apiResponse) {
is ApiSuccessResponse -> onSuccess(apiResponse.response)
is ApiEmptyResponse -> onDataEmpty()
is ApiFailedResponse -> onFailed(apiResponse.errorCode, apiResponse.errorMsg)
is ApiErrorResponse -> onError(apiResponse.throwable)
}
onComplete()
}
再扩展LiveData，通过
kotlin的DSL表达式替换java的callback回调，简写代码。classStateLiveData<T> : MutableLiveData<ApiResponse<T>>() {
funobserveState(owner: LifecycleOwner, listenerBuilder: ListenerBuilder.() -> Unit) {
val listener = ListenerBuilder().also(listenerBuilder)
val value = object : IStateObserver<T>() {
overridefunonSuccess(data: T) {
listener.mSuccessListenerAction?.invoke(data)
}
overridefunonError(e: Throwable) {
listener.mErrorListenerAction?.invoke(e) ?: toast("Http Error")
}
overridefunonDataEmpty() {
listener.mEmptyListenerAction?.invoke()
}
overridefunonComplete() {
listener.mCompleteListenerAction?.invoke()
}
overridefunonFailed(errorCode: Int?, errorMsg: String?) {
listener.mFailedListenerAction?.invoke(errorCode, errorMsg)
}
}
super.observe(owner, value)
}
}
四、总结
封装一：代码量更少，可以根据项目需要封装一些具体的ui相关，开发起来更快速，用起来更爽。封装二：解耦更彻底，可以独立于ui模块运行。个人认为，框架设计主要还是服务于自己的项目需求（开源项目除外），符合设计模式和设计原则更好，但是不满足也没关系，适合自己项目需求，能节省自己的时间，就是好的。
我们自己项目中使用，怎么轻便，怎么快速，怎么写的爽就怎么来。
---END---
推荐阅读： 简单易用的Jetpack Compose版骨架屏，不来了解一下~
自定义可点击、可滑动的通用RatingBar
Gradle 7.0 依赖统一管理的全新方式！了解一下
不做跟风党，LiveData，StateFlow，SharedFlow 的使用场景对比
快手开源项目KOOM分析，一个高性能线上内存监控方案！
Android 自定义控件 | 弹幕的两种实现及性能对比
在Flutter中实现酷炫的文本动画（含代码示例） 更文不易，点个“在看”支持一下👇
关键词
数据
状态
方法
代码
协程
最新评论
推荐文章
作者最新文章
你可能感兴趣的文章
Copyright Disclaimer: The copyright of contents (including texts, images, videos and audios) posted above belong to the User who shared or the third-party website which the User shared from. If you found your copyright have been infringed, please send a DMCA takedown notice to [email protected]. For more detail of the source, please click on the button "Read Original Post" below. For other communications, please send to [email protected].
版权声明：以上内容为用户推荐收藏至CareerEngine平台，其内容（含文字、图片、视频、音频等）及知识版权均属用户或用户转发自的第三方网站，如涉嫌侵权，请通知[email protected]进行信息删除。如需查看信息来源，请点击“查看原文”。如需洽谈其它事宜，请联系[email protected]。
版权声明：以上内容为用户推荐收藏至CareerEngine平台，其内容（含文字、图片、视频、音频等）及知识版权均属用户或用户转发自的第三方网站，如涉嫌侵权，请通知[email protected]进行信息删除。如需查看信息来源，请点击“查看原文”。如需洽谈其它事宜，请联系[email protected]。