一步步基于ViewModel协程搭建通用网络请求工具

本文次要介绍如何在ViewModel封装通用的网络申请，不过在真正介绍封装前先解说下应用到的基础知识：协程中异样的捕捉

1.协程中异样的捕捉

协程中异样捕捉的形式有两种：

• 常见的try-catch

相比拟于CoroutineExceptionHandler，这种形式能够灵便的捕获可能产生异样的代码块：

lifecycleScope.launch {
    //省略其余逻辑代码
    try {
        val result = 8 / 0
    } catch (e: Exception) {
    }
    //省略其余逻辑代码
}

• 协程上下文元素CoroutineExceptionHandler

这种形式捕获的异样是间接捕获的整个协程块的异样，颗粒度比拟大，短少灵活性。

lifecycleScope.launch(CoroutineExceptionHandler { _, throwable ->
    Log.e("ChapterActivity", "exception occur: ${throwable.message}")
}) {
    //省略其余逻辑代码
    val result = 8 / 0
    //省略其余逻辑代码
}

2.封装网络申请

首先定义一个类，类中别离定义三种函数类型属性，别离用作：发动申请、申请胜利、申请失败。

class Action<T> {
    //发动申请
    var request: (suspend () -> Response<T>)? = null
        private set

    //申请胜利
    var success: ((T) -> Unit)? = null
        private set

    //申请失败
    var error: ((Throwable) -> Unit)? = null
        private set

    fun request(block: suspend () -> Response<T>) {
        request = block
    }

    fun success(block: (T) -> Unit) {
        success = block
    }

    fun error(block: (Throwable) -> Unit) {
        error = block
    }
}

data class Response<T>(val code: Int = -1, val data: T? = null)

定义一个扩大函数netRequest，以DSL的形式创立Action<T>对象：

fun <T> ViewModel.netRequest(block: Action<T>.() -> Unit) {
    val action = Action<T>().apply(block)
}

咱们就能够这样创立Action<T>对象并为其函数类型的属性别离设置值：

netRequest<String> { 
    request { 
        //模仿执行网络耗时
        delay(5* 1000)
        Response("dd")
    }
    success { 
        //申请胜利执行代码逻辑
    }
    error { 
        //申请失败执行的代码逻辑
    }
}

架子基本上咱们曾经搭建起来了，在解决网络申请之前先定义一个异样，专门用于解决申请响应失败的问题。

data class CustomException(val code: Int = -1, val throwable: String? = null) : Exception(throwable)

当初就得在netRequest办法中利用协程来执行网络申请、解决申请后果回调以及异样的捕捉：

fun <T> ViewModel.netRequest(block: Action<T>.() -> Unit) {
    val action = Action<T>().apply(block)

    viewModelScope.launch(CoroutineExceptionHandler { _, throwable ->
        action.error?.invoke(throwable)
    }) {
        val result = withContext(Dispatchers.IO) {
            action.request!!.invoke()
        }
        if (result.code == 0) {
            action.success?.invoke(result.data)
        } else {
            action.error?.invoke(CustomException(result.code, "申请失败"))
        }
    }
}

通过viewModelScope开启一个协程，不过咱们并没有间接在外层的launch就间接指定执行的线程，而是通过withContext指定散发器Dispatchers.IO去独自执行耗时申请，申请完结后会主动将线程从withContext指定的线程中切换到外层launch协程块所在的线程。

如果间接在外层launch间接指定Dispatchers.IO，这就会导致申请胜利action.success和申请失败action.error的执行的环境为非主线程，防止后续开发者再额定解决这种非主线程回调的状况。

通过上述一步步流程，咱们就最终搭建胜利了一个简单网络申请工具类。

搭配Retrofit提供的suspend适配器

com.squareup.retrofit2:retrofit:2.9.0这个版本的retrofit曾经适配了协程的suspend：

判断是否为suspend润饰的申请办法：suspend润饰办法会在办法参数上减少一个Continuation参数：
#RequestFactory.java

在HttpServiceMethod中：

具体的源码就不带大家看了，要害就在于SuspendForBody办法中的adapt办法中，外部会调用OkhttpClient#Call的办法enqueue开启线程去执行网络申请，执行结束之后会再切换到调用申请的地位所在的线程，感兴趣的请自行查看。

喜欢 (0)赏

[搞代码]

分享 (0)