当前位置：首页 > PHP

php实现数据库连接池

2026-02-28 05:15:41PHP

PHP 实现数据库连接池的方法

在 PHP 中实现数据库连接池可以通过多种方式完成，以下是几种常见的方法：

使用 PDO 扩展

PDO（PHP Data Objects）是 PHP 的一个数据库访问抽象层，可以用于连接多种类型的数据库。通过 PDO 可以实现简单的连接池功能。

php实现数据库连接池

class ConnectionPool {
    private static $pool = [];
    private static $maxConnections = 10;

    public static function getConnection($dsn, $username, $password) {
        if (count(self::$pool) >= self::$maxConnections) {
            throw new Exception("Connection pool limit reached");
        }

        if (!isset(self::$pool[$dsn])) {
            self::$pool[$dsn] = new PDO($dsn, $username, $password);
        }

        return self::$pool[$dsn];
    }

    public static function releaseConnection($connection) {
        // 在实际应用中可能需要更复杂的释放逻辑
    }
}

使用 Swoole 扩展

Swoole 是一个高性能的 PHP 协程框架，内置了数据库连接池功能。使用 Swoole 可以轻松实现高效的连接池。

php实现数据库连接池

$server = new Swoole\Http\Server("0.0.0.0", 9501);

$server->on('WorkerStart', function ($server, $workerId) {
    global $dbPool;
    $dbPool = new Swoole\Database\PDOPool(
        (new Swoole\Database\PDOConfig())
            ->withHost('127.0.0.1')
            ->withPort(3306)
            ->withDbName('test')
            ->withCharset('utf8mb4')
            ->withUsername('root')
            ->withPassword('password'),
        16
    );
});

$server->on('request', function ($request, $response) {
    global $dbPool;
    $pdo = $dbPool->get();
    $statement = $pdo->query('SELECT * FROM users');
    $result = $statement->fetchAll(PDO::FETCH_ASSOC);
    $dbPool->put($pdo);
    $response->end(json_encode($result));
});

$server->start();

使用第三方库

可以使用一些现成的 PHP 连接池库，如 php-pool 或 laravel-connection-pool。

use PhpPool\ConnectionPool;

$pool = new ConnectionPool(
    [
        'size' => 5,
        'provider' => function () {
            return new PDO('mysql:host=localhost;dbname=test', 'username', 'password');
        }
    ]
);

$connection = $pool->get();
// 使用连接
$pool->put($connection);

手动实现连接池

如果需要更灵活的控制，可以手动实现一个简单的连接池。

class SimpleConnectionPool {
    private $connections = [];
    private $maxConnections;
    private $inUse = [];

    public function __construct($maxConnections = 10) {
        $this->maxConnections = $maxConnections;
    }

    public function getConnection($dsn, $username, $password) {
        if (count($this->inUse) >= $this->maxConnections) {
            throw new Exception("Connection pool limit reached");
        }

        if (!isset($this->connections[$dsn])) {
            $this->connections[$dsn] = new PDO($dsn, $username, $password);
            $this->inUse[] = $dsn;
        }

        return $this->connections[$dsn];
    }

    public function releaseConnection($dsn) {
        if (($key = array_search($dsn, $this->inUse)) !== false) {
            unset($this->inUse[$key]);
        }
    }
}