PHP数据库连接泄漏防范-源码库

PHP数据库连接泄漏防范：从一次线上故障说起

上周我们线上环境出现了一个诡异的问题——数据库连接数持续增长，最终导致新请求无法建立数据库连接。经过排查，发现是数据库连接没有正确关闭导致的泄漏问题。今天我就结合这次实战经验，分享如何在PHP开发中有效防范数据库连接泄漏。

什么是数据库连接泄漏？

简单来说，就是程序申请了数据库连接，但在使用完毕后没有及时释放，导致连接一直占用着数据库资源。当这样的”僵尸连接”积累到数据库最大连接数时，新的数据库请求就会被拒绝。

常见的连接泄漏场景

在我遇到的案例中，主要有以下几种情况：

// 场景1：异常情况下连接未关闭
try {
    $pdo = new PDO($dsn, $username, $password);
    // 执行数据库操作
    // 如果这里抛出异常，下面的close就不会执行
    $pdo = null; // 关闭连接
} catch (Exception $e) {
    // 连接泄漏了！
    log_error($e->getMessage());
}

// 场景2：长生命周期脚本中的连接累积
while (true) {
    $db = new mysqli($host, $user, $pass, $database);
    // 处理数据
    // 忘记关闭连接，每次循环都创建新连接
}

正确的连接管理姿势

经过这次教训，我总结了几个有效的防范措施：

1. 使用try-finally确保连接关闭

$pdo = null;
try {
    $pdo = new PDO($dsn, $username, $password);
    // 执行数据库操作
    $stmt = $pdo->query('SELECT * FROM users');
    // ... 其他操作
} finally {
    // 无论是否发生异常，都会执行关闭操作
    if ($pdo !== null) {
        $pdo = null;
    }
}

2. 利用析构函数自动管理

class DatabaseConnection {
    private $connection;
    
    public function __construct($config) {
        $this->connection = new PDO(
            $config['dsn'], 
            $config['username'], 
            $config['password']
        );
    }
    
    public function __destruct() {
        // 对象销毁时自动关闭连接
        $this->connection = null;
    }
    
    public function query($sql) {
        return $this->connection->query($sql);
    }
}

// 使用示例
$db = new DatabaseConnection($config);
$result = $db->query('SELECT * FROM products');
// 当$db超出作用域或被unset时，连接自动关闭

3. 使用连接池（适用于高并发场景）

class ConnectionPool {
    private $pool;
    private $config;
    private $maxConnections;
    
    public function __construct($config, $maxConnections = 10) {
        $this->config = $config;
        $this->maxConnections = $maxConnections;
        $this->pool = new SplQueue();
    }
    
    public function getConnection() {
        if (!$this->pool->isEmpty()) {
            return $this->pool->dequeue();
        }
        
        if (count($this->pool) < $this->maxConnections) {
            return new PDO(
                $this->config['dsn'],
                $this->config['username'],
                $this->config['password']
            );
        }
        
        throw new Exception('连接池已满');
    }
    
    public function releaseConnection($connection) {
        $this->pool->enqueue($connection);
    }
}

4. 监控和告警机制

除了代码层面的防范，建立监控也很重要：

// 简单的连接数监控
function checkConnectionUsage() {
    $pdo = new PDO($dsn, $username, $password);
    $result = $pdo->query('SHOW PROCESSLIST');
    $connections = $result->rowCount();
    
    if ($connections > 100) { // 阈值根据实际情况调整
        // 发送告警
        sendAlert("数据库连接数异常：{$connections}");
    }
}