Node.js中ERR_HTTP_HEADERS_SENT错误排查与解决求助

我使用Node.js、Express、MySQL数据库和React前端开发，调用API时出现Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client错误。我查过相关问题，知道需要用return终止响应，但已经添加return还是没解决。我的需求是先查询数据库表获取课程ID，再用该ID在另一张表中存储数据，请问怎么操作才能避免触发这个错误？

原API代码 #

app.post('/registerInCourse', (req, res) => {
  const cd = [req.body.code];
  const sId = [req.body.studentId];
  const sqlCode = "SELECT idCourses FROM stumgmtdb.Courses WHERE courseCode = ?"
  const sql = "INSERT INTO stumgmtdb.Registry (stuId, courId) VALUES (?,?)";
   
  let courseId = db.query(sqlCode, cd, (err,result)=> {
    if(err){
      return res.json({message: "Could not get course ID. " + err});
    }else {
      return res.json(result);
    }
  });

  const values = [
    sId,
    courseId.idCourses
  ]

  db.query(sql, values, (err,result)=> {
    if(err){
      return res.json({message: "Could not add student to the course " + err});
    }else {
      return res.json({message: "Student added successfully to the course"});
    }
  });
   
});

报错信息 #

Error [ERR_HTTP_HEADERS_SENT]: Cannot set headers after they are sent to the client
    at ServerResponse.setHeader (node:_http_outgoing:652:11)
    at ServerResponse.header (/Users/Jaculine/ReactProjects/Student-Results-Management-System/server/node_modules/express/lib/response.js:794:10)
    at ServerResponse.send (/Users/Jaculine/ReactProjects/Student-Results-Management-System/server/node_modules/express/lib/response.js:174:12)
    at ServerResponse.json (/Users/Jaculine/ReactProjects/Student-Results-Management-System/server/node_modules/express/lib/response.js:278:15)
    at Query.<anonymous> (/Users/Jaculine/ReactProjects/Student-Results-Management-System/server/index.js:160:18)
    at Query.<anonymous> (/Users/Jaculine/ReactProjects/Student-Results-Management-System/server/node_modules/mysql/lib/Connection.js:526:10)
    at Query._callback (/Users/Jaculine/ReactProjects/Student-Results-Management-System/server/node_modules/mysql/lib/Connection.js:488:16)
    at Sequence.end (/Users/Jaculine/ReactProjects/Student-Results-Management-System/server/node_modules/mysql/lib/protocol/sequences/Sequence.js:83:24)
    at Query.ErrorPacket (/Users/Jaculine/ReactProjects/Student-Results-Management-System/server/node_modules/mysql/lib/protocol/sequences/Query.js:92:8)
    at Protocol._parsePacket (/Users/Jaculine/ReactProjects/Student-Results-Management-System/server/node_modules/mysql/lib/protocol/Protocol.js:291:23) {
  code: 'ERR_HTTP_HEADERS_SENT'
}

错误原因 #

1. 异步操作顺序错误：db.query是异步方法，你当前的写法是发起查询后立刻执行插入操作，这时候课程ID还没查到，而且第一个查询的回调里直接返回了响应，之后插入操作又会再次调用res.json，导致多次向客户端发送响应，触发错误。
2. 错误获取查询结果：db.query的返回值是Query对象，不是查询结果，所以courseId.idCourses根本拿不到正确的课程ID。

修复方案 #

把插入操作放到第一个查询的回调函数内部，确保拿到课程ID后再执行插入，并且整个请求流程只返回一次响应。推荐用async/await写法，避免回调嵌套，代码更易读。

写法1：回调嵌套（兼容现有代码） #

app.post('/registerInCourse', (req, res) => {
  const cd = [req.body.code];
  const sId = req.body.studentId; // 不需要包装成数组，直接传值即可
  const sqlCode = "SELECT idCourses FROM stumgmtdb.Courses WHERE courseCode = ?";
  const sql = "INSERT INTO stumgmtdb.Registry (stuId, courId) VALUES (?,?)";
   
  db.query(sqlCode, cd, (err, result) => {
    if (err) {
      return res.json({ message: "Could not get course ID. " + err });
    }
    // 检查是否查到课程
    if (result.length === 0) {
      return res.json({ message: "Course not found." });
    }
    const courseId = result[0].idCourses;
    const values = [sId, courseId];

    db.query(sql, values, (err) => {
      if (err) {
        return res.json({ message: "Could not add student to the course " + err });
      }
      res.json({ message: "Student added successfully to the course" });
    });
  });
});

写法2：async/await（更简洁易维护） #

如果你的mysql库支持Promise（比如mysql2/promise），可以改用async/await：

// 先确保db是Promise化的连接，比如用mysql2/promise
const mysql = require('mysql2/promise');
const db = mysql.createConnection({ /* 你的数据库配置 */ });

app.post('/registerInCourse', async (req, res) => {
  try {
    const { code, studentId } = req.body;
    const sqlCode = "SELECT idCourses FROM stumgmtdb.Courses WHERE courseCode = ?";
    const sql = "INSERT INTO stumgmtdb.Registry (stuId, courId) VALUES (?,?)";

    // 查询课程ID
    const [courseResult] = await db.query(sqlCode, [code]);
    if (courseResult.length === 0) {
      return res.json({ message: "Course not found." });
    }
    const courseId = courseResult[0].idCourses;

    // 执行插入
    await db.query(sql, [studentId, courseId]);
    res.json({ message: "Student added successfully to the course" });
  } catch (err) {
    res.json({ message: "Error: " + err.message });
  }
});

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