firebase 实时数据库事务导致监听器回调与未提交的数据

Question

我正在使用适用于 android 的 firebase 实时数据库，进行事务以更新对象，假设阻止 2 个用户相互覆盖。这似乎有效。

问题：一位用户被阻止写信，所以doTransation() 将被再次调用。 根据我下面的逻辑，第一个 doTransation 调用不会在服务器上生效。第二个 doTransation 调用将中止。 在第一个 doTransation 之后和第二个之前，我将回调 onDataChange() 到我的 ValueEventListener，其中包含被拒绝/未提交的数据以及在调用 onComplete() 之前。

知道为什么会出现这种行为吗？怎么改？

fun onIconClicked(currentGameState: GameState, gameId: String, iconClicked: Long) {
    Log.d(TAG, "onIconClicked() called")

    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")
        }
    })
}

Answer 1

我收到了回调 onDataChange() 到我的 ValueEventListener，其中包含在 onComplete() 调用之前被拒绝/未提交的数据。

事务运行所在的同一客户端上的侦听器确实会看到中间事务迭代的本地事件。

如果您不希望触发这些本地事件，请使用 runTransaction 的重载，它接受名为 fireLocalEvents 的第二个参数，并为此传递 false。

所以：

database.child(GAME_STATE_PATH).child(gameId).runTransaction(..., false)