retrofit content-length为0_LiveData+Retrofit 网络请求实战
作者:星星y
链接:https://www.jianshu.com/p/34fb6ffaa684
声明:本文已获星星y
授权发表,转发等请联系原作者授权
RxJava与Retrofit
在出现LiveData之前,Android上实现网络请求最常用的方式是使用Retrofit+Rxjava。通常是RxJavaCallAdapterFactory将请求转成Observable(或者Flowable等)被观察者对象,调用时通过subscribe方式实现最终的请求。为了实现线程切换,需要将订阅时的线程切换成io线程,请求完成通知被观察者时切换成ui线程。代码通常如下:
observable.subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(subscriber)
为了能够让请求监听到生命周期变化,onDestroy时不至于发生view空指针,要需要使用RxLifecycle或AutoDispose让Observable能够监听到Activity和Fragment的生命周期,在适当的生命周期下取消订阅。
LiveData与Retrofit
LiveData和Rxjava中的Observable类似,是一个被观察者的数据持有类。但是不同的是LiveData具有生命周期感知,相当于RxJava+RxLifecycle。LiveData使用起来相对简单轻便,所以当它加入到项目中后,再使用RxJava便显得重复臃肿了(RxJava包1~2M容量)。为了移除RxJava,我们将Retrofit的Call请求适配成LiveData,因此我们需要自定义CallAdapterFactory。根据接口响应格式不同,对应的适配器工厂会有所区别。本次便以广为人知的wanandroid的api为例子,来完成LiveData网络请求实战。
首先根据它的响应格式:
{ data:[],//或者{} errorCode:0, errorMsg:""}
定义一个通用的响应实体ApiResponse
class ApiResponse<T>( var data: T?, var errorCode: Int, var errorMsg: String)
然后我们定义对应的LiveDataCallAdapterFactory
class LiveDataCallAdapterFactory : Factory() { override fun get(returnType: Type, annotations: Array, retrofit: Retrofit): CallAdapter? { if (getRawType(returnType) != LiveData::class.java) return null //获取第一个泛型类型val observableType = getParameterUpperBound(0, returnType as ParameterizedType) val rawType = getRawType(observableType) if (rawType != ApiResponse::class.java) { throw IllegalArgumentException("type must be ApiResponse") } if (observableType !is ParameterizedType) { throw IllegalArgumentException("resource must be parameterized") } return LiveDataCallAdapter(observableType) }}
然后在LiveDataCallAdapter将Retrofit的Call对象适配成LiveData
class LiveDataCallAdapter<T>(private val responseType: Type) : CallAdapter> {override fun adapt(call: Call<T>): LiveData {return object : LiveData() {private val started = AtomicBoolean(false)override fun onActive() {super.onActive()if (started.compareAndSet(false, true)) {//确保执行一次 call.enqueue(object : Callback {override fun onFailure(call: Call<T>, t: Throwable) {val value = ApiResponse(null, -1, t.message ?: "") as T postValue(value) }override fun onResponse(call: Call<T>, response: Response<T>) { postValue(response.body()) } }) } } } }override fun responseType() = responseType}
第一个请求
以首页banner接口(https://www.wanandroid.com/banner/json)为例,完成第一个请求。
新建一个WanApi接口,加入Banner列表api,以及Retrofit初始化方法,为方便查看http请求和响应,加入了okhttp自带的日志拦截器。
interface WanApi { companion object { fun get(): WanApi { val clientBuilder = OkHttpClient.Builder() .connectTimeout(60, TimeUnit.SECONDS) if (BuildConfig.DEBUG) { val loggingInterceptor = HttpLoggingInterceptor() loggingInterceptor.level = HttpLoggingInterceptor.Level.BODY clientBuilder.addInterceptor(loggingInterceptor) } return Retrofit.Builder() .baseUrl("https://www.wanandroid.com/") .client(clientBuilder.build()) .addCallAdapterFactory(LiveDataCallAdapterFactory()) .addConverterFactory(GsonConverterFactory.create()) .build() .create(WanApi::class.java) } } /** * 首页banner */ @GET("banner/json") fun bannerList(): LiveData>>}
BannerVO实体
data class BannerVO( var id: Int, var title: String, var desc: String, var type: Int, var url: String, var imagePath:String)\
我们在MainActivity中发起请求
private fun loadData() { val bannerList = WanApi.get().bannerList() bannerList.observe(this, Observer { Log.e("main", "res:$it") }) }
调试结果如下:
LiveData的map与switchMap操作
LiveData可以通过Transformations的map和switchMap操作,将一个LiveData转成另一种类型的LiveData,效果与RxJava的map/switchMap操作符类似。可以看看两个函数的声明
public static LiveData map(@NonNull LiveData source,@NonNull final Function mapFunction)public static LiveData switchMap(@NonNull LiveData source,@NonNull final Function> switchMapFunction)
根据以上代码,我们可以知道,对应的变换函数返回的类型是不一样的:map是基于泛型类型的变换,而switchMap则返回一个新的LiveData。
还是以banner请求为例,我们将map和switchMap应用到实际场景中:
1: 为了能够手动控制请求,我们需要一个refreshTrigger触发变量,当这个变量被设置为true时,通过switchMap生成一个新的LiveData用作请求banner
private val refreshTrigger = MutableLiveData<Boolean>()private val api = WanApi.get()private val bannerLis:LiveData>> = Transformations.switchMap(refreshTrigger) {//当refreshTrigger的值被设置时,bannerList api.bannerList()}
2: 为了展示banner,我们通过map将ApiResponse转换成最终关心的数据是List
val banners: LiveData> = Transformations.map(bannerList) {
it.data ?: ArrayList()
}
LiveData与ViewModel结合
为了将LiveData与Activity解耦,我们通过ViewModel来管理这些LiveData。
class HomeVM : ViewModel() { private val refreshTrigger = MutableLiveData<Boolean>() private val api = WanApi.get() private val bannerList: LiveData>> = Transformations.switchMap(refreshTrigger) {//当refreshTrigger的值被设置时,bannerList api.bannerList() }val banners: LiveData> = Transformations.map(bannerList) { it.data ?: ArrayList() }fun loadData() { refreshTrigger.value = true }}
在activity_main.xml中加入banner布局,这里使用BGABanner-Android来显示图片
<?xml version="1.0" encoding="utf-8"?><layout xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto"xmlns:tools="http://schemas.android.com/tools"> <data> <variablename="vm"type="io.github.iamyours.wandroid.ui.home.HomeVM"/> data> <LinearLayoutandroid:layout_width="match_parent"android:layout_height="match_parent"android:orientation="vertical">
<cn.bingoogolapple.bgabanner.BGABannerandroid:id="@+id/banner"android:layout_width="match_parent"android:layout_height="120dp"android:paddingLeft="16dp"android:paddingRight="16dp"app:banner_indicatorGravity="bottom|right"app:banner_isNumberIndicator="true"app:banner_pointContainerBackground="#0000"app:banner_transitionEffect="zoom"/>
<TextViewandroid:layout_width="match_parent"android:layout_height="44dp"android:background="#ccc"android:gravity="center"android:onClick="@{()->vm.loadData()}"android:text="加载Banner"/> LinearLayout>layout>
然后在MainActivity完成Banner初始化,通过监听ViewModel中的banners实现轮播图片的展示。
class MainActivity : AppCompatActivity() { lateinit var binding: ActivityMainBinding override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) binding = DataBindingUtil.setContentView(this, R.layout.activity_main) val vm = ViewModelProviders.of(this).get(HomeVM::class.java) binding.lifecycleOwner = this binding.vm = vm initBanner() }
private fun initBanner() { binding.run { val bannerAdapter = BGABanner.Adapter { _, image, model, _ -> image.displayWithUrl(model?.imagePath) } banner.setAdapter(bannerAdapter) vm?.banners?.observe(this@MainActivity, Observer { banner.setData(it, null) }) } }}
最终效果如下:
加载进度显示
SwipeRefreshLayout
请求网络过程中,必不可少的是加载进度的展示。这里我们列举两种常用的的加载方式,一种在布局中的进度条(如SwipeRefreshLayout),另一种是加载对话框。
为了控制加载进度条显示隐藏,我们在HomeVM中添加loading变量,在调用loadData时通过loading.value=true控制进度条的显示,在map中的转换函数中控制进度的隐藏
val loading = MutableLiveData<Boolean>()val banners: LiveData> = Transformations.map(bannerList) { loading.value = false it.data ?: ArrayList()}fun loadData() { refreshTrigger.value = true loading.value = true}
我们在activity_main.xml的外层嵌套一个SwipeRefreshLayout,通过databinding设置加载状态,添加刷新事件
<androidx.swiperefreshlayout.widget.SwipeRefreshLayoutandroid:layout_width="match_parent"android:layout_height="match_parent"app:onRefreshListener="@{() -> vm.loadData()}"app:refreshing="@{vm.loading}"> ...androidx.swiperefreshlayout.widget.SwipeRefreshLayout>
然后我们再看下效果:
加载对话框KProgressHUD
为了能和ViewModel解藕,我们将加载对话框封装到一个Observer中。
class LoadingObserver(context: Context) : Observer<Boolean> { private val dialog = KProgressHUD(context) .setStyle(KProgressHUD.Style.SPIN_INDETERMINATE) .setCancellable(false) .setAnimationSpeed(2) .setDimAmount(0.5f)
override fun onChanged(show: Boolean?) { if (show == null) return if (show) { dialog.show() } else { dialog.dismiss() } }}
然后在MainActivity添加这个Observer
vm.loading.observe(this, LoadingObserver(this))
效果:
我们还可以将LoadingObserver注册到BaseActivity
class BaseActivity : AppCompatActivity() { val loadingState = MutableLiveData<Boolean>() override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) loadingState.observe(this, LoadingObserver(this)) }}
然后在HomeVM中添加一个attachLoading方法
class HomeVM:ViewModel{ fun attachLoading(otherLoadingState: MutableLiveData<Boolean>) { loading.observeForever { otherLoadingState.value = it } }}
最终如果想要显示进度对话框,在BaseActivity到子类中,只需调用vm.attachLoading(loadingState)即可。
分页请求
分页请求是另个一常用请求,它的请求状态就比刷新数据多了几种。以wanandroid首页文章列表api为例,我们在HomeVM中加入page,refreshing,moreLoading,hasMore变量控制分页请求
private val page = MutableLiveData<Int>() //分页数据val refreshing = MutableLiveData<Boolean>()//下拉刷新状态val moreLoading = MutableLiveData<Boolean>()//上拉加载更多状态val hasMore = MutableLiveData<Boolean>()//是否还有更多数据private val articleList = Transformations.switchMap(page) { api.articleList(it)}
val articlePage = Transformations.map(articleList) { refreshing.value = false moreLoading.value = false hasMore.value = !(it?.data?.over ?: false) it.data}
fun loadMore() { page.value = (page.value ?: 0) + 1 moreLoading.value = true}
fun refresh() { loadBanner() page.value = 0 refreshing.value = true}
用SmartRefreshLayout作为分页组件,来实现WanAndroid首页文章列表数据的展示。
绑定SmartRefreshLayout属性和事件
通过@BindingAdapter注解,将绑定SmartRefreshLayout属性和事件封装一样,便于我们在布局文件通过databinding控制它。
新建一个CommonBinding.kt文件,注意在gradle中引入kotlin-kapt
@BindingAdapter(value = ["refreshing", "moreLoading", "hasMore"], requireAll = false)fun bindSmartRefreshLayout( smartLayout: SmartRefreshLayout, refreshing: Boolean, moreLoading: Boolean, hasMore: Boolean) { if (!refreshing) smartLayout.finishRefresh() if (!moreLoading) smartLayout.finishLoadMore() smartLayout.setEnableLoadMore(hasMore)}
@BindingAdapter(value = ["onRefreshListener", "onLoadMoreListener"], requireAll = false)fun bindListener( smartLayout: SmartRefreshLayout, refreshListener: OnRefreshListener?, loadMoreListener: OnLoadMoreListener?) { smartLayout.setOnRefreshListener(refreshListener) smartLayout.setOnLoadMoreListener(loadMoreListener)}
然后在布局中使用
"http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto" xmlns:tools="http://schemas.android.com/tools"> <data> name="vm" type="io.github.iamyours.wandroid.ui.home.HomeVM"/>data> android:id="@+id/refreshLayout" android:layout_width="match_parent" app:onRefreshListener="@{()->vm.refresh()}" app:refreshing="@{vm.refreshing}" app:moreLoading="@{vm.moreLoading}" app:hasMore="@{vm.hasMore}" app:onLoadMoreListener="@{()->vm.loadMore()}" android:layout_height="match_parent"> android:layout_width="match_parent" android:layout_height="match_parent"> android:layout_width="match_parent" android:orientation="vertical" android:layout_height="wrap_content"> android:id="@+id/banner" android:layout_width="match_parent" android:layout_height="140dp" app:banner_indicatorGravity="bottom|right" app:banner_isNumberIndicator="true" app:banner_pointContainerBackground="#0000" app:banner_transitionEffect="zoom"/> android:id="@+id/recyclerView" android:layout_width="match_parent" android:layout_marginTop="5dp" tools:listitem="@layout/item_article" android:layout_height="wrap_content"/>
分页实现
然后在MainActivity中完成RecyclerView的逻辑
class MainActivity : AppCompatActivity() { lateinit var binding: ActivityMainBinding private val adapter = ArticleAdapter() override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) binding = DataBindingUtil.setContentView(this, R.layout.activity_main) val vm = ViewModelProviders.of(this).get(HomeVM::class.java) binding.lifecycleOwner = this binding.vm = vm binding.executePendingBindings() initBanner() initRecyclerView() binding.refreshLayout.autoRefresh() }
private fun initRecyclerView() { binding.recyclerView.let { it.adapter = adapter it.layoutManager = LinearLayoutManager(this) } binding.vm?.articlePage?.observe(this, Observer { it?.run { if (curPage == 1) { adapter.clearAddAll(datas) } else { adapter.addAll(datas) } } }) }
private fun initBanner() { ... }}
最终效果:
项目地址https://github.com/iamyours/Wandroid
推荐阅读
Android 官方架构组件(二)——LiveData
LiveData 源码分析之事件总线 LiveBus 实现
扫一扫 关注我的公众号
如果你想要跟大家分享你的文章,欢迎投稿~
retrofit content-length为0_LiveData+Retrofit 网络请求实战相关推荐
- Android RxJava与Retrofit与RecyclerView与Fresco结合网络请求
展示效果 首先添加依赖 compile 'com.squareup.retrofit2:retrofit:2.0.1'compile 'com.squareup.retrofit2:converter ...
- 从源码处理一理Retrofit的异步网络请求如何把结果切换到主线程
前提,需要具备的知识点是:动态代理,反射,注解. 场景:某日面试的时候被问道,Retrofit异步网络请求是怎么把结果返回给主线程的? 答曰:具体原理不是很清楚,最后应该是通过handler把结果发送 ...
- 鸿蒙网络请求(原生+zzr+OkHttp+Retrofit)
鸿蒙网络请求 网络请求的一些概念 鸿蒙网络请求 基础配置 网络请求 原生网络请求HttpURLConnection 原生网络Get请求 原生网络Post请求 ZZR封装的网络请求 配置 使用 OkHt ...
- Retrofit网络请求参数注解,@Path、@Query、@Post、Body等总结(超级实用)以及以Json格式和form-data格式提交数据
我总结的不是很全,这位博主介绍的十分详细:超级实用 https://blog.csdn.net/guohaosir/article/details/78942485 Retrofit 以Json格式提 ...
- 带你一步步剖析Retrofit-源码解析:一款基于-OkHttp-实现的网络请求框架
int question = value.indexOf('?'); if (question != -1 && question < value.length() - 1) { ...
- kotlin 用协程做网络请求_中国电信营业厅: 感受 Kotlin 的 quot;加速度quot;
"我们手上是一个很成熟的项目,所以毫无疑问需要保留 Java 代码,目前只会在新开发的页面中使用 Kotlin,并已经感受到了它带来的便利.随着功能的迭代,我们相信更多的功能会转而使用 Ko ...
- flutter 项目实战二 网络请求
本项目借用 逛丢 网站的部分数据,仅作为 flutter 开发学习之用. 逛丢官方网址:https://guangdiu.com/ flutter windows开发环境设置 flutter 项目实战 ...
- 模仿Retrofit封装一个使用更简单的网络请求框架
本文已授权微信公众号:郭霖 在微信公众号平台原创首发.会用Retrofit了?你也能自己动手写一个! 前言 想封装一套网络请求,不想直接上来就用别人写好的,或者说对项目可以更好的掌控,所以自己模仿着 ...
- Android中网络请求框架的封装-Retrofit+RxJava+OkHttp
Retrofit注解 请求方法 注解代码 请求格式 @GET GET请求 @POST POST请求 @DELETE DELETE请求 @HEAD HEAD请求 @OPTIONS OPTIONS请求 @ ...
最新文章
- 32位网卡驱动 2008_DPDK之网卡收包流程
- 一个新手学linux!
- java常用技术名词解析
- AngularJS中关于ng-class和*ngIf指令
- SAP 电商云 Spartacus UI 设置 delivery mode 在 3G 慢速网络下的排队效果
- Android之SwipeRefreshLayout
- python网络爬虫面试题,搞定这套Python爬虫面试题(面试会so easy)
- 美图影像节发布六款新品 满足用户生活、工作全方位变美需求
- memcached简单的使用教程
- 江西6地列入国家智慧城市试点 智慧城市啥模样专家来描绘
- 禁用微信浏览器的下拉_解决微信浏览器禁止下拉查看真实域名网址的问题
- 计算机固态硬盘作用,固态硬盘是什么及作用
- history的使用方法
- win7更新错误代码80072efe怎么解决?
- 6、淘宝双11数据分析与预测
- 滴滴6月或发布造车计划;头部App上线一键关闭 “个性化推荐 ”​;下载捆绑,“高速下载”竟为元凶 | EA周报...
- DataMatrix编码 关于libdmtx的使用
- layui数据表格导入Excel,后端打印乱码
- C# 代码 Unicode码和字符串相互转换
- 163网页邮箱的实现
热门文章
- SAP外币评估 fagl_fc_val 多评估与少评估问题
- 美团医美发起“至美行动”,单月拦截六万余条虚假医美评价
- 拼购电商不是团购,但扎的的却是三四五线城市老百姓的心
- ibatis mysql 配置文件详解_MyBatis Generator 配置文件详解
- fastdfs笔记_fastDFS 命令笔记-阿里云开发者社区
- Python基础入门:使用openpyxl读写Excel文件
- Python字符串的定义与常用操作
- 一文读懂:从 Python 打包到 CLI 工具
- 计算机网络通信有哪些研究课题,科研进阶 | 西北大学 | 电子信息工程、通信与信息系统:通信与计算机网络...
- c++ mysql 配置_C++--mysql相关配置