基于Firebase实时数据库与SwiftUI实现双观察者更新单视图

问题描述 #

我需要实现以下功能，目前对实现方式存在疑问：
我的Firebase实时数据库包含两个节点：

Groups节点结构 #

Groups:
------- GroupID:
        -------- UserID : True/False

该节点存储群组ID及关联的用户ID，通过布尔值标记用户的活跃状态。

Notes节点结构 #

Notes:
------ GroupID:
       -------- UserID: 
                ------- Paid: True/False

此节点存储用户备注信息，包含用户的Paid状态（已支付/未支付）。

需求：同时监听两个节点的变化，更新同一列表视图：

• 监听Groups节点中群主修改用户的活跃/非活跃状态；
• 监听Notes节点中群主修改用户的已支付/未支付状态。

我编写的代码中，Groups节点的监听可正常工作，但Notes节点的修改无法触发视图更新：

self.groupRef.child(groupId).observe(.value, with: { (snap) in
    
    self.user = []
    
    var counter: UInt = 0
    
    for child in snap.children {

            let userId = (child as! DataSnapshot).key
            
            self.userNotesRef.child(groupId).child(userId).observe(.value, with: { (snapshot) in

                let val = snapshot.value as? NSDictionary
                
                let note = val?["Note"] as? String ?? ""
                let paid = val?["Paid"] as? Bool ?? false
                
                print("USERS Paid: ", paid)
                print("USERS Note ", note)
            
            })

     }

})

解决方案 #

你的代码存在几个关键问题：

• 嵌套监听导致重复订阅：每次Groups节点更新时，都会为每个UserID新增一个Notes监听，旧监听不会被移除，不仅浪费资源，还会导致数据处理混乱
• 未将Notes数据与Groups的活跃状态结合更新数据源：获取到Paid状态后没有更新用于列表展示的user数组
• 未触发UI刷新：数据更新后没有调用列表的刷新方法

修改方案如下：

1. 定义统一的用户数据模型 #

先创建一个模型类，整合用户的活跃状态和Paid状态：

struct UserModel {
    let userId: String
    var isActive: Bool
    var isPaid: Bool
    var note: String
}

2. 拆分监听逻辑，分别维护数据 #

将Groups和Notes的监听分开，各自更新数据模型，最后合并刷新UI：

// 存储用户数据的全局数组
var userModels: [UserModel] = []

override func viewDidLoad() {
    super.viewDidLoad()
    startListeningToGroups()
    startListeningToNotes()
}

// 监听Groups节点
func startListeningToGroups() {
    groupRef.child(groupId).observe(.value) { [weak self] snap in
        guard let self = self else { return }
        // 初始化/更新用户的活跃状态
        var tempUserMap: [String: UserModel] = [:]
        
        for child in snap.children {
            let userSnap = child as! DataSnapshot
            let userId = userSnap.key
            let isActive = userSnap.value as? Bool ?? false
            
            // 复用已有用户的Paid/Note数据，仅更新活跃状态
            if let existingUser = self.userModels.first(where: { $0.userId == userId }) {
                tempUserMap[userId] = UserModel(userId: userId, isActive: isActive, isPaid: existingUser.isPaid, note: existingUser.note)
            } else {
                tempUserMap[userId] = UserModel(userId: userId, isActive: isActive, isPaid: false, note: "")
            }
        }
        
        self.userModels = Array(tempUserMap.values)
        // 刷新列表
        self.tableView.reloadData()
    }
}

// 监听Notes节点
func startListeningToNotes() {
    userNotesRef.child(groupId).observe(.value) { [weak self] snap in
        guard let self = self else { return }
        // 更新用户的Paid和Note状态
        for child in snap.children {
            let noteSnap = child as! DataSnapshot
            let userId = noteSnap.key
            let val = noteSnap.value as? NSDictionary
            let isPaid = val?["Paid"] as? Bool ?? false
            let note = val?["Note"] as? String ?? ""
            
            // 更新已有用户数据
            if let index = self.userModels.firstIndex(where: { $0.userId == userId }) {
                var updatedUser = self.userModels[index]
                updatedUser.isPaid = isPaid
                updatedUser.note = note
                self.userModels[index] = updatedUser
            } else {
                // 若Groups中无该用户，根据业务需求决定是否添加
                self.userModels.append(UserModel(userId: userId, isActive: false, isPaid: isPaid, note: note))
            }
        }
        // 刷新列表
        self.tableView.reloadData()
    }
}

// 页面销毁时移除监听（推荐）
override func viewWillDisappear(_ animated: Bool) {
    super.viewWillDisappear(animated)
    groupRef.child(groupId).removeAllObservers()
    userNotesRef.child(groupId).removeAllObservers()
}

3. 列表数据源方法 #

确保列表的数据源方法使用userModels数组：

func tableView(_ tableView: UITableView, numberOfRowsInSection section: Int) -> Int {
    return userModels.count
}

func tableView(_ tableView: UITableView, cellForRowAt indexPath: IndexPath) -> UITableViewCell {
    let cell = tableView.dequeueReusableCell(withIdentifier: "UserCell", for: indexPath)
    let user = userModels[indexPath.row]
    cell.textLabel?.text = user.userId
    cell.detailTextLabel?.text = "活跃: \(user.isActive) | 已支付: \(user.isPaid)"
    return cell
}

修改后，无论是Groups节点的活跃状态变化，还是Notes节点的Paid状态变化，都会更新userModels数组并触发列表刷新，实现单列表响应两个节点变化的需求。

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