NodeJS获取Firebase实时数据库节点数据时的竞态条件问题

问题背景 #

循环查询Firebase Realtime Database的PoolType信息时，出现竞态条件：所有异步回调都使用了循环结束后的currPool值，导致输出的Pool ID全部为最后一个值，而非对应查询的ID。

原代码 #

(;currPool<=lastPool;) {

    console.log("Current Pool ID: " + currPool);

    poolsRef.child(currPool).child("PoolType").once('value', function(snapshot) {
        
        if (snapshot.exists()) {
        
            const poolType = snapshot.val();
            console.log("Pool ID:", currPool, "is a:", poolType , " Style PoolType");

         }

    });

    currPool++;

}

当前输出 #

Current Pool ID: 11018
Current Pool ID: 11019
Current Pool ID: 11020
Current Pool ID: 11021
Current Pool ID: 11022
Current Pool ID: 11023
Pool ID: 11024 is a: Survivor  Style PoolType
Pool ID: 11024 is a: Pickem  Style PoolType
Pool ID: 11024 is a: Pickem  Style PoolType
Pool ID: 11024 is a: Pickem  Style PoolType
Pool ID: 11024 is a: Pickem  Style PoolType
Pool ID: 11024 is a: Survivor  Style PoolType

期望输出 #

Pool ID: 11018 is a: Survivor  Style PoolType
Pool ID: 11019 is a: Pickem  Style PoolType
Pool ID: 11020 is a: Pickem  Style PoolType
Pool ID: 11021 is a: Pickem  Style PoolType
Pool ID: 11022 is a: Pickem  Style PoolType
Pool ID: 11023 is a: Survivor  Style PoolType

问题原因 #

once('value')是异步操作，回调函数会在数据库查询完成后执行。原循环中的currPool是外层作用域变量，循环会快速执行完毕，此时currPool已递增到lastPool + 1（即11024），所有回调函数引用的都是这个最终值。

解决方案 #

方案1：使用块级作用域变量（let） #

将循环改为for循环，用let声明currPool，每次迭代都会创建独立的变量绑定，回调函数会引用当前迭代的currPool值：

// 替换为实际的起始和结束Pool ID
for (let currPool = 11018; currPool <= 11023; currPool++) {
    console.log("Current Pool ID: " + currPool);

    poolsRef.child(currPool).child("PoolType").once('value', function(snapshot) {
        if (snapshot.exists()) {
            const poolType = snapshot.val();
            console.log("Pool ID:", currPool, "is a:", poolType , " Style PoolType");
        }
    });
}

方案2：使用Async/Await（推荐） #

将异步查询转为串行执行，确保每次查询完成后再进行下一次循环，输出顺序严格与循环顺序一致，同时便于错误处理：

async function fetchPoolTypes() {
    const startPool = 11018;
    const lastPool = 11023;

    for (let currPool = startPool; currPool <= lastPool; currPool++) {
        console.log("Current Pool ID: " + currPool);
        
        try {
            const snapshot = await poolsRef.child(currPool).child("PoolType").once('value');
            if (snapshot.exists()) {
                const poolType = snapshot.val();
                console.log("Pool ID:", currPool, "is a:", poolType , " Style PoolType");
            }
        } catch (error) {
            console.error("Failed to fetch PoolType for ID", currPool, error);
        }
    }
}

fetchPoolTypes();

说明 #

• 方案1保持异步并行查询，执行效率更高，但输出顺序可能因数据库响应速度不同而变化。
• 方案2通过await实现串行查询，输出顺序完全匹配循环顺序，更适合需要严格顺序的场景。

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