mysql连接池php

基础概念

MySQL连接池是一种管理数据库连接的技术，它预先创建一定数量的数据库连接，并将这些连接保存在一个池中。当应用程序需要访问数据库时，可以直接从连接池中获取一个已经建立的连接，而不是每次都重新创建一个新的连接。使用完毕后，连接会被归还到连接池中，供下次使用。

类型

MySQL连接池主要有两种类型：

持久连接：连接一旦建立，就会一直保持，直到超时或被显式关闭。
非持久连接：每次请求结束后，连接会被关闭，下次请求时重新建立。

应用场景

适用于高并发、高访问量的Web应用，如电商网站、社交平台等。

PHP中的实现

在PHP中，可以使用多种方式实现MySQL连接池，以下是一个简单的示例，使用PDO扩展和自定义连接池类：

class MySQLConnectionPool {
    private $pool = [];
    private $minConnections = 5;
    private $maxConnections = 10;
    private $connectionParams;

    public function __construct($host, $dbname, $user, $password) {
        $this->connectionParams = [
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
            PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8mb4',
        ];
        $this->connectionParams[PDO::ATTR_EMULATE_PREPARES] = false;
        $this->connectionParams[PDO::ATTR_STRINGIFY_FETCHES] = false;
        $this->connectionParams[PDO::ATTR_ERRMODE] = PDO::ERRMODE_EXCEPTION;
        $this->connectionParams[PDO::ATTR_DEFAULT_FETCH_MODE] = PDO::FETCH_ASSOC;
        $this->connectionParams[PDO::MYSQL_ATTR_INIT_COMMAND] = 'SET NAMES utf8mb4';

        for ($i = 0; $i < $this->minConnections; $i++) {
            $this->pool[] = new PDO("mysql:host=$host;dbname=$dbname;charset=utf8mb4", $user, $password, $this->connectionParams);
        }
    }

    public function getConnection() {
        if (empty($this->pool)) {
            if (count($this->pool) < $this->maxConnections) {
                $this->pool[] = new PDO("mysql:host={$this->connectionParams['host']};dbname={$this->connectionParams['dbname']};charset=utf8mb4", $this->connectionParams['user'], $this->connectionParams['password'], $this->connectionParams);
            } else {
                throw new Exception('No available connections in the pool.');
            }
        }
        return array_pop($this->pool);
    }

    public function releaseConnection(PDO $connection) {
        $this->pool[] = $connection;
    }
}

// 使用示例
$pool = new MySQLConnectionPool('localhost', 'testdb', 'user', 'password');
$dbh = $pool->getConnection();
try {
    $stmt = $dbh->prepare('SELECT * FROM users WHERE id = :id');
    $stmt->execute(['id' => 1]);
    $result = $stmt->fetch();
    print_r($result);
} catch (Exception $e) {
    echo 'Error: ' . $e->getMessage();
} finally {
    $pool->releaseConnection($dbh);
}