当前位置：首页 > PHP

php实现数据库连接池

2026-01-29 08:02:33PHP

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

PHP 本身没有内置的数据库连接池功能，但可以通过多种方式实现类似效果。以下是几种常见的方法：

使用 PDO 持久连接

PDO 支持持久连接，可以在多个请求之间保持连接不关闭：

$dsn = 'mysql:host=localhost;dbname=test';
$options = [
    PDO::ATTR_PERSISTENT => true
];
$db = new PDO($dsn, $username, $password, $options);

持久连接会在脚本结束后保持打开状态，下次请求可以复用。需要注意并发连接数限制。

使用 Swoole 扩展

Swoole 提供了内置的连接池功能：

$pool = new Swoole\ConnectionPool(
    function() {
        return new PDO('mysql:host=localhost;dbname=test', 'user', 'pass');
    },
    100 // 连接池大小
);

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

Swoole 的连接池适合长生命周期应用，如常驻内存的 CLI 或 Swoole HTTP 服务器。

使用第三方库

一些 PHP 库提供了连接池实现，例如：

php-pool/pool
spatie/laravel-pool (Laravel 专用)

安装示例：

composer require php-pool/pool

使用示例：

$pool = new PhpPool\Pool(
    function() {
        return new PDO('mysql:host=localhost;dbname=test', 'user', 'pass');
    },
    ['max' => 20]
);

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

实现自定义连接池

可以自行实现简单的连接池：

class ConnectionPool {
    private $pool = [];
    private $maxSize;

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

    public function get() {
        if (!empty($this->pool)) {
            return array_pop($this->pool);
        }

        if (count($this->pool) < $this->maxSize) {
            return $this->createConnection();
        }

        throw new RuntimeException('Connection pool exhausted');
    }

    public function release($connection) {
        if (count($this->pool) < $this->maxSize) {
            $this->pool[] = $connection;
        }
    }

    private function createConnection() {
        return new PDO('mysql:host=localhost;dbname=test', 'user', 'pass');
    }
}