如何在 Kotlin 协程中发送 HTTP 请求而不阻塞主线程

2024-03-18 23:25:30

Kotlin 协程中的 HTTP 请求：告别 runBlocking

前言

协程是一种强大的工具，可帮助我们在 Kotlin 中编写异步和非阻塞代码。然而，使用 runBlocking 来执行 HTTP 请求可能会导致问题。在这篇文章中，我们将探讨为什么应避免使用 runBlocking，并介绍替代方案，以帮助你在 Kotlin 协程中正确执行 HTTP 请求。

为什么应避免 `runBlocking`

runBlocking 函数将当前线程阻塞，直到协程块完成执行。虽然这在测试或调试期间可能很方便，但它不适合在实际应用中使用。阻塞主线程会导致用户界面无响应，并可能导致应用程序崩溃。

替代方案：启动协程

launch 和 async

要解决 runBlocking 的问题，我们可以使用 launch 或 async 函数启动协程。这些函数允许我们在后台执行耗时操作，而不会阻塞当前线程。

使用 launch：

launch {
    val users = createRequest()
    Log.v("_APP_", users.toString())
}

使用 async：

val users = async {
    createRequest()
}

其他提示

使用生命周期感知协程：

如果在 Android 环境中工作，可以使用 lifecycleScope 访问生命周期感知协程。这些协程会自动在 Activity 或 Fragment 的生命周期内运行。

调度器：

在协程中使用适当的调度器很重要。Dispatchers.IO 用于执行 I/O 密集型任务。

协程库：

考虑使用协程库，如 kotlinx.coroutines 或 Turbine，以简化协程的使用。

完整代码示例

使用 launch 函数的完整代码示例：

fun main() = runBlocking {
    launch {
        val users = createRequest()
        Log.v("_APP_", users.toString())
    }
}

suspend fun createRequest(): List<User>? {
    return withContext(Dispatchers.IO) {
        try {
            val client = HttpClient(CIO)
            val response: HttpResponse = client.get("http://10.0.2.2:9999/users")
            client.close()
            val str = response.readText()
            val itemType = object : TypeToken<List<User>>() {}.type
            Gson().fromJson<List<User>>(str, itemType)
        } catch (e: Exception) {
            null
        }
    }
}