前言

需要掌握kotlin 协程基础概念和用法

先看使用情况 在viewmodel 中

 fun login() {
        val map = hashMapOf(                         // 传参
            "username" to (username.value ?: ""),
            "password" to (passwrod.value ?: "")
        )
        loadHttp(
            request = { ApiClient.userApi.login(map) },  // 请求
            resp = { loginResult.postValue(it) },       // 响应回调
        )
    }

如果不想在viewmodel中使用，http请求可在组件中直接使用

 bind.tvLogin3.onClick {
            val usename = bind.etUser.text.toString().trim()
            val pwd = bind.etPwd.text.toString().trim()
            lifecycleScope.loadHttp(
                request = { ApiClient.userApi.login(usename,pwd) },  // 请求
                resp = { loginOk(it) }                              // 响应
            )
        }

如果是在子线程中执行网络任务

class TaskTask1() : Runnable {
    override fun run() {
        val data = runBlocking {             //阻塞当前线程
           ApiClient.appApi.getBanner() 
        }
        //线程继续执行
        if (data.code== 0) {

        }

    }
}

OkHttp 和 Retrofit 的DC单例封装

object RetrofitClient {

    //---------------------------------OkHttp-------------------------------
    @JvmStatic
    val okClient by lazy(LazyThreadSafetyMode.SYNCHRONIZED){
        OkHttpClient.Builder()
            .addInterceptor(BaseUrlInterceptor())
            .addInterceptor(RequestInterceptor())
            .addInterceptor(ResponseInterceptor())
            .addInterceptor(HttpLoggingInterceptor().setLevel(HttpLoggingInterceptor.Level.BODY))
            .build()
    }

    //-------------------------------Retrofit-----------------------------------


    @JvmStatic
    val retrofitClient  by lazy(LazyThreadSafetyMode.SYNCHRONIZED){
        Retrofit.Builder()
            .addConverterFactory(GsonConverterFactory.create())
            .baseUrl(AppConfig.BASE_URL)
            .client(okClient)
            .build()
    }


}

Refrofit Api (方法前需要添加suspend关键字)

interface UserApi {
    /**
     * 登录
     */
    @POST("api/login")
    suspend fun login(@Body map: HashMap<String, String>): Res<LoginModel?>

}

interface AppApi{

    @GET("/article/list/{page}/json")
    suspend fun getPageList(@Path("page")page:String): Res<PageList<InfoModel>>

    @GET("banner/list")
    suspend fun getBanner(): Res<MutableList<BannerDataModel>>
}

Refrofit Api 的DC单例

object ApiClient {

    //api 可自行扩展

   @JvmStatic
    val appApi by lazy(LazyThreadSafetyMode.SYNCHRONIZED){
        retrofitClient.create(AppApi::class.java)
    }

    @JvmStatic
    val userApi by lazy(LazyThreadSafetyMode.SYNCHRONIZED){
        retrofitClient.create(UserApi::class.java)
    }
}

BaseViewModel 中的封装

fun <T> loadHttp(
        request: suspend CoroutineScope.() -> Res<T>,  // 请求
        resp: (T?) -> Unit,                            // 相应
        err: (String) -> Unit = { },                   // 错误处理
        end: () -> Unit = {},                          // 最后执行方法
        isShowToast: Boolean = true,                   // 是否toast
        isShowDialog: Boolean = true,                  // 是否显示加载框
    ) {
        viewModelScope.launch {
            try {
                showDialog(isShowDialog)
                val data = request()                   // 请求+响应数据
                if (data.code == ResCode.OK.getCode()) {    //业务响应成功
                    resp(data.data)                   // 响应回调
                } else {
                    showToast(isShowDialog, data.msg)
                    err(data.msg)                       // 业务失败处理
                }
            } catch (e: Exception) {
                err(e.message ?: "")  //可根据具体异常显示具体错误提示   异常处理
                showToast(isShowToast, e.message ?: "")
            } finally {
                end()
                dismissDialog(isShowDialog)
            }
        }

    }

协程的http请求扩展

fun <T> CoroutineScope.loadHttp(
    start: () -> Unit = {},
    request: suspend CoroutineScope.() -> Res<T>,
    resp: (T?) -> Unit,
    err: (String) -> Unit = {},
    end: () -> Unit = {}
) {
    launch {
        try {
            start()
            val data = request()
            if (data.code == ResCode.OK.getCode()) {
                resp(data.data)
            } else {
                err(data.msg)
            }
        } catch (e: Exception) {
            err(e.message ?: "")  //可根据具体异常显示具体错误提示
            Log.e("HttpClient", "异常:" + e.message)
        } finally {
            end()
        }
    }
}

结尾

代码已开源
https://github.com/ruirui1128/jetpack-hilt-flow-mvvm.git