php 实现mysql连接池

基础概念

MySQL连接池是一种管理数据库连接的技术，它预先创建一组数据库连接，并将这些连接保存在一个池中。当应用程序需要与数据库进行交互时，它可以从连接池中获取一个已经建立的连接，使用完毕后，再将连接归还到池中，而不是直接关闭连接。这样可以减少频繁创建和销毁连接的开销，提高数据库访问的性能。

优势

减少连接开销：避免了每次请求都创建和销毁数据库连接的开销。
提高响应速度：由于连接已经预先创建好，应用程序可以快速获取连接，从而提高响应速度。
资源管理：可以更有效地管理数据库连接资源，避免资源浪费。

类型

持久连接：服务器在脚本结束时不关闭连接，而是保持打开状态供后续请求使用。
非持久连接：每次请求结束后都会关闭连接。

应用场景

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

实现MySQL连接池的PHP代码示例

以下是一个简单的PHP MySQL连接池实现示例：

<?php
class MySQLConnectionPool {
    private $pool = [];
    private $minConnections;
    private $maxConnections;
    private $connectionParams;

    public function __construct($host, $user, $password, $database, $minConnections = 5, $maxConnections = 10) {
        $this->connectionParams = [
            'host' => $host,
            'user' => $user,
            'password' => $password,
            'database' => $database
        ];
        $this->minConnections = $minConnections;
        $this->maxConnections = $maxConnections;
        $this->initializePool();
    }

    private function initializePool() {
        for ($i = 0; $i < $this->minConnections; $i++) {
            $this->pool[] = $this->createConnection();
        }
    }

    private function createConnection() {
        try {
            $conn = new mysqli($this->connectionParams['host'], $this->connectionParams['user'], $this->connectionParams['password'], $this->connectionParams['database']);
            if ($conn->connect_error) {
                die("Connection failed: " . $conn->connect_error);
            }
            return $conn;
        } catch (Exception $e) {
            echo "Error: " . $e->getMessage();
        }
    }

    public function getConnection() {
        if (empty($this->pool)) {
            if (count($this->pool) < $this->maxConnections) {
                $this->pool[] = $this->createConnection();
            } else {
                throw new Exception("No available connections in the pool.");
            }
        }
        return array_pop($this->pool);
    }

    public function releaseConnection($conn) {
        if (count($this->pool) < $this->maxConnections) {
            array_push($this->pool, $conn);
        } else {
            $conn->close();
        }
    }
}

// 使用示例
$pool = new MySQLConnectionPool('localhost', 'user', 'password', 'database');
$conn = $pool->getConnection();
// 执行数据库操作
$pool->releaseConnection($conn);
?>