Kotlin中如何等待异步函数执行完成并获取下载URL？

你的核心问题是异步任务还没完成就返回了结果：uploadImage调用uploadImageProcess后立刻返回downloadUri，但此时Firebase的上传和获取下载URL的异步回调还没执行，所以拿到的是未更新的初始值。下面用Kotlin协程给出可靠的解决方案：

重构代码为挂起函数（推荐） #

利用Firebase任务的await()扩展（需引入Kotlin协程依赖），将异步操作转为同步写法，确保等待任务完成后再返回URL：

import kotlinx.coroutines.tasks.await

// 改为挂起函数，必须在协程作用域内调用
suspend fun uploadImage(userName: String, uri: Uri): String {
    val ref = createReference(userName)
    Log.d("uploadImageFUNCTION", "Reference: $ref")
    
    return try {
        // 等待上传完成
        val uploadResult = ref.putFile(uri).await()
        // 等待下载URL获取完成
        val downloadUri = uploadResult.storage.downloadUrl.await()
        downloadUri.toString()
    } catch (e: Exception) {
        Log.d("uploadImageFUNCTION", "任务执行失败: ${e.message}")
        throw e // 抛出异常让调用方处理，或返回默认值
    }
}

调用方式 #

必须在协程作用域内调用这个挂起函数，比如在Activity/Fragment用lifecycleScope，在ViewModel用viewModelScope：

// Activity内调用示例
lifecycleScope.launch {
    try {
        val validDownloadUrl = uploadImage("testUser", imageUri)
        // 这里已经拿到可用URL，存入你的对象
        yourTargetObject.downloadUrl = validDownloadUrl
    } catch (e: Exception) {
        // 处理上传或URL获取失败的情况
    }
}

保留原有函数结构的修改方案 #

如果想保留uploadImageProcess的拆分，可以把它也改成挂起函数：

import kotlinx.coroutines.tasks.await

suspend fun uploadImage(userName: String, uri: Uri): String {
    return uploadImageProcess(userName, uri)
}

private suspend fun uploadImageProcess(userName: String, uri: Uri): String {
    val ref = createReference(userName)
    Log.d("uploadImageFUNCTION", "Reference: $ref")
    
    return try {
        // 链式任务直接await，替代回调
        ref.putFile(uri)
            .continueWithTask { task ->
                if (!task.isSuccessful) task.exception?.let { throw it }
                ref.downloadUrl
            }
            .await()
            .toString()
    } catch (e: Exception) {
        Log.d("uploadImageFUNCTION", "错误信息: ${e.message}")
        throw e
    }
}

为什么原代码和之前的async尝试失败？ #

• 原代码的addOnCompleteListener是异步回调，uploadImage函数不会等待回调执行就返回downloadUri，此时URL还未赋值。
• 若之前用async但没成功，大概率是没有在协程作用域内正确调用await()，或者没有将异步任务转为挂起函数，导致依然无法等待结果。

内容的提问来源于stack exchange，提问作者Yam Horin