如何排查并修复Oracle+TypeORM后端连接池函数超时问题

核心问题分析 #

当前poolMin:2、poolMax:5的配置在高并发场景下会快速耗尽连接，导致请求排队等待超时；另外现有代码缺少连接超时、闲置连接回收等关键配置，健康检查逻辑也存在潜在阻塞风险，这些都会加剧超时问题。

具体修复方案 #

1. 调整连接池核心参数 #

修改extra配置，补充连接池管理的关键参数，适配业务并发需求：

extra: {
  poolMin: Number(process.env.DB_POOL_MIN) || 5, // 提高最小连接数，减少连接频繁创建销毁的开销
  poolMax: Number(process.env.DB_POOL_MAX) || 15, // 根据峰值并发量调整，比如按QPS的1.5倍设置
  poolIncrement: 2, // 每次扩容的连接数，避免一次性创建过多连接
  poolTimeout: 30, // 闲置连接30秒后自动回收
  queueTimeout: 5000, // 请求等待连接的超时时间（毫秒），避免无限阻塞
  poolPingInterval: 5000, // 定期检查连接可用性，提前淘汰失效连接
}

注意：poolMax需要结合实际业务峰值调整，比如服务峰值有10个并发请求，设15足够应对突发流量；queueTimeout要和业务接口的超时时间匹配，比如接口超时10秒，这里设5秒，提前释放等待的请求。

2. 排查并修复连接泄漏 #

连接泄漏是超时的高发原因，必须确保所有数据库操作都正确释放连接：

• 使用queryRunner时，必须在finally块中释放资源：

const queryRunner = DB.createQueryRunner()
try {
  await queryRunner.connect()
  // 执行数据库操作
} catch (error) {
  // 错误处理
} finally {
  await queryRunner.release() // 必须释放，否则连接会留在池中无法复用
}

• 重点检查confirm-email、start-exam、get-genders这几个函数，确认没有未释放的连接或未完成的事务。

3. 优化健康检查逻辑 #

现有健康检查未设置超时，可能导致检查本身挂起，修改后避免阻塞：

private startHealthCheck(): void {
  if (this.healthCheckInterval) {
    clearInterval(this.healthCheckInterval)
  }

  this.healthCheckInterval = setInterval(async () => {
    const queryRunner = DB.createQueryRunner()
    try {
      await queryRunner.connect()
      // 设置查询超时，防止健康检查卡住
      await queryRunner.query('SELECT 1 FROM DUAL', [], { timeout: 2000 })
    } catch (error) {
      console.error('Health check failed:', error)
      this.handleConnectionError()
    } finally {
      await queryRunner.release()
    }
  }, this.HEALTH_CHECK_INTERVAL)
}

4. 添加数据库操作超时配置 #

可以全局配置查询超时，也可以针对单个查询指定超时：

// 全局配置，添加到extra中
extra: {
  // ...其他参数
  defaultStmtTimeout: 10000, // 单个查询默认超时10秒
  stmtCacheSize: 20, // 开启语句缓存，提升查询性能
}

// 单个查询指定超时
await DB.query('SELECT * FROM genders', [], { timeout: 5000 })

5. 完善重连逻辑 #

现有重连逻辑缺少旧连接池销毁步骤，补充后确保资源完全释放：

// 在DatabaseService中添加连接状态标识
private isConnected = false

public async initialize(): Promise<void> {
  try {
    await DB.initialize()
    console.log('Database connection established')
    this.isConnected = true
    this.startHealthCheck()
  } catch (error) {
    console.error('Failed to connect to database:', error)
    this.isConnected = false
    this.handleConnectionError()
  }
}

private handleConnectionError(): void {
  console.log('Database connection lost. Attempting to reconnect...')

  if (this.reconnectTimeout) clearTimeout(this.reconnectTimeout)
  if (this.healthCheckInterval) clearInterval(this.healthCheckInterval)

  this.reconnectTimeout = setTimeout(async () => {
    try {
      if (DB.isInitialized) {
        await DB.destroy() // 先销毁旧连接池，避免资源泄漏
        DB = createDataSource()
      }

      await DB.initialize()
      console.log('Database connection re-established')
      this.isConnected = true
      this.startHealthCheck()
      this.currentReconnectInterval = 1000
    } catch (error) {
      console.error('Reconnection attempt failed:', error)
      this.isConnected = false
      this.currentReconnectInterval = Math.min(this.currentReconnectInterval * 2, this.MAX_RECONNECT_INTERVAL)
      this.handleConnectionError()
    }
  }, this.currentReconnectInterval)
}

6. 监控连接池状态 #

添加日志定期打印连接池使用情况，方便快速定位问题：

// 在initialize成功后添加监控
setInterval(async () => {
  if (DB.isInitialized) {
    const poolStats = await DB.driver.connectionPool.getStats()
    console.log('Connection pool stats:', {
      active: poolStats.activeConnections,
      idle: poolStats.idleConnections,
      total: poolStats.totalConnections,
      waiting: poolStats.waitingRequests
    })
  }
}, 30000) // 每30秒打印一次

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