数据库连接池配置优化

数据库连接池配置优化

Koa2应用中数据库连接池的配置直接影响性能表现。连接池过小会导致请求排队等待，过大则可能耗尽系统资源。合理的配置需要结合具体业务场景和服务器硬件条件进行调整。

连接池基础参数解析

核心配置参数包括：

• max: 最大连接数
• min: 最小保持连接数
• acquire: 获取连接超时时间(毫秒)
• idle: 连接最大空闲时间(毫秒)

const pool = new Pool({
  max: 20,
  min: 5,
  acquire: 30000,
  idle: 10000
})

连接数计算公式

推荐的最大连接数公式：

最大连接数 = (核心数 * 2) + 有效磁盘数

例如4核服务器带SSD存储：

const cpuCores = require('os').cpus().length
const maxConnections = (cpuCores * 2) + 1  // 得到9

连接泄漏检测

Koa2中间件中需要显式释放连接：

app.use(async (ctx, next) => {
  const conn = await pool.getConnection()
  try {
    await next()
  } finally {
    conn.release() // 必须释放
  }
})

添加泄漏监控：

setInterval(() => {
  if(pool.numUsed() > maxConnections * 0.8) {
    console.warn('连接使用率超过80%')
  }
}, 5000)

分库分表场景优化

多数据源配置示例：

const userPool = new Pool({
  max: 10,
  // ...用户库配置
})

const orderPool = new Pool({
  max: 15,
  // ...订单库配置  
})

// 根据路由选择连接池
app.use(async (ctx, next) => {
  if(ctx.path.startsWith('/api/user')) {
    ctx.db = userPool
  } else {
    ctx.db = orderPool 
  }
  await next()
})

压力测试调优

使用autocannon进行基准测试：

npx autocannon -c 100 -d 60 http://localhost:3000/api

观察指标调整参数：

1. 逐步增加max值直到吞吐量不再提升
2. 监控内存使用情况
3. 记录错误率变化

连接池事件监听

重要事件处理：

pool.on('acquire', connection => {
  console.log(`Connection ${connection.threadId} acquired`)
})

pool.on('release', connection => {
  console.log(`Connection ${connection.threadId} released`)
})

pool.on('error', err => {
  console.error('Unexpected pool error', err)
})

生产环境实践

典型电商应用配置：

{
  max: 50,
  min: 10,
  acquire: 10000,
  idle: 60000,
  evict: 10000, // 检查空闲连接间隔
  connectTimeout: 2000 // 连接超时
}

灰度发布时建议：

1. 先修改单个实例配置
2. 观察15分钟监控数据
3. 全量滚动更新

连接池健康检查

定时验证连接有效性：

setInterval(async () => {
  const conn = await pool.getConnection()
  try {
    await conn.query('SELECT 1')
  } finally {
    conn.release()
  }
}, 300000) // 每5分钟执行

连接池包装模式

创建智能连接代理：

class SmartPool {
  constructor(pool) {
    this.pool = pool
    this.stats = {
      acquires: 0,
      releases: 0
    }
  }

  async getConnection() {
    this.stats.acquires++
    return this.pool.getConnection()
  }

  // 其他代理方法...
}