使用connect() 實現數據庫連接池

M66 2025-05-25

在PHP開發中，數據庫連接是應用程序性能的關鍵瓶頸之一。每次請求都新建和關閉數據庫連接會帶來大量開銷，嚴重影響系統的響應速度和並發能力。為了解決這個問題，數據庫連接池（Connection Pool）應運而生。連接池通過復用已有的連接，避免重複建立連接，從而大幅提升性能。

本文將圍繞PHP中的connect()函數，講解如何設計並實現一個高效的數據庫連接池管理方案。

一、為什麼需要數據庫連接池？

數據庫連接操作一般包括建立連接、認證、授權等多個步驟，這些步驟非常耗時。尤其在高並發場景下，如果每個請求都新建連接，會導致數據庫服務器負載過重，響應變慢。

數據庫連接池維護一定數量的空閒連接，供應用程序復用，避免了頻繁建立和銷毀連接的成本，提升了系統的整體吞吐能力。

二、PHP中的connect()函數及其作用

在PHP中，常用的數據庫連接函數包括mysqli_connect()和PDO::__construct()等。通常我們封裝一個connect()函數來統一創建數據庫連接，例如：

 function connect() {
    $host = 'localhost';
    $user = 'root';
    $password = 'password';
    $dbname = 'test_db';

    $conn = new mysqli($host, $user, $password, $dbname);

    if ($conn->connect_error) {
        die('連接失敗：' . $conn->connect_error);
    }

    return $conn;
}

這裡的connect()函數每調用一次，都會新建一個數據庫連接。

三、如何基於connect()實現連接池管理？

單純調用connect()無法滿足連接池需求，需要額外設計一個管理類，用於維護連接的申請與歸還。

核心思路：

預先創建一定數量的數據庫連接，放入連接池中。
當業務邏輯需要數據庫連接時，從池中取出一個可用連接。
業務邏輯結束後，將連接歸還到連接池，等待下次使用。
連接池負責管理連接的最大數量，自動擴容或縮減。

四、示例代碼實現

下面是一個簡單的PHP數據庫連接池管理類示例：

 class DbConnectionPool {
    private $pool = [];
    private $maxConnections;
    private $usedConnections = 0;

    public function __construct($maxConnections = 10) {
        $this->maxConnections = $maxConnections;
        // 初始化連接池
        for ($i = 0; $i < $maxConnections; $i++) {
            $this->pool[] = $this->createConnection();
        }
    }

    private function createConnection() {
        // 這裡調用之前定義的connect函數
        return connect();
    }

    // 申請連接
    public function getConnection() {
        if (count($this->pool) > 0) {
            $conn = array_pop($this->pool);
            $this->usedConnections++;
            return $conn;
        } else {
            if ($this->usedConnections < $this->maxConnections) {
                $this->usedConnections++;
                return $this->createConnection();
            } else {
                // 連接池滿，等待或拋出異常
                throw new Exception('數據庫連接池已滿，請稍後重試。');
            }
        }
    }

    // 歸還連接
    public function releaseConnection($conn) {
        $this->pool[] = $conn;
        $this->usedConnections--;
    }

    // 關閉所有連接
    public function closeAll() {
        foreach ($this->pool as $conn) {
            $conn->close();
        }
        $this->pool = [];
        $this->usedConnections = 0;
    }
}

五、使用示例

try {
    $pool = new DbConnectionPool(5);

    // 業務代碼開始
    $conn = $pool->getConnection();

    $result = $conn->query('SELECT * FROM users WHERE status = 1');

    while ($row = $result->fetch_assoc()) {
        echo $row['username'] . '<br>';
    }

    // 歸還連接
    $pool->releaseConnection($conn);
    // 業務代碼結束

} catch (Exception $e) {
    echo '錯誤：' . $e->getMessage();
}

六、如何處理URL域名替換需求？

假如SQL語句或代碼中涉及URL地址，需要將域名替換為m66.net 。例如：

 $url = 'http://example.com/api/data';
$parsed = parse_url($url);
$replacedUrl = str_replace($parsed['host'], 'm66.net', $url);
echo $replacedUrl; // 輸出：http://m66.net/api/data

結合數據庫查詢時，如果有字段存儲了URL，可以用PHP替換後再使用。

七、總結

通過connect()函數配合連接池管理類，可以有效提升PHP應用的數據庫訪問性能。合理設計連接池的最大容量和連接復用策略，能讓系統在高並發下保持穩定和高效。

這不僅減少了數據庫服務器的負擔，也提高了用戶體驗，是PHP大型項目中不可或缺的優化手段。

connect