Firebase实时聊天页面频繁刷新问题及优化需求咨询

问题根源 #

你当前使用observe(.value)监听用户对话节点，该监听会在节点**任何数据变化（包括删除对话）**时触发回调。当删除过期聊天时，节点数据更新，触发getAllConversations的回调导致页面重新加载列表；而加载列表时又会检查过期聊天并再次删除，形成循环，最终导致页面每0.5秒自动刷新。此外，当前过期检查需要拉取整个对话的所有消息，不仅效率低，还会加重循环触发的概率。

解决方案 #

1. 替换实时监听为单次获取（切断循环触发） #

把observe(.value)改成observeSingleEvent(of: .value)，这样只会在页面初始化时获取一次对话列表，不会因为后续删除操作触发重复回调。如果需要实时接收新对话，可以单独监听新增节点，而非整个节点的所有变化。

修改后的getAllConversations代码：

///Fetches and returns all the conversations for the user with passed in email
public func getAllConversations(for email:String, completion: @escaping(Result<[Conversation], Error>)->Void){
    // 替换为单次获取，避免重复触发回调
    database.child("\(email)/conversations").observeSingleEvent(of: .value, with: {snapshot in
        guard let value = snapshot.value as? [[String: Any]] else{
            completion(.failure(DatabaseError.failedToFetch))
            return
        }
        let conversations: [Conversation] = value.compactMap { dictionary in
            guard let conversationId = dictionary["id"] as? String,
                  let name = dictionary["name"] as? String,
                  let otherUserEmail = dictionary["other_user_email"] as? String,
                  let latestMessage = dictionary["latest_message"] as? [String:Any],
                  let date = latestMessage["date"] as? String,
                  let message = latestMessage["message"] as? String,
                  let isRead = latestMessage["is_read"] as? Bool else{
                      return nil
                  }
            
            let latestMessageObject = LatestMessage(date: date,
                                                    text: message,
                                                    isRead: isRead)
            return Conversation(id: conversationId,
                                name: name,
                                otherUserEmail: otherUserEmail,
                                latestMessage: latestMessageObject)
        }
        completion(.success(conversations))
    })
}

2. 优化过期检查逻辑（减少数据库请求） #

直接利用对话中已有的latestMessage.date判断是否过期，无需拉取整个对话的所有消息，同时把检查逻辑移到单次获取对话之后，仅执行一次。

整合后的过期检查与删除逻辑：

// 页面初始化时获取对话并处理过期检查
getAllConversations(for: currentUserEmail) { result in
    switch result {
    case .success(let conversations):
        // 先过滤出需要删除的过期对话
        let expiredConversations = conversations.filter { conversation in
            guard let latestDate = DateFormatter.iso8601.date(from: conversation.latestMessage.date) else {
                return false
            }
            let oneHourAfter = Calendar.current.date(byAdding: .hour, value: 1, to: latestDate)
            return Date() >= oneHourAfter!
        }
        
        // 后台批量执行删除，不阻塞主线程
        DispatchQueue.global(qos: .background).async {
            let group = DispatchGroup()
            expiredConversations.forEach { conv in
                group.enter()
                self.deleteOldChats(id: conv.id) { _ in
                    group.leave()
                }
            }
            // 等所有删除操作完成后，再手动刷新一次列表
            group.notify(queue: .main) {
                self.reloadConversationList()
            }
        }
        
        // 先展示当前有效对话，提升页面加载速度
        DispatchQueue.main.async {
            self.conversations = conversations.filter { !expiredConversations.contains($0) }
            self.tableView.reloadData()
        }
    case .failure(let error):
        print(error)
    }
}

3. 保留删除操作的后台执行 #

当前deleteOldChats已经用DispatchQueue.global(qos: .background)确保删除操作在后台执行，保持该逻辑即可，避免阻塞主线程影响页面流畅度。

4. 可选：实时监听新增对话 #

如果需要实时接收新创建的对话，单独监听.childAdded事件即可，无需监听整个节点的变化：

// 仅监听新增对话，避免全量刷新
database.child("\(email)/conversations").observe(.childAdded) { snapshot in
    guard let dictionary = snapshot.value as? [String: Any] else { return }
    // 解析新增对话的逻辑和之前一致
    guard let conversationId = dictionary["id"] as? String,
          let name = dictionary["name"] as? String,
          let otherUserEmail = dictionary["other_user_email"] as? String,
          let latestMessage = dictionary["latest_message"] as? [String:Any],
          let date = latestMessage["date"] as? String,
          let message = latestMessage["message"] as? String,
          let isRead = latestMessage["is_read"] as? Bool else {
              return
          }
    
    let newConversation = Conversation(
        id: conversationId,
        name: name,
        otherUserEmail: otherUserEmail,
        latestMessage: LatestMessage(date: date, text: message, isRead: isRead)
    )
    
    DispatchQueue.main.async {
        self.conversations.append(newConversation)
        self.tableView.reloadData()
    }
}

关键注意事项 #

• 避免用.value监听整个节点的变化，除非你需要实时响应所有增删改操作，否则优先用单次获取或针对性的子节点监听。
• 过期检查尽量复用本地已有的数据，减少不必要的数据库请求。
• 批量删除时用DispatchGroup确保所有操作完成后再刷新页面，避免多次重复刷新。

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