Android 使用 OkHttp 和协程下载多个文件

Question

在我的应用程序中，我从 api 获得了一组指向某些图像的 url，并且需要从这些 url 中创建 Bitmap 对象才能在 UI 中显示图像。我看到 android 文档建议使用协程来执行此类异步任务，但我不确定如何正确执行。

在我的 http 客户端使用 OkHttp，我尝试了以下方法：

GlobalScope.launch {
                    val gson = Gson();
                    val parsedRes = gson.fromJson(
                        response.body?.charStream(),
                        Array<GoodreadsBook>::class.java
                    );
                    // Create the bitmap from the imageUrl
                    for (i in 0 until parsedRes.size) {
                        val bitmap =
                            GlobalScope.async { createBitmapFromUrl(parsedRes[i].best_book.image_url) }
                        parsedRes[i].best_book.imageBitmap = bitmap.await();
                    }
                   searchResults.postValue(parsedRes)
                }

response 是我从我的 API 中返回的，searchResults 是一个 LiveData，用于保存已解析的响应。 另外，这是我从这些网址获取图像的方式：

suspend fun createBitmapFromUrl(url: String): Bitmap? {
    val client = OkHttpClient();
    val req = Request.Builder().url(url).build();
    val res = client.newCall(req).execute();
    return BitmapFactory.decodeStream(res.body?.byteStream())
}

即使每个 fetch 操作都是在一个单独的协程上完成的，它仍然太慢了。有更好的方法吗？如果有一个针对协程进行优化的 http 客户端，我可以使用任何其他 http 客户端，尽管我是 Kotlin 的新手，所以我不知道。

Answer 1

首先createBitmapFromUrl(url: String) 同步执行所有操作，您必须首先阻止它们阻塞协程线程，您可能想要使用Dispatchers.IO，因为回调不是协程中最典型的事情。

val client = OkHttpClient()  // preinitialize the client

suspend fun createBitmapFromUrl(url: String): Bitmap? = withContext(Dispatchers.IO) {
    val req = Request.Builder().url(url).build()
    val res = client.newCall(req).execute()
    BitmapFactory.decodeStream(res.body?.byteStream())
}

现在，当您调用 bitmap.await() 时，您只是在说“嘿，等待延迟的 bitmap，一旦完成，就恢复循环以进行下一次迭代”

因此，您可能希望在协程本身中进行赋值以阻止它暂停循环，否则为此创建另一个循环。我会选择第一个选项。

scope.launch {
    val gson = Gson();
    val parsedRes = gson.fromJson(
        response.body?.charStream(),
        Array<GoodreadsBook>::class.java
    );
    // Create the bitmap from the imageUrl
    for (i in 0 until parsedRes.size) {
        launch {
            parsedRes[i].best_book.imageBitmap = createBitmapFromUrl(parsedRes[i].best_book.image_url)
        }
    }
}

Answer 2

使用如下库，它不使用阻塞 execute 方法，而是从异步 enqueue 桥接。

https://github.com/gildor/kotlin-coroutines-okhttp

suspend fun main() {
    // Do call and await() for result from any suspend function
    val result = client.newCall(request).await()
    println("${result.code()}: ${result.message()}")
}

这基本上做的是以下内容

public suspend fun Call.await(): Response {
    return suspendCancellableCoroutine { continuation ->
        enqueue(object : Callback {
            override fun onResponse(call: Call, response: Response) {
                continuation.resume(response)
            }

            override fun onFailure(call: Call, e: IOException) {
                if (continuation.isCancelled) return
                continuation.resumeWithException(e)
            }
        })

        continuation.invokeOnCancellation {
            try {
                cancel()
            } catch (ex: Throwable) {
                //Ignore cancel exception
            }
        }
    }
}