Node.js中如何等待Firebase实时数据库onValue返回值？

你的问题核心是**onValue是异步且持续监听的方法**，它的回调函数不会阻塞getData函数的执行流程。所以getData会先执行完console.log('END!')并返回undefined，等数据库异步返回数据后才会触发回调里的console.log('DATA: ...')。

下面是两种针对性的解决方案：

方案1：仅获取单次数据（推荐） #

如果只需要获取一次数据，改用Firebase的get()方法（专门用于单次异步读取数据，返回Promise），配合async/await实现同步写法：

async function getData(path) {
    try {
        const reference = ref(database, path);
        const snapshot = await get(reference);
        const data = snapshot.val();
        console.log('DATA: ' + data);
        console.log('END!');
        return data;
    } catch (error) {
        console.error(error);
        return undefined;
    }
}

调用方式（必须用await或.then()处理异步返回值）：

// 在async函数内用await
const data = await getData('你的数据路径');

// 或用.then()链式调用
getData('你的数据路径').then(data => {
    console.log('返回的数据:', data);
});

方案2：需要持续监听数据变化 #

如果确实需要持续监听数据更新（这是onValue的设计初衷），不要试图让函数返回数据，而是把数据处理逻辑直接放在onValue的回调里，或者用Promise封装单次触发（仅适合需要首次数据的场景）：

方式A：直接在回调内处理数据 #

function setupDataListener(path) {
    try {
        const reference = ref(database, path);
        // 持续监听，每次数据变化都会触发回调
        onValue(reference, (snapshot) => {
            const data = snapshot.val();
            console.log('DATA更新: ' + data);
            // 在这里处理数据，比如更新UI、存入变量等
            handleData(data);
        }, (error) => {
            console.error(error);
        });
    } catch (error) {
        console.error(error);
    }
}

// 处理数据的函数
function handleData(data) {
    console.log('处理数据:', data);
    console.log('END!');
}

方式B：Promise封装首次数据（仅获取一次） #

function getData(path) {
    return new Promise((resolve, reject) => {
        try {
            const reference = ref(database, path);
            // 监听一次后取消订阅
            const unsubscribe = onValue(reference, (snapshot) => {
                const data = snapshot.val();
                console.log('DATA: ' + data);
                resolve(data);
                unsubscribe(); // 获取到数据后停止监听
            }, (error) => {
                console.error(error);
                reject(error);
            });
        } catch (error) {
            console.error(error);
            reject(error);
        }
    });
}

调用方式：

getData('你的数据路径').then(data => {
    console.log('返回的数据:', data);
    console.log('END!');
}).catch(err => {
    console.error(err);
});

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