Firebase实时数据库中数据结构的原子更新实现问询

我正在使用TypeScript和Firebase实时数据库（无法使用Firestore），数据结构基于以下接口定义：

enum RunStatus {
    RUNNING,
    ENDED
}

interface IResults {
    firstItem: string;
    secondItem: number;
}

interface MyData {
    status: RunStatus;
    results: IResults;
}

假设有10个客户端可能同时写入数据，操作包括：1. 将status从RUNNING改为ENDED；2. 设置results字段。我希望仅第一个客户端能完成该操作，因此需要使用事务机制。数据存储路径为："/some/path/here/mydata"。根据有限的文档，我编写了如下代码：

class MyDatabase {
    db: Database;

    constructor(db_: Database) {
        this.db = db_
    }

    writeMyData(newData: MyData) {
        const path="/some/path/here/mydata";
        const reference=child(ref(this.db),path);
        runTransaction(reference, (currentData) => {
            if (currentData) {
                if (currentData.status!=RunStatus.ENDED && newData.status==RunStatus.ENDED) {
                    currentData.status=newData.status;
                    currentData.results=newData.results;
                    // Or, I could have just set currentData=newData
                }
            }
            return currentData;
        });
    }
}

请问这段代码是否正确？当多个客户端同时执行该操作时，具体会发生什么？文档提到如果在第一个客户端写入时currentData被其他客户端更新，runTransaction会自动重新运行，能否解释这一机制及当前代码的正确性？

代码正确性判断 #

这段代码核心逻辑符合需求，但存在一个关键漏洞：如果目标节点的currentData不存在（即节点未初始化），事务会直接返回undefined，不会写入任何数据。如果你的业务场景中该节点初始状态必然存在且status为RUNNING，那代码能正常工作；但如果节点可能不存在，这段代码就无法完成首次写入。

另外，你注释里提到的直接设置currentData=newData是可行的，只要newData完全符合MyData类型结构，不会遗漏必要字段即可。

多客户端同时操作的行为 #

当10个客户端同时调用writeMyData并传入status=ENDED的newData时：

• 所有客户端的事务会先读取目标节点的当前数据。
• 第一个通过校验（currentData.status != ENDED）的客户端，会修改数据并提交到服务器。
• 其他客户端提交时，服务器会检测到数据已被修改（status变为ENDED），此时事务会自动重新运行。
• 重新运行时，读取到的currentData.status已是ENDED，触发条件不满足，直接返回原数据，不会执行修改操作。
  最终只有第一个客户端的修改会生效，其余客户端的操作不会产生任何变化。

事务自动重运行机制及代码正确性解释 #

Firebase实时数据库的事务基于乐观锁逻辑运行，具体流程：

1. 客户端读取目标节点的当前数据和对应的版本戳。
2. 客户端执行事务函数，生成待提交的新数据。
3. 客户端将新数据与之前读取的版本戳一起发送给服务器。
4. 服务器校验版本戳：如果与当前节点版本一致，说明这段时间无其他修改，接受新数据；如果版本不一致，说明数据已被其他客户端修改，拒绝提交并返回最新数据给客户端。
5. 客户端收到拒绝后，自动重复整个事务流程（重新读取最新数据、执行事务函数、提交），直到事务成功或达到重试上限（默认有次数限制，避免无限循环）。

回到你的代码，这个机制能保障需求的正确性：

• 只要有一个客户端成功将status改为ENDED，其他客户端的事务在重试时，读取到的currentData.status已是ENDED，不会再执行修改逻辑，完美实现“仅第一个客户端完成操作”的目标。
• 若要覆盖节点不存在的场景，可修改事务逻辑补充初始化处理：

runTransaction(reference, (currentData) => {
    // 数据不存在时，直接写入newData（前提是newData的status为ENDED）
    if (!currentData) {
        return newData.status === RunStatus.ENDED ? newData : currentData;
    }
    // 原有校验逻辑
    if (currentData.status !== RunStatus.ENDED && newData.status === RunStatus.ENDED) {
        currentData.status = newData.status;
        currentData.results = newData.results;
    }
    return currentData;
});

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