Firebase Realtime Database事务触发未提交数据的监听器回调问题

Firebase Realtime Database SDK 为了提升交互流畅度，默认会对事务操作做本地预提交处理：

• 第一次调用doTransaction()时，SDK 会先基于本地缓存的数据计算修改结果，直接将修改写入本地缓存，并触发所有关联的ValueEventListener/ChildEventListener回调，此时回调携带的数据是本地预估值，还未经过服务端校验。
• 之后 SDK 才会把修改请求提交到服务端，若服务端检测到数据冲突（和其他用户的写入冲突），会将最新的服务端数据返回给客户端，重新触发doTransaction()调用。
• 如果第二次doTransaction()触发中止逻辑，SDK 会将本地缓存回滚为服务端的最新有效值，再次触发回调同步正确数据。

你观察到的未提交数据提前触发回调的现象是 SDK 的默认设计，不属于异常问题。

方案1：关闭事务的本地事件触发（最直接） #

runTransaction方法提供了第二个可选参数fireLocalEvents，默认值为true，控制是否触发事务执行过程中的本地中间状态回调。你只需要调用重载方法，将该参数设为false即可：

database.child(GAME_STATE_PATH).child(gameId).runTransaction(object : Transaction.Handler {
    override fun doTransaction(currentData: MutableData): Transaction.Result {
        val gameState = currentData.getValue(GameState::class.java)
            ?: return Transaction.success(currentData)

        // make sure the state from server match the client, and check if won the card        
        return if (gameState == currentGameState && true == currentGameState.users?.get(currentUserId)?.card?.contains(iconClicked) &&
                true == currentGameState.mainCard?.contains(iconClicked)) {

            // player won card - make the changes in game state...

            currentData.value = gameState
            Log.d(TAG, "doTransaction() winning card, game after = $gameState")

            Transaction.success(currentData)
        } else {
            Log.d(TAG, "doTransaction() aborting")
            Transaction.abort()
        }
    }

    override fun onComplete(error: DatabaseError?, committed: Boolean, currentData: DataSnapshot?) {
        Log.d(TAG, "onIconClicked onComplete() called with: error = $error, committed = $committed, currentData = $currentData")
    }
}, false) // 新增这个参数，关闭本地中间事件触发

修改后，只有事务完全执行完成（提交成功/中止）后，才会触发关联的监听器回调，不会再收到中间状态的脏数据。

方案2：在监听器中过滤本地缓存数据 #

如果你需要保留其他场景的本地事件触发能力，也可以在ValueEventListener的onDataChange回调中，通过DataSnapshot.isFromCache()方法判断数据来源，过滤掉本地临时缓存的未校验数据：

override fun onDataChange(snapshot: DataSnapshot) {
    if (snapshot.isFromCache) return // 跳过本地缓存的中间数据
    // 原有业务逻辑
}

可选优化：调整事务内的判断逻辑 #

当前事务中你依赖外部传入的currentGameState做状态校验，这个值是客户端之前持有的旧状态，事务重试时currentData已经是服务端返回的最新值，用旧状态比对可能会导致不必要的事务中止。建议调整为完全基于currentData取出的最新gameState做所有业务判断，不要依赖外部传入的状态快照。

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