使用mariadb npm包无负载时数据库仍频繁超时，求技术支援

你的代码实现了基于MariaDB连接池的查询函数，但在无负载场景下每隔几分钟就触发超时错误并终止，核心问题通常是数据库服务器主动断开了空闲连接，但连接池未感知到连接失效，下次获取连接时就会触发超时。以下是具体的排查和修复方案：

可能的原因 #

• 数据库端的wait_timeout或interactive_timeout设置比你的连接池idleTimeout短，导致数据库主动回收空闲连接
• 连接池未启用连接有效性校验，无法识别已失效的连接
• 连接池缺少自动重连机制，失效连接未被及时清理

修复方案 #

1. 匹配数据库与连接池的超时参数 #

首先查看你的MariaDB服务器配置，执行以下SQL查询超时设置：

SHOW VARIABLES LIKE '%timeout';

找到wait_timeout和interactive_timeout的值（默认通常是28800秒，即8小时，但部分环境可能设置得很短，比如300秒）。

修改连接池的idleTimeout，确保它小于等于数据库的超时值，比如数据库超时是300秒，那么连接池idleTimeout设为290000（290秒），避免数据库先断开连接：

const pool = mariadb.createPool({
    host: process.env.DB_HOST,
    user: process.env.DB_USER,
    password: process.env.DB_PASSWORD,
    database: process.env.DB_NAME,
    acquireTimeout: 30000,
    connectTimeout: 10000,
    idleTimeout: 290000, // 比数据库wait_timeout小10秒
});

2. 启用连接有效性校验 #

在连接池配置中添加validateConnection选项，每次从池里获取连接时自动验证连接是否可用：

const pool = mariadb.createPool({
    // 原有配置...
    validateConnection: (conn) => {
        return conn.ping().then(() => true).catch(() => false);
    },
});

这个函数会在获取连接前执行ping，如果失败则连接池会自动销毁该连接并创建新连接。

3. 添加连接获取失败的重试逻辑 #

如果连接池中的连接全部失效，第一次获取可能失败，在query函数中添加重试逻辑：

export async function query(sql: string | QueryOptions, values?: Array<unknown>, retryCount = 2) {
    let conn;
    try {
        console.log("Attempting to get a connection from the pool...");
        conn = await pool.getConnection();
        console.log(`Connection acquired. Active connections: ${pool.activeConnections()}, Idle connections: ${pool.idleConnections()}`);

        // 额外手动验证连接（可选，配合validateConnection使用更稳妥）
        await conn.ping();

        console.log("Executing query...");
        const rows = await conn.query(sql, values);

        console.log("Query executed successfully:", rows);
        return rows;
    } catch (e) {
        console.error("Error executing query:", e);
        // 如果是连接相关错误且还有重试次数，递归重试
        if (retryCount > 0 && ((e as Error).message.includes("timeout") || (e as Error).message.includes("closed"))) {
            console.log(`Retrying query, remaining attempts: ${retryCount - 1}`);
            if (conn) await conn.destroy(); // 销毁失效连接
            return query(sql, values, retryCount - 1);
        }
        throw e;
    } finally {
        if (conn) {
            console.log("Releasing connection back to the pool...");
            await conn.release();
            console.log(`Connection released. Active connections: ${pool.activeConnections()}, Idle connections: ${pool.idleConnections()}`);
        }
    }
}

4. 启用连接保活机制 #

如果你的MariaDB版本支持，可以在连接池配置中添加keepAlive选项，定期发送心跳包保持连接活跃：

const pool = mariadb.createPool({
    // 原有配置...
    keepAlive: true,
    keepAliveInterval: 30000, // 每30秒发送一次心跳
});

验证修复 #

修改配置后，让程序在无负载状态下运行，观察是否还会出现超时错误。同时可以通过日志查看连接的获取、释放和验证过程，确认失效连接被正确处理。

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