Swift中Firestore异步查询依赖调用的实现方案求助

你的核心问题是闭包式异步调用无法保证执行顺序，改用Firestore提供的async/await版本API就能轻松解决这个问题，同时让代码逻辑更清晰。以下是具体改造步骤：

1. 改造fetchUsersIFollow为异步函数 #

把原来的闭包回调改成async函数，直接返回关注的用户数组，避免依赖外部状态变量，同时统一错误处理：

private func fetchUsersIFollow() async throws -> [User] {
    guard let userID = FirebaseManager.shared.auth.currentUser?.uid else {
        throw NSError(domain: "AuthError", code: 0, userInfo: [NSLocalizedDescriptionKey: "未登录"])
    }
    
    let db = FirebaseManager.shared.firestore
    let querySnapshot = try await db.collection("Users")
        .document(userID)
        .collection("Following")
        .getDocuments()
    
    return querySnapshot.documents.compactMap {
        try? $0.data(as: User.self)
    }
}

2. 改造fetchReviews为异步函数 #

同样改用async/await，返回单个用户的最新3条评论：

private func fetchLatestReviews(for userID: String) async throws -> [Review] {
    let reviewRef = FirebaseManager.shared.firestore.collection("Reviews")
    
    let querySnapshot = try await reviewRef
        .whereField("uid", isEqualTo: userID)
        .order(by: "createdAt", descending: true)
        .limit(to: 3)
        .getDocuments()
    
    return querySnapshot.documents.compactMap {
        try? $0.data(as: Review.self)
    }
}

3. 协调执行顺序的顶层函数 #

创建一个异步函数，按顺序完成「获取关注用户→批量获取评论→合并排序→更新UI」的流程：

private func fetchFollowedUsersFeed() async {
    do {
        // 第一步：获取所有关注的用户
        let followedUsers = try await fetchUsersIFollow()
        let followedUserIDs = followedUsers.map { $0.id } // 假设User模型有id字段对应documentID
        
        // 第二步：并行获取每个用户的最新评论（比串行更快）
        var allReviews: [Review] = []
        try await withThrowingTaskGroup(of: [Review].self) { group in
            for userID in followedUserIDs {
                group.addTask {
                    try await self.fetchLatestReviews(for: userID)
                }
            }
            
            // 收集所有任务的结果
            for try await reviews in group {
                allReviews.append(contentsOf: reviews)
            }
        }
        
        // 第三步：按时间排序所有评论（可选，让动态按最新顺序展示）
        let sortedReviews = allReviews.sorted { $0.createdAt > $1.createdAt }
        
        // 回到主队列更新UI状态
        DispatchQueue.main.async {
            self.reviews = sortedReviews
        }
    } catch {
        // 处理错误（比如网络问题、权限不足）
        print("获取动态失败：\(error.localizedDescription)")
    }
}

调用方式 #

在需要加载动态的地方（比如viewDidAppear）调用这个顶层函数：

override func viewDidAppear(_ animated: Bool) {
    super.viewDidAppear(animated)
    Task {
        await fetchFollowedUsersFeed()
    }
}

关键说明 #

• 使用async/await让异步代码的执行顺序和同步代码一致，彻底避免回调嵌套问题。
• 用withThrowingTaskGroup并行获取多个用户的评论，比逐个串行调用效率更高。
• 必须在主队列更新UI状态，因为异步任务默认在后台队列执行。

内容的提问来源于stack exchange，提问作者Apekshik Panigrahi