Node.js中REST API的async/await正确用法及响应异常排查

你的代码存在语法错误、逻辑漏洞，导致请求无法正常响应。下面逐一修正并改用async/await风格实现需求：

1. 重构ValidationService（用async函数替代嵌套Promise） #

原函数参数名不匹配、未正确实现Promise逻辑，改成async函数后，直接抛出错误即可被上层await捕获：

// ValidationService.js
export const validatePricingJSON = async (obj) => {
  // 校验JSON结构的合法性
  if (!obj || !Array.isArray(obj) || obj.length === 0 || !obj[0].Query) {
    const error = new Error('Failed to process JSON: File content is empty or structure invalid');
    error.status = 400; // 自定义错误状态码
    throw error;
  }

  // 可添加其他验证逻辑...

  return 'Validation completed successfully';
};

2. 修复BaseController的错误 #

原代码存在未导入模块、路径拼接错误、重复响应等问题，修正后：

// BaseController.js
import fs from 'fs';
import path from 'path';
import validatePricingJSON from "../services/ValidationService";

// 按实际项目结构定义文件目录，示例为当前文件上级目录
const sourceDir = path.resolve(__dirname, '../');

export const validatePricing = async (req, res) => {
  try {
    console.log("Validating pricing json file");
    
    // 用path.join安全处理路径，避免拼接错误
    const pricingPath = path.join(sourceDir, 'pricing.json');
    const pricingJSON = fs.readFileSync(pricingPath, 'utf8');
    const data = JSON.parse(pricingJSON);

    // 等待验证完成，错误会被try/catch捕获
    await validatePricingJSON(data);

    // 验证通过后返回成功响应
    res.status(200).json({
      status: 'Success',
      message: 'JSON validation was completed successfully'
    });
  } catch (error) {
    // 统一处理所有异常：文件读取错误、JSON解析错误、验证错误
    const statusCode = error.status || 500;
    res.status(statusCode).json({
      status: 'Error',
      message: error.message || 'Internal server error'
    });
  }
};

3. 路由文件无需修改 #

// 路由文件
import express from 'express';
import { validatePricing } from "../controllers/BaseController";

const apiRouter = express.Router();

apiRouter.get('/validate-pricing-file', validatePricing);

export default apiRouter;

关键问题说明 #

• 重复响应漏洞：原代码中await validatePricingJSON(data).catch(...)执行后，无论验证失败与否，都会继续执行后续的res.status(200)，导致发送两次响应，Node.js会拦截重复响应，最终请求挂起。改用try/catch统一处理后，错误时进入catch块返回错误响应，成功时才返回成功响应。
• Promise实现错误：原ValidationService未用new Promise包裹就直接调用resolve/reject，会触发语法错误。改成async函数后，抛出的错误会自动被包装为rejected Promise，更贴合async/await的使用逻辑。
• 路径与模块问题：原代码未导入fs模块会导致运行时错误，用path.join处理路径可避免操作系统路径分隔符差异带来的问题。

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