如何在node-postgres中优雅处理“SASL: SCRAM-SERVER-FIRST-MESSAGE”报错

你尝试的两种处理方案本身逻辑正确，出现漏捕大多是绑定时机、API调用方式的问题，以下是可直接复用的完整处理逻辑：

核心问题说明 #

1. 若使用回调风格调用pool.connect()，try-catch无法捕获异步抛出的错误，错误会作为回调的第一个参数返回
2. Pool对象的error事件必须在实例化后立刻绑定，晚于初始化阶段触发的错误会直接抛到全局导致进程崩溃

完整实现代码 #

Promise + async/await 写法（推荐） #

const { Pool } = require('pg');

// 连接池配置示例，此处模拟未传密码的场景
const pool = new Pool({
  host: '127.0.0.1',
  port: 5432,
  user: 'postgres',
  database: 'test_db'
  // password: 'xxx'  故意缺失触发认证错误
});

// 1. 实例化后立刻绑定连接池全局error事件，处理后台自动建连的错误
pool.on('error', (err) => {
  // 匹配PostgreSQL身份验证错误码 28P01
  if (err.code === '28P01') {
    console.error('数据库身份验证失败，请检查账号密码配置');
    // 自定义降级逻辑：比如终止服务启动、返回默认静态数据、提示管理员修改配置等
  } else {
    console.error('连接池异常:', err.message);
  }
});

async function getValidClient() {
  let client = null;
  try {
    client = await pool.connect();
    // 绑定单个client的error事件，处理连接建立后出现的异常
    client.on('error', (err) => {
      console.error('数据库客户端异常:', err.message);
    });
    return client;
  } catch (err) {
    // 此处可捕获主动调用connect时的认证错误
    if (err.code === '28P01') {
      console.error('获取连接失败：身份验证不通过');
      // 你的自定义优雅处理逻辑
    }
    // 已经拿到client的场景要主动释放
    if (client) client.release();
    // 根据业务需求选择抛出错误或者返回默认值
    throw err;
  }
}

回调风格写法 #

const pool = new Pool({/* 配置同上 */});
pool.on('error', (err) => { /* 全局错误处理同上 */ });

pool.connect((err, client, release) => {
  if (err) {
    if (err.code === '28P01') {
      // 处理认证错误
    }
    return console.error('获取连接失败:', err.message);
  }
  client.on('error', (err) => { /* client错误处理同上 */ });
  // 业务逻辑执行完毕后释放连接
  release();
});

补充注意事项 #

• 若需要兜底所有未捕获的数据库错误，可添加全局进程异常监听，避免服务直接崩溃：

process.on('uncaughtException', (err) => {
  if (err.code === '28P01') {
    console.error('全局捕获数据库认证错误:', err.message);
    // 执行优雅退出逻辑
    // process.exit(1);
  }
});

• 所有PoolClient使用完毕后必须调用release()方法释放，避免连接池资源被耗尽

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