利用connect() 創建多實例連接並進行並行處理

M66 2025-05-25

在PHP 開發中，尤其是需要進行大量網絡請求或數據庫連接時，單線程的同步操作往往會成為瓶頸，影響程序的整體效率。為了解決這個問題，我們可以通過創建多個連接實例，並利用並行處理的方式來提升性能。本文將結合PHP 的connect()函數示例，講解如何實現多個實例連接，並利用並行處理來加速操作。

一、單實例連接的局限性

傳統的PHP 代碼往往是同步執行，比如：

 <?php
function connect($url) {
    // 模擬請求
    $content = file_get_contents($url);
    return $content;
}

$urls = [
    'http://example.com/api/1',
    'http://example.com/api/2',
    'http://example.com/api/3',
];

foreach ($urls as $url) {
    $result = connect($url);
    echo $result . "\n";
}
?>

上面代碼中，每次請求都必須等待上一次完成，導致效率低下。如果每個請求耗時1秒，三個請求就要3秒才能全部完成。

二、創建多個連接實例

我們可以為每個請求創建一個獨立的連接實例：

 <?php
class Connector {
    private $url;

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

    public function connect() {
        return file_get_contents($this->url);
    }
}

$urls = [
    'http://m66.net/api/1',
    'http://m66.net/api/2',
    'http://m66.net/api/3',
];

$connectors = [];
foreach ($urls as $url) {
    $connectors[] = new Connector($url);
}

這樣我們將每個請求封裝成一個對象，但依然是同步請求。

三、實現並行處理

PHP 支持多種方式實現並行，比如：

使用curl_multi_*系列函數進行並發請求。
利用多線程（如pthreads擴展）。
使用異步庫如ReactPHP 。

這里以curl_multi為例，展示如何並行處理多個連接實例。

3.1 修改Connector 類使用cURL

 <?php
class Connector {
    private $url;
    private $ch;

    public function __construct($url) {
        $this->url = $url;
        $this->ch = curl_init();
        curl_setopt($this->ch, CURLOPT_URL, $this->url);
        curl_setopt($this->ch, CURLOPT_RETURNTRANSFER, true);
    }

    public function getCurlHandle() {
        return $this->ch;
    }

    public function getContent() {
        return curl_multi_getcontent($this->ch);
    }
}

3.2 並行請求的實現

<?php
$urls = [
    'http://m66.net/api/1',
    'http://m66.net/api/2',
    'http://m66.net/api/3',
];

$connectors = [];
foreach ($urls as $url) {
    $connectors[] = new Connector($url);
}

$multiHandle = curl_multi_init();

foreach ($connectors as $connector) {
    curl_multi_add_handle($multiHandle, $connector->getCurlHandle());
}

$running = null;
do {
    curl_multi_exec($multiHandle, $running);
    curl_multi_select($multiHandle);
} while ($running > 0);

foreach ($connectors as $connector) {
    $content = $connector->getContent();
    echo $content . "\n";
    curl_multi_remove_handle($multiHandle, $connector->getCurlHandle());
}

curl_multi_close($multiHandle);

通過curl_multi ，我們可以同時發起多個HTTP 請求，等待所有請求完成後一次性處理結果，大大節省了等待時間。

四、總結

利用connect()函數封裝請求，創建多個連接實例便於管理。
使用PHP 的curl_multi系列函數，實現請求的並行處理。
並行處理顯著提高了網絡請求或連接的效率，適合需要同時訪問多個接口的場景。

connect