MVVMLin网络请求封装：Retrofit+FlowAdapterFactory实现优雅API调用

MVVMLin网络请求封装RetrofitFlowAdapterFactory实现优雅API调用【免费下载链接】MVVMLin一个基于MVVM用KotlinRetrofit协程ViewbindingFlow来封装的快速开发框架项目地址: https://gitcode.com/gh_mirrors/mv/MVVMLinMVVMLin是一个基于MVVM架构采用KotlinRetrofit协程ViewbindingFlow封装的快速开发框架。本文将详细介绍如何通过FlowAdapterFactory实现网络请求的优雅封装帮助开发者简化API调用流程提升代码质量与开发效率。为什么选择RetrofitFlow组合在Android开发中网络请求是核心模块之一。传统的Callback方式容易导致回调地狱而Retrofit结合Kotlin Flow的响应式编程模式能够以更简洁的代码处理异步数据流同时提供生命周期感知能力有效避免内存泄漏。MVVMLin框架通过FlowAdapterFactory将Retrofit的Call对象转换为Flow数据流实现了以下优势简化代码用协程替代回调代码更线性直观响应式处理支持数据变化监听与事件流操作错误统一处理集中管理网络异常与业务错误生命周期感知自动绑定UI生命周期避免无效数据更新FlowAdapterFactory核心实现解析1. 适配器工厂创建FlowAdapterFactory是连接Retrofit与Flow的桥梁其核心作用是将Retrofit的Call对象适配为Flow数据流。关键代码位于mvvmlin/src/main/java/com/aleyn/mvvm/adapter/FlowAdapterFactory.ktclass FlowAdapterFactory private constructor(private val async: Boolean) : CallAdapter.Factory() { override fun get(returnType: Type, annotations: Arrayout Annotation, retrofit: Retrofit): CallAdapter*, *? { val rawType getRawType(returnType) if (rawType ! Flow::class.java) return null // 处理Flow泛型类型 val flowType getParameterUpperBound(0, returnType as ParameterizedType) return if (getRawType(flowType) Response::class.java) { FlowCallAdapter(getParameterUpperBound(0, flowType as ParameterizedType), false, async) } else { FlowCallAdapter(flowType, true, async) } } companion object { JvmStatic fun create(async: Boolean false) FlowAdapterFactory(async) } }该实现通过Retrofit的CallAdapter.Factory接口检查返回类型是否为Flow然后创建对应的FlowCallAdapter实例。2. 网络请求执行器FlowCallAdapter负责实际执行网络请求并转换为Flow流实现代码位于mvvmlin/src/main/java/com/aleyn/mvvm/adapter/FlowCallAdapter.ktclass FlowCallAdapterR : Type( private val responseBodyType: R, private val isBody: Boolean, private val isAsync: Boolean ) : CallAdapterR, Flow* { override fun adapt(call: CallR): Flow* { val callResponse if (isAsync) ASyncCall(call) else SyncCall(call) return if (isBody) bodyFlow(callResponse) else responseFlow(callResponse) } private fun responseFlow(call: CallResponse): FlowResponse* flow { emit(call.call()) } private fun bodyFlow(call: CallResponse): Flow* flow { val response call.call() if (response.isSuccessful) { emit(response.body()!!) } else { throw HttpException(response) } } }核心逻辑根据isAsync参数选择同步或异步请求模式responseFlow直接发射完整Response对象bodyFlow仅发射响应体并自动处理HTTP错误状态3. 框架集成方式在Retrofit客户端配置中添加FlowAdapterFactory代码位于app/src/main/java/com/pcl/mvvm/utils/RetrofitClient.ktval retrofit Retrofit.Builder() .baseUrl(Constant.BASE_URL) .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(FlowAdapterFactory.create(true)) .build()通过FlowAdapterFactory.create(true)启用异步请求模式使网络请求在后台线程执行避免阻塞主线程。实际应用场景1. 定义API接口在app/src/main/java/com/pcl/mvvm/network/api/HomeService.kt中定义Flow返回类型的APIinterface HomeService { GET(banner/json) fun getBanner(): FlowBannerBean GET(article/list/{page}/json) fun getHomeList(Path(page) page: Int): FlowHomeListBean }2. ViewModel中使用在ViewModel中通过Repository调用API并将结果转换为UI状态class HomeViewModel : BaseViewModel() { private val repository by lazy { HomeRepository() } val bannerData MutableStateFlowListBannerBean.DataBean(emptyList()) fun getBanner() { launchUI { repository.getBanner().collect { bannerData.value it.data ?: emptyList() } } } }3. UI层观察数据在Fragment中观察ViewModel的数据变化class HomeFragment : BaseVMFragmentHomeViewModel() { override fun initView() { viewModel.bannerData.observe(viewLifecycleOwner) { banners - bannerAdapter.setList(banners) } viewModel.getBanner() } }错误处理机制MVVMLin框架提供了统一的错误处理机制通过ExceptionHandle.kt集中处理网络异常object ExceptionHandle { fun handleException(e: Throwable): ResponseThrowable { return when (e) { is HttpException - { // 处理HTTP错误状态码 ResponseThrowable(e.code(), e.message()) } is ConnectException - { ResponseThrowable(ERROR.NETWORK_ERROR, 网络连接失败) } // 其他异常处理... else - { ResponseThrowable(ERROR.UNKNOWN, 未知错误) } } } }在ViewModel中通过launchUI函数自动捕获并处理异常无需手动try-catchlaunchUI { // 异常会被自动捕获并处理 repository.getHomeList(page).collect { // 处理正常数据 } }总结与最佳实践通过MVVMLin框架的FlowAdapterFactory实现我们可以简化网络请求代码用Flow替代传统Callback减少模板代码提升代码可读性线性代码结构更符合直觉优化生命周期管理自动绑定UI生命周期避免内存泄漏统一错误处理集中管理各类网络异常建议在实际项目中始终使用launchUI函数执行网络请求确保异常被正确处理根据业务需求选择同步或异步请求模式合理设计数据模型配合Flow的操作符进行数据转换在Repository层统一处理数据缓存逻辑MVVMLin框架的网络请求封装为Android开发提供了一种优雅高效的解决方案帮助开发者更专注于业务逻辑实现提升应用质量与开发效率。【免费下载链接】MVVMLin一个基于MVVM用KotlinRetrofit协程ViewbindingFlow来封装的快速开发框架项目地址: https://gitcode.com/gh_mirrors/mv/MVVMLin创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考