如何用Task函数批量上传Firebase图片并获URL？代码纠错与效率对比

一、第一段协程逐个上传代码的正确性 #

这段代码是正确的，逻辑没问题：

• 通过for循环结合await()实现串行上传，每个文件的上传、URL获取都会挂起协程，确保前一个完成后再处理下一个，不会出现异步遗漏的情况。
• 异常被try-catch捕获，返回对应的Success/Failure封装类，符合协程的异常处理逻辑。
• 最终返回的downloadUrls是完整的所有文件URL列表。

完整代码（修正转义符号后）：

override suspend fun addProductImagesToFirebaseStorage(productImages: List<Uri>): AddProductImagesResponse {
    return try {
        val downloadUrls: MutableList<Uri> = arrayListOf()

        for (item in productImages) {
            val productDownloadUrl = categoryImageStorage.reference.child("HomeFeed").child("Products")
                .child("Product${UUID.randomUUID()}")
                .putFile(item).await()
                .storage.downloadUrl.await()
            downloadUrls.add(productDownloadUrl)
        }

        Success(downloadUrls)
    } catch (e: Exception) {
        Failure(e)
    }
}

二、第二段Tasks.whenAll代码的问题及纠错 #

原代码有三个核心问题：

1. forEach里调用了await()，导致上传任务还是串行执行，完全浪费了whenAll的并行能力；
2. 在协程里用addOnSuccessListener异步回调，函数会直接返回空的downloadUrls，因为回调还没执行；
3. downloadUrls.add(it)错误，whenAllSuccess的回调参数是所有结果的列表，直接添加会把整个列表作为单个元素存入。

纠正后的代码（基于Tasks+协程） #

override suspend fun addTestProductImagesToFirebase(testImages: List<Uri>): AddProductImagesResponse {
    return try {
        // 为每个文件创建「上传→获取URL」的链式Task，不立即等待完成
        val taskList = testImages.map { uri ->
            val uploadTask = categoryImageStorage.reference
                .child("HomeFeed")
                .child("Products")
                .child("Product${UUID.randomUUID()}")
                .putFile(uri)
            
            // 上传完成后链式获取下载URL
            uploadTask.continueWithTask { task ->
                if (!task.isSuccessful) {
                    throw task.exception ?: Exception("文件上传失败")
                }
                task.result.storage.downloadUrl
            }
        }

        // 用await()挂起协程，等待所有Task完成，直接拿到结果列表
        val downloadUrls = Tasks.whenAllSuccess<Uri>(taskList).await()
        Success(downloadUrls)
    } catch (e: Exception) {
        Failure(e)
    }
}

更贴合Kotlin协程风格的并行实现 #

override suspend fun addTestProductImagesToFirebase(testImages: List<Uri>): AddProductImagesResponse {
    return try {
        // 启动多个并行协程处理上传
        val deferredList = testImages.map { uri ->
            coroutineScope {
                async {
                    categoryImageStorage.reference
                        .child("HomeFeed")
                        .child("Products")
                        .child("Product${UUID.randomUUID()}")
                        .putFile(uri).await()
                        .storage.downloadUrl.await()
                }
            }
        }

        // 等待所有协程完成，获取结果列表
        val downloadUrls = deferredList.awaitAll()
        Success(downloadUrls)
    } catch (e: Exception) {
        Failure(e)
    }
}

三、Task函数上传是否更高效？ #

不是Task函数本身更高效，而是并行执行比串行执行高效：

• 第一段代码是串行上传，总时间等于所有文件上传时间之和，效率最低；
• 用Tasks.whenAllSuccess或协程async+awaitAll实现的并行上传，多个文件同时发起上传请求，总时间接近单个文件的上传时间（受限于网络带宽和Firebase的并发限制，合理并行数建议控制在10个以内）。

两种并行实现的效率差异很小，选哪种取决于项目的技术栈习惯——如果项目已经大量使用Kotlin协程，优先用协程的并行方案；如果更偏向原生Task API，用whenAllSuccess的方案也没问题。

内容的提问来源于stack exchange，提问作者Shiva s