Firestore获取新闻流挂起函数耗时过长，如何优化？

问题背景 #

你的Firestore数据库结构如下：

users->uniqueUserId 
|-->UsersProfileInfo--->Profile(document)
|-->FeedNewsFeed |--->unique documents for each newsfeed
                 |--->unique documents for each newsfeed
                 |--->unique documents for each newsfeed

当前实现中，为了获取所有用户的新闻流，你使用嵌套循环+多次串行Firestore请求，导致挂起函数执行耗时极长，核心问题在于多次嵌套网络请求和串行处理逻辑。

当前代码的性能瓶颈 #

你的查询函数存在几个关键问题：

• 串行遍历每个用户，每个用户的Profile查询、Feed查询依次执行，总耗时为所有请求时间的累加
• 遍历FeedNewsFeed快照时，重复调用thisDocRef.get().await()，但documentOfFeed已包含文档数据，无需额外发起请求
• 对象创建逻辑冗余，循环内重复实例化NewsFeedClass

当前代码：

suspend fun getAllNewsFeeds(): ArrayList<NewsFeedClass> {

    list.clear()

    val querySnapshot = collectionRef.get().await()

    //Traversing through each document in collection
    for (document in querySnapshot) {

        val currDocRef = document.reference
        //Getting user name
        val userName =
                 currDocRef
                .collection(Constants.UserProfileInfo)
                .document(Constants.Profile)
                .get()
                .await()
                .toObject(FeedUserName::class.java)?.userName


       // adding username in newsFeedClass for displaying on newsfeed
        val newsFeedClass = NewsFeedClass()
        if (userName != null) {
            newsFeedClass.username = userName
        }
        //getting QuerySnapshot from FeedNewsFeed collection
        val newsFeedQuerySnapshot =
                 currDocRef
                .collection(Constants.FeedNewsFeeds).get().await()
        //Traversing through each document in 
        // collecting and respectively  adding feed on newsFeedClass
        //adding newsFeedClass to list 
        for (documentOfFeed in newsFeedQuerySnapshot) {

            val thisDocRef = documentOfFeed.reference

            val feed =
                thisDocRef
                .get().await().toObject<FeedNewsFeed>()

            if (feed != null) {
                newsFeedClass.content = feed.newsfeed
                list.add(NewsFeedClass(newsFeedClass.username, newsFeedClass.content))
            }
        }
    }
    list.shuffle()
    return list

}

优化方案 #

1. 数据库结构优化（推荐，NoSQL核心原则：扁平化+冗余） #

Firestore的性能瓶颈主要来自嵌套查询和多次请求，最根本的优化是调整数据结构，避免跨集合关联查询：

• 冗余用户信息到Feed文档：在每个FeedNewsFeed文档中直接存储userName字段，查询Feed时无需再访问用户Profile集合
• 独立新闻流集合：创建顶级集合newsFeeds，每个文档包含userId、userName、content等字段，一次查询即可获取所有新闻流数据，彻底避免嵌套遍历

2. 代码层面优化（无需改结构时的临时方案） #

如果暂时无法调整数据库结构，可通过并发请求和减少冗余请求大幅提升性能：

• 使用协程async并行处理每个用户的Profile和Feed查询，将串行耗时转为并行耗时
• 去掉documentOfFeed.reference.get()的冗余请求，直接用documentOfFeed.toObject()解析数据
• 简化对象创建逻辑，直接在循环中构造并添加NewsFeedClass实例

优化后的代码示例：

suspend fun getAllNewsFeeds(): ArrayList<NewsFeedClass> {
    val list = arrayListOf<NewsFeedClass>()
    
    // 获取所有用户快照
    val usersSnapshot = collectionRef.get().await()
    
    // 并行处理每个用户的请求
    usersSnapshot.map { userDoc ->
        async {
            val userRef = userDoc.reference
            
            // 并行获取用户名称和Feed列表
            val userNameDeferred = async {
                userRef.collection(Constants.UserProfileInfo)
                    .document(Constants.Profile)
                    .get()
                    .await()
                    .toObject(FeedUserName::class.java)?.userName
            }
            
            val feedsDeferred = async {
                userRef.collection(Constants.FeedNewsFeeds)
                    .get()
                    .await()
                    .documents
                    .mapNotNull { it.toObject<FeedNewsFeed>() }
            }
            
            val userName = userNameDeferred.await()
            val feeds = feedsDeferred.await()
            
            // 关联Feed与用户名并添加到列表
            feeds.forEach { feed ->
                userName?.let { name ->
                    list.add(NewsFeedClass(name, feed.newsfeed))
                }
            }
        }
    }.awaitAll() // 等待所有并行任务完成
    
    list.shuffle()
    return list
}

额外优化建议 #

• 分页查询：若新闻流数据量大，使用limit()和startAfter()实现分页，减少单次请求的数据量
• 缓存策略：利用Firestore本地缓存（默认开启），或手动缓存用户名称和Feed数据，避免重复请求
• 实时监听：若需要实时展示新闻流，使用addSnapshotListener替代get()，仅获取变更数据，无需全量刷新

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