Node.js中UnhandledPromiseRejectionWarning问题求助

以下是针对你遇到问题的具体排查方向和解决方案：

1. 检查是否遗漏await关键字 #

如果你的SQL操作是异步Promise接口，但调用时没加await，Promise的rejection会直接逃逸到全局，外层的try...catch根本捕获不到。

错误示例：

async function handleInsert() {
  try {
    // 未加await，Promise直接被抛出，catch无法捕获
    db.query('INSERT INTO users (name) VALUES (?)', ['test']);
  } catch (err) {
    console.error(err);
  }
}

修复：确保所有异步SQL调用前加await：

async function handleInsert() {
  try {
    await db.query('INSERT INTO users (name) VALUES (?)', ['test']);
  } catch (err) {
    console.error(err);
  }
}

2. 排查嵌套异步操作的错误捕获 #

如果SQL操作嵌套在其他回调或非async函数内部，外层的try...catch无法覆盖内层的Promise rejection。

错误示例：

async function handleRequest() {
  try {
    // 内层回调的SQL操作未被await，错误无法被外层catch捕获
    someAsyncMiddleware(() => {
      db.query('DELETE FROM users WHERE id=?', [1]);
    });
  } catch (err) {
    console.error(err);
  }
}

修复：将嵌套的回调转为async函数并await，或者用Promise封装回调逻辑：

async function handleRequest() {
  try {
    await new Promise((resolve, reject) => {
      someAsyncMiddleware(async () => {
        try {
          await db.query('DELETE FROM users WHERE id=?', [1]);
          resolve();
        } catch (err) {
          reject(err);
        }
      });
    });
  } catch (err) {
    console.error(err);
  }
}

3. 确认请求处理函数的错误传递 #

如果用Express这类框架，async路由函数的Promise rejection需要主动处理，否则会触发全局警告。

错误示例：

// 未处理async函数的rejection，会触发UnhandledPromiseRejectionWarning
app.post('/api/users', async (req, res) => {
  await db.query('INSERT INTO users (name) VALUES (?)', [req.body.name]);
  res.send('success');
});

修复：二选一：

• 路由内加try...catch直接处理错误：

app.post('/api/users', async (req, res) => {
  try {
    await db.query('INSERT INTO users (name) VALUES (?)', [req.body.name]);
    res.send('success');
  } catch (err) {
    console.error(err);
    res.status(500).send('操作失败');
  }
});

• 用全局错误中间件捕获，需将错误传给next()：

app.post('/api/users', async (req, res, next) => {
  try {
    await db.query('INSERT INTO users (name) VALUES (?)', [req.body.name]);
    res.send('success');
  } catch (err) {
    next(err); // 交给全局错误中间件处理
  }
});

// 全局错误处理中间件
app.use((err, req, res, next) => {
  console.error(err.stack);
  res.status(500).send('服务器内部错误');
});

4. 检查SQL库的异步接口类型 #

如果你的SQL库是回调风格而非Promise风格，直接用await无效，错误会在回调中抛出，外层try...catch无法捕获。

错误示例：

async function handleInsert() {
  try {
    // 回调风格的query，await无效，错误在回调中抛出
    await db.query('INSERT INTO users (name) VALUES (?)', ['test'], (err, result) => {
      if (err) throw err;
    });
  } catch (err) {
    console.error(err);
  }
}

修复：用util.promisify将回调接口转为Promise风格：

const util = require('util');
// 封装为Promise风格的查询函数
const queryAsync = util.promisify(db.query).bind(db);

async function handleInsert() {
  try {
    await queryAsync('INSERT INTO users (name) VALUES (?)', ['test']);
  } catch (err) {
    console.error(err);
  }
}

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