Node.js接口报Can not set headers after they are sent to client错误排查

代码存在的核心问题 #

• 重复调用回调函数：Service层的callback被多次触发，导致控制器反复调用Express的res.json()
• 异步/同步逻辑混淆：Club插入成功后，先同步执行了return callback(null, result.insertId)（触发控制器发响应），但同时for循环里的Player插入是异步的，每个Player插入完成后又触发callback
• 错误回调未加return：Club插入出错时，if(error){ callback(error); }后没有return，会继续执行后续代码，扩大错误范围
• Player插入依赖子查询：用子查询查Club ID，并发场景下容易取错ID，且增加DB开销

为何请求看似正常但末尾报错 #

Express的响应机制是：一旦调用res.json()/res.send()等方法，就会把响应头+响应体发送给客户端，之后再调用任何修改响应头/体的方法，就会触发Can not set headers after they are sent to client错误。
你的代码中：

1. Club插入成功后，同步执行的callback(null, result.insertId)先触发控制器，发送200响应——这就是你看到“请求正常”的原因
2. 但异步的Player插入回调还在后台运行，每个Player插入完成后，又调用callback，控制器再尝试res.json()——此时响应已发送完毕，触发报错

为何需要重启Node服务 #

Node.js的事件循环会残留未处理的异步任务/错误：

• 重复触发的callback会导致未捕获的异步错误（上述响应报错）
• 残留的MySQL异步查询回调会堆积在事件循环中，导致后续请求的回调逻辑混乱
  重启Node服务会清空事件循环的残留任务，所以能临时恢复正常

具体修复方案 #

1. 修正Service层的回调逻辑（仅触发一次回调） #

把代码改为等待所有Player插入完成后，再统一触发回调，且所有错误回调都加return，同时直接使用Club插入返回的ID，替代子查询：

module.exports = {
  create: (data, callback) => {
    const myArray = [];
    // 构造Player数据数组
    data.players.forEach(player => {
      myArray.push({
        id: player.id,
        firstname: player.firstname,
        lastname: player.lastname,
        position: player.position,
        price: player.price,
        appearences: player.appearences,
        goals: player.goals,
        assists: player.assists,
        cleansheets: player.cleansheets,
        redcards: player.redcards,
        yellowcards: player.yellowcards,
        image: player.image
      });
    });

    // 第一步：插入Club
    pool.query(
      'insert into club(userid,email,password,name,price) values(?,?,?,?,?)',
      [data.userid, data.email, data.password, data.name, data.price],
      (clubErr, clubResult) => {
        // 出错直接终止回调，不执行后续逻辑
        if (clubErr) return callback(clubErr);

        const newClubId = clubResult.insertId;
        const totalPlayers = myArray.length;
        // 无Player时直接返回Club ID
        if (totalPlayers === 0) return callback(null, newClubId);

        let completedCount = 0;
        // 第二步：批量插入Player（等待所有完成后回调）
        myArray.forEach(item => {
          pool.query(
            `insert into players(id,firstname,lastname,position,price,appearences,goals,assists,cleansheets,redcards,yellowcards,image,clubid) 
             values (?,?,?,?,?,?,?,?,?,?,?,?, ?)`,
            [
              item.id, item.firstname, item.lastname, item.position,
              item.price, item.appearences, item.goals, item.assists,
              item.cleansheets, item.redcards, item.yellowcards,
              item.image, newClubId
            ],
            (playerErr) => {
              if (playerErr) return callback(playerErr);
              // 计数：所有Player插入完成后统一回调
              completedCount++;
              if (completedCount === totalPlayers) {
                callback(null, newClubId);
              }
            }
          );
        });
      }
    );
  }
}

2. 控制器层无需修改 #

当前控制器的逻辑是正确的：仅在callback触发后调用一次res.json()，只要Service层不再重复触发callback，就不会再报错

内容的提问来源于stack exchange，提问作者Fares Ben Slama