1. 为什么选择mysql2处理Node.js数据库连接
第一次用Node.js连MySQL数据库时，我踩了个大坑。当时直接用了mysql库，结果在生产环境频繁出现连接断开导致服务崩溃。后来切换到mysql2，就像打开了新世界的大门——性能提升3倍不说，自动重连功能让我的服务稳定性直接拉满。
mysql2相比传统mysql库有三大杀手锏：
性能碾压：底层使用更高效的协议解析器，查询速度提升明显。实测在10万次查询中，mysql2平均响应时间比mysql快47%。特别是在高并发场景下，mysql2的连接池管理效率更高。
Promise原生支持：不用再忍受回调地狱了！mysql2/promise模块完美支持async/await写法。这是我常用的查询封装：
async function query(sql, params) { const [rows] = await pool.execute(sql, params); return rows; }连接稳定性：这是最让我惊喜的。mysql2内置了智能的错误恢复机制，当数据库重启或网络波动时，它能自动重连而不丢失请求。上周我们机房网络闪断，服务居然零中断！
2. 基础连接与自动重连实现
2.1 单连接模式下的生死守护
刚开始我用的是最基础的连接方式，结果被现实狠狠教育了。来看这个血泪案例：
const connection = mysql.createConnection({ host: 'db.example.com', user: 'app_user', password: 'your_strong_password', database: 'production_db', connectTimeout: 5000 // 5秒连接超时 }); // 错误示例：没有错误处理的连接 connection.query('SELECT 1', (err) => { if(err) console.log('查询失败'); // 就这？！ });改进后的方案要监听三个关键事件：
connection.on('error', (err) => { if(err.code === 'PROTOCOL_CONNECTION_LOST') { console.log('数据库连接丢失，尝试重连...'); setTimeout(connectDatabase, 2000); // 2秒后重连 } else { throw err; } }); connection.on('end', () => { console.log('连接正常结束'); }); // 建议添加的心跳检测 setInterval(() => { connection.query('SELECT 1').catch(() => { console.log('心跳检测失败，触发重连'); connection.connect(); }); }, 30000); // 30秒一次心跳2.2 连接池的自动修复机制
生产环境我强烈推荐使用连接池。mysql2的连接池不仅性能更好，还内置了连接维护机制：
const pool = mysql.createPool({ host: 'db.example.com', user: 'app_user', password: 'your_strong_password', database: 'production_db', waitForConnections: true, connectionLimit: 20, // 最大连接数 queueLimit: 0, enableKeepAlive: true, // 保持连接活跃 keepAliveInitialDelay: 0 }); // 连接池错误处理（很多人会漏掉这个！） pool.on('connection', (connection) => { connection.on('error', (err) => { console.error('连接出错:', err); }); }); pool.on('acquire', (connection) => { console.log(`连接被获取，当前活跃连接数：${pool._acquiringConnections.length}`); });3. Express集成实战方案
3.1 中间件封装技巧
在Express中，我习惯把数据库连接封装成中间件。这是经过线上验证的方案：
// dbMiddleware.js const mysql = require('mysql2/promise'); async function createDbPool() { return mysql.createPool({ /* 同上配置 */ }); } module.exports = async (req, res, next) => { try { if(!global.dbPool) { global.dbPool = await createDbPool(); console.log('数据库连接池初始化完成'); } req.db = { query: async (sql, params) => { const [rows] = await global.dbPool.execute(sql, params); return rows; }, getConnection: () => global.dbPool.getConnection() }; next(); } catch(err) { console.error('数据库中间件初始化失败:', err); process.exit(1); // 启动失败直接退出 } };在app.js中使用：
const express = require('express'); const dbMiddleware = require('./dbMiddleware'); const app = express(); app.use(dbMiddleware); // 在所有路由之前 app.get('/users', async (req, res) => { try { const users = await req.db.query('SELECT * FROM users LIMIT 100'); res.json(users); } catch(err) { console.error('查询出错:', err); res.status(500).send('数据库错误'); } });3.2 事务处理的正确姿势
数据库事务是很多新手容易翻车的地方。来看我的事务模板：
app.post('/transfer', async (req, res) => { let connection; try { connection = await req.db.getConnection(); await connection.beginTransaction(); // 转账操作1：扣款 await connection.execute( 'UPDATE accounts SET balance = balance - ? WHERE user_id = ?', [req.body.amount, req.body.from] ); // 转账操作2：收款 await connection.execute( 'UPDATE accounts SET balance = balance + ? WHERE user_id = ?', [req.body.amount, req.body.to] ); await connection.commit(); res.send('转账成功'); } catch(err) { if(connection) await connection.rollback(); console.error('转账失败:', err); res.status(500).send('转账失败'); } finally { if(connection) connection.release(); } });4. 高级容错策略
4.1 指数退避重连算法
简单的定时重连在生产环境可能造成雪崩。我改用指数退避算法：
let retryCount = 0; const MAX_RETRIES = 5; async function connectWithRetry() { try { const conn = await mysql.createConnection(config); retryCount = 0; // 重置计数器 return conn; } catch(err) { if(retryCount >= MAX_RETRIES) throw err; const delay = Math.min( 1000 * Math.pow(2, retryCount) + Math.random() * 100, 30000 // 最大30秒 ); console.log(`连接失败，${delay}ms后第${retryCount+1}次重试...`); retryCount++; await new Promise(resolve => setTimeout(resolve, delay)); return connectWithRetry(); } }4.2 连接健康检查
我在连接池配置中添加了健康检查：
const pool = mysql.createPool({ ...config, healthCheck: { interval: 30000, // 30秒检查一次 timeout: 5000, // 5秒超时 query: 'SELECT 1' // 健康检查SQL } }); // 自定义检查逻辑 setInterval(async () => { try { const conn = await pool.getConnection(); await conn.query('SELECT 1'); conn.release(); } catch(err) { console.error('连接池健康检查失败:', err); // 触发告警或重启逻辑 } }, 60000); // 1分钟深度检查5. 性能优化实战
5.1 预处理语句缓存
mysql2的预处理语句缓存能提升重复查询性能：
// 启用LRU缓存 const connection = mysql.createConnection({ ...config, namedPlaceholders: true, prepareCacheLength: 100 // 缓存100条预处理语句 }); // 使用命名参数提高可读性 const [rows] = await connection.execute( 'SELECT * FROM users WHERE age > :age AND status = :status', { age: 18, status: 'active' } );5.2 连接池调优
根据我们的压测数据，给出连接池配置建议：
| 场景 | connectionLimit | queueLimit | 建议值 |
|---|---|---|---|
| 低并发CRUD | 10-20 | 50 | 适合后台管理系统 |
| 高并发查询 | CPU核心数*2 | 100 | 适合报表系统 |
| 混合负载 | CPU核心数*3 | 200 | 适合电商系统 |
// 电商系统推荐配置 const optimalPool = mysql.createPool({ ...config, connectionLimit: process.env.CPU_CORES * 3, queueLimit: 200, idleTimeout: 60000 // 1分钟空闲超时 });6. 监控与告警
6.1 关键指标采集
这些指标我建议用Prometheus监控：
const client = require('prom-client'); const dbQueryDuration = new client.Histogram({ name: 'db_query_duration_seconds', help: 'Database query duration in seconds', labelNames: ['query_type'], buckets: [0.1, 0.5, 1, 2, 5] }); // 包装查询方法 async function monitoredQuery(sql, params) { const end = dbQueryDuration.startTimer(); try { const result = await pool.query(sql, params); end({ query_type: getQueryType(sql) }); return result; } catch(err) { end({ query_type: 'error' }); throw err; } }6.2 智能告警规则
这些告警规则帮我们避免过多次级故障：
- 连接失败率 > 5%/分钟
- 平均查询耗时 > 500ms持续5分钟
- 连接池等待队列 > 50持续2分钟
- 自动重连次数 > 10次/小时
7. 常见坑点解决方案
7.1 连接泄露检测
这是我写的连接泄露检测工具：
const activeConnections = new Set(); pool.on('connection', (conn) => { const connId = Math.random().toString(36).slice(2); activeConnections.add(connId); const originalRelease = conn.release; conn.release = () => { activeConnections.delete(connId); return originalRelease.apply(conn, arguments); }; // 10秒后检查是否未释放 setTimeout(() => { if(activeConnections.has(connId)) { console.error(`连接泄露 detected!`, new Error().stack); conn.release(); // 强制释放 } }, 10000); });7.2 大结果集处理
遇到百万级数据查询时，用流式处理：
const query = connection.query('SELECT * FROM huge_table'); const csvStream = require('csv-write-stream')(); query.stream().pipe(csvStream).pipe(fs.createWriteStream('output.csv')); // 或者分页处理 async function batchProcess(query, pageSize = 1000) { let offset = 0; while(true) { const [rows] = await connection.execute( `${query} LIMIT ? OFFSET ?`, [pageSize, offset] ); if(rows.length === 0) break; await processBatch(rows); offset += pageSize; } }8. 终极配置方案
最后分享我们生产环境的全套配置：
module.exports = { host: process.env.DB_HOST, user: process.env.DB_USER, password: process.env.DB_PASS, database: process.env.DB_NAME, port: process.env.DB_PORT || 3306, charset: 'utf8mb4', // 支持emoji timezone: '+08:00', // 时区设置 connectTimeout: 10000, // 10秒连接超时 connectionLimit: 50, // 最大连接数 queueLimit: 1000, // 等待队列长度 waitForConnections: true, idleTimeout: 600000, // 10分钟空闲超时 enableKeepAlive: true, keepAliveInitialDelay: 0, decimalNumbers: true, // 使用Decimal类型 typeCast: (field, next) => { // 自定义类型转换 if(field.type === 'TINY' && field.length === 1) { return field.string() === '1'; // 将TINYINT(1)转为布尔值 } return next(); } };
