Firebase中DataEventType.value监听数据重复及观察者重复致分支多次更新问题

我来帮你分析下你遇到的DataEventType.value监听收到重复数据、终端分支多次更新的问题，这是Firebase实时数据库开发里很常见的场景，主要原因和对应的解决方案如下：

核心原因 #

• 重复注册观察者：如果你的checkingPostToAddNotifications函数被多次调用（比如在视图生命周期方法中重复触发，或者逻辑里多次执行该函数），每次调用都会给同一个REF_POSTS.child(postId).child("likes")节点添加一个新的.value观察者。这样当节点数据变化时，所有已注册的观察者都会触发回调，导致你看到重复的数据输出和分支更新。
• .value事件的特性：DataEventType.value的设计是每次节点数据变化（包括首次监听时的初始加载）都会返回整个节点的完整快照。如果没区分首次加载和后续更新，你可能会把初始快照和后续更新的快照误认为是重复数据，但更常见的还是观察者重复注册的问题。

解决方案 #

1. 避免重复注册观察者 #

如果你的场景不需要持续监听数据变化，直接用observeSingleEvent(of: .value)代替observe，它只会获取一次数据，不会持续监听：

func checkingPostToAddNotifications(userId: String, postId: String, hasUserIdCallback: @escaping (Bool)->Void) {
    print("postId -> \(postId),userId -> \(userId)")
    Api.Post.REF_POSTS.child(postId).child("likes").observeSingleEvent(of: .value, with: { (postCheck) in
        print("postCheck -> \(postCheck)")
        // 你的业务逻辑处理
        // ...
        hasUserIdCallback(/* 你的判断结果 */)
    })
}

如果必须持续监听，一定要保存观察者的句柄，在下次注册前移除旧的观察者，或者在不需要监听时主动移除：

// 定义一个变量保存观察者句柄
private var likesObserverHandle: DatabaseHandle?

func checkingPostToAddNotifications(userId: String, postId: String, hasUserIdCallback: @escaping (Bool)->Void) {
    print("postId -> \(postId),userId -> \(userId)")
    
    // 先移除之前注册的观察者（如果存在）
    if let handle = likesObserverHandle {
        Api.Post.REF_POSTS.child(postId).child("likes").removeObserver(withHandle: handle)
    }
    
    // 注册新的观察者并保存句柄
    likesObserverHandle = Api.Post.REF_POSTS.child(postId).child("likes").observe(DataEventType.value, with: { (postCheck) in
        print("postCheck -> \(postCheck)")
        // 你的业务逻辑处理
        // ...
        hasUserIdCallback(/* 你的判断结果 */)
    })
}

// 在视图销毁或者不需要监听的时机移除观察者，比如ViewController的deinit方法
deinit {
    if let handle = likesObserverHandle {
        // 注意这里要对应到你监听的节点
        Api.Post.REF_POSTS.child(postId).child("likes").removeObserver(withHandle: handle)
    }
}

2. 检查函数调用时机 #

排查你的代码，看看checkingPostToAddNotifications是不是被重复调用了。比如如果在viewWillAppear里调用这个函数，每次视图出现都会执行，就会重复注册观察者。可以加个判断，比如只有当postId变化时才重新调用，或者用一个标记避免重复执行。

3. 区分首次加载和后续更新 #

如果需要持续监听，并且要区分首次加载的初始数据和后续的数据更新，可以加一个标记变量：

private var isInitialLoad = true

func checkingPostToAddNotifications(userId: String, postId: String, hasUserIdCallback: @escaping (Bool)->Void) {
    Api.Post.REF_POSTS.child(postId).child("likes").observe(DataEventType.value, with: { (postCheck) in
        if self.isInitialLoad {
            self.isInitialLoad = false
            // 处理首次加载的初始数据，比如不需要触发通知逻辑
            return
        }
        // 处理后续的数据更新，比如触发你的通知逻辑
        print("postCheck -> \(postCheck)")
        hasUserIdCallback(/* 你的判断结果 */)
    })
}

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