NodeJS中Express响应提前发送：如何确保res.json最后执行？

你当前代码的核心问题有两个：

1. 误用同步FS方法的回调：fs.existsSync、fs.readdirSync是同步阻塞方法，不接受回调参数，你写的回调函数根本不会被执行，这是files数组无法添加的直接原因。
2. 异步操作未等待完成：就算改用异步FS方法，循环中的文件操作是并行异步执行的，res.json会在循环结束后立刻触发，此时所有文件读取逻辑还未完成，导致返回的结果中没有files字段。

使用Node.js原生的fs.promisesAPI（v10+支持）配合async/await，将每个查询结果项的文件处理逻辑封装为异步任务，再通过Promise.all等待所有任务完成后再发送响应。

修改后的代码 #

const fs = require('fs').promises;
const path = require('path'); // 用path拼接路径更安全，避免分隔符问题

con.query(sql, async function(err, result) {
    if (err) {
        console.error(err);
        return res.status(500).json({ error: '查询失败' });
    }

    // 封装单个结果项的处理逻辑为异步函数
    const processObservation = async (item) => {
        item.test = ["aaa", "bbb", "ccc"];
        // 安全拼接目录路径
        const dirPath = path.join(fichiers_observations, item.id_observation.toString());
        
        try {
            // 检查目录是否存在（替代已废弃的exists方法）
            await fs.access(dirPath);
            // 读取目录下的文件列表
            const files = await fs.readdir(dirPath);
            // 生成文件URL数组
            item.files = files.map(file => `a URL/${file}`);
        } catch (err) {
            // 目录不存在或读取失败时，设置空数组避免undefined
            item.files = [];
            // 可选：打印错误日志排查问题
            // console.log(`处理目录${dirPath}失败:`, err.message);
        }
        return item;
    };

    // 等待所有结果项的文件处理逻辑完成
    const processedResult = await Promise.all(result.map(processObservation));

    // 所有异步操作完成后，再发送响应
    res.json(processedResult);
});

关键优化点 #

1. 使用fs.promises：原生Promise化的FS方法，无需额外promisify或第三方模块，代码更简洁可靠。
2. Promise.all批量等待：将每个结果项的处理任务转为Promise，通过Promise.all确保所有异步操作完成后再执行res.json。
3. 安全路径拼接：用path.join替代手动拼接路径，避免跨平台分隔符问题和路径注入风险。
4. 错误捕获：单独捕获每个文件操作的错误，防止单个项处理失败导致整个请求崩溃。

进阶优化（可选） #

如果你的MySQL客户端支持Promise（比如mysql2），可以将整个查询逻辑也改为async/await，代码结构更清晰：

const mysql = require('mysql2/promise');
const fs = require('fs').promises;
const path = require('path');

// 假设已创建Promise化的数据库连接或连接池
app.get('/your-api-path', async (req, res) => {
    try {
        // 执行SQL查询
        const [result] = await con.query(sql);
        
        const processedResult = await Promise.all(result.map(async (item) => {
            item.test = ["aaa", "bbb", "ccc"];
            const dirPath = path.join(fichiers_observations, item.id_observation.toString());
            try {
                await fs.access(dirPath);
                const files = await fs.readdir(dirPath);
                item.files = files.map(file => `a URL/${file}`);
            } catch (err) {
                item.files = [];
            }
            return item;
        }));

        res.json(processedResult);
    } catch (err) {
        res.status(500).json({ error: err.message });
    }
});

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