Node.js Express中ERR_HTTP_HEADERS_SENT错误求助：新增商户数据问题

你遇到的Cannot set headers after they are sent to the client错误，核心原因是重复向客户端发送响应，具体来说是你的代码没有正确捕获异步操作中的错误，导致未处理的Promise拒绝触发了额外的响应逻辑。

问题根源分析 #

你的外层try/catch只能捕获同步代码的错误，但models.merchants.findOne()是异步Promise操作，它的then回调里抛出的错误无法被外层try/catch捕获。当用户名已存在时抛出的错误会变成未处理的Promise拒绝，Node.js会尝试自动发送错误响应；如果后续代码（比如create成功后的res.json）再尝试发送响应，就会触发重复发送的错误。

修正方案 #

这里提供两种常用的修复方式，你可以根据习惯选择：

方式一：使用async/await简化异步代码（推荐）

把路由处理函数改成async函数，用await等待异步操作完成，这样try/catch可以捕获所有异步错误：

var express = require("express");
var router = express.Router();
var models = require("../models");
const { check, validationResult } = require('express-validator/check');

/* GET users listing. */
router.get('/', function(req, res, next) {
  res.send('respond with a resource - merchant');
});

/* POST ADD USERS. */
router.post('/add-merchant', [
  check('name').not().isEmpty(),
], async (req, res, next) => {
  try {
    const errors = validationResult(req);
    if (!errors.isEmpty()) {
      return res.json({ errors: errors.array()});
    }
    console.log("error passed")
    
    // 用await等待异步查询完成
    const merchant = await models.merchants.findOne({ where: {name: req.body.name}});
    if(merchant) {
      throw new Error("Username already exists");
    }
    
    // 等待创建商户完成
    const newMerchant = await models.merchants.create(req.body);
    res.json(newMerchant);
  } catch (error) {
    res.json({"status": "error", "message": error.message});
  }
});

module.exports = router;

方式二：在Promise链中添加catch捕获错误

如果习惯使用Promise链式调用，在链的末尾添加catch来统一处理所有异步错误：

var express = require("express");
var router = express.Router();
var models = require("../models");
const { check, validationResult } = require('express-validator/check');

/* GET users listing. */
router.get('/', function(req, res, next) {
  res.send('respond with a resource - merchant');
});

/* POST ADD USERS. */
router.post('/add-merchant', [
  check('name').not().isEmpty(),
], (req, res, next) => {
  const errors = validationResult(req);
  if (!errors.isEmpty()) {
    return res.json({ errors: errors.array()});
  }
  console.log("error passed")
  
  models.merchants.findOne({ where: {name: req.body.name}})
    .then((merchant) => {
      if(merchant) {
        throw new Error("Username already exists");
      }
      // 返回创建操作的Promise，继续链式调用
      return models.merchants.create(req.body);
    })
    .then((newMerchant) => {
      res.json(newMerchant);
    })
    .catch((error) => {
      // 捕获链中所有错误，统一发送响应
      res.json({"status": "error", "message": error.message});
    });
});

module.exports = router;

修复原理说明 #

两种方式都解决了核心问题：

1. 确保所有异步操作的错误都被捕获，避免出现未处理的Promise拒绝
2. 保证每个请求只会发送一次响应，不会触发重复发送的错误

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