PHP 多線程併發請求實作：cURL Multi Handle 並行抓取完整封裝類別

PHP cURL 多線程併發請求：Http_MultiRequest 類別完整實作

為什麼需要併發請求？

串行請求總耗時 = Σ(單次請求耗時)。對多個獨立 API 呼叫、爬蟲抓取、微服務聚合，併發可將總耗時降至 ≈ max(單次請求耗時)，效能提升顯著。

核心類別實作

<?php
class Http_MultiRequest {
    private $urls = [];
    private $options = [];

    public function __construct($options = []) {
        $this->setOptions($options);
    }

    public function setUrls(array $urls) {
        $this->urls = $urls;
        return $this;
    }

    public function setOptions(array $options) {
        // 預設選項
        $defaults = [
            CURLOPT_RETURNTRANSFER => 1,
            CURLOPT_USERAGENT      => 'Mozilla/5.0 (compatible; PHP Http_MultiRequest)',
            CURLOPT_FOLLOWLOCATION => 1,
            CURLOPT_HEADER         => 0,
            CURLOPT_TIMEOUT        => 30,
            CURLOPT_CONNECTTIMEOUT => 10,
            CURLOPT_SSL_VERIFYPEER => false, // 測試環境；生產請設 true 並配置 CA
        ];
        
        // POST 資料處理
        if (isset($options['HTTP_POST'])) {
            $defaults[CURLOPT_POST] = 1;
            $defaults[CURLOPT_POSTFIELDS] = $options['HTTP_POST'];
            unset($options['HTTP_POST']);
        }
        
        $this->options = array_merge($defaults, $options);
    }

    /** 併發執行所有 URL */
    public function exec() {
        if (empty($this->urls) || !is_array($this->urls)) return false;

        $mh = curl_multi_init();
        $handles = [];

        // 建立並加入 handles
        foreach ($this->urls as $k => $url) {
            $ch = curl_init($url);
            curl_setopt_array($ch, $this->options);
            curl_multi_add_handle($mh, $ch);
            $handles[$k] = $ch;
        }

        // 執行併發 —— 改良版：使用 curl_multi_select 避免 CPU 100%
        $this->execMultiHandle($mh);

        // 收集結果
        $results = [];
        foreach ($handles as $k => $ch) {
            $results[$k] = curl_multi_getcontent($ch);
            curl_multi_remove_handle($mh, $ch);
        }
        curl_multi_close($mh);
        return $results;
    }

    /** 單一請求（串行） */
    public function execOne($url) {
        if (empty($url)) return false;
        $ch = curl_init($url);
        curl_setopt_array($ch, $this->options);
        $content = curl_exec($ch);
        curl_close($ch);
        return $content;
    }

    /** 改良版併發迴圈：避免忙等待消耗 CPU */
    private function execMultiHandle($mh) {
        $running = null;
        do {
            // 執行可用的傳輸
            curl_multi_exec($mh, $running);
            
            // 等待活動，最長 1 秒 —— 關鍵優化！
            if ($running > 0) {
                curl_multi_select($mh, 1.0);
            }
        } while ($running > 0);
    }
}
?>

效能對比測試

<?php
$urls = [
    "https://httpbin.org/delay/1",
    "https://httpbin.org/delay/1",
    "https://httpbin.org/delay/1",
    "https://httpbin.org/delay/1",
    "https://httpbin.org/delay/1",
];

$client = new Http_MultiRequest();

// 併發測試
$start = microtime(true);
$parallelData = $client->setUrls($urls)->exec();
$parallelTime = microtime(true) - $start;
echo "併發耗時: {$parallelTime} 秒\n"; // 約 1 秒

// 串行測試
$start = microtime(true);
$serialData = [];
foreach ($urls as $url) {
    $serialData[] = $client->execOne($url);
}
$serialTime = microtime(true) - $start;
echo "串行耗時: {$serialTime} 秒\n"; // 約 5 秒

echo "加速比: " . round($serialTime / $parallelTime, 1) . "x\n";
?>

關鍵優化細節：curl_multi_select

進階擴充建議

• 錯誤處理：檢查 curl_errno()、curl_getinfo($ch, CURLINFO_HTTP_CODE)
• 超時控制：CURLOPT_TIMEOUT、CURLOPT_CONNECTTIMEOUT
• 限流機制：分批次處理大量 URL，避免連線耗盡
• 重試邏輯：指數退避重試失敗請求
• 非阻塞框架：Swoole、ReactPHP、Amp 實現真非阻塞 I/O

適用場景對比

1. 上一篇文章： PHP 多維陣列依指定鍵值分組合併：遞歸實現相同字段值聚合
2. 下一篇文章： PHP 多維陣列指定欄位排序：array_multisort 封裝通用函式

PHP 相關知識

PHP 擴展開發：深入掌握 zend_parse_parameters 參數解析與類型處理

前言 在 PHP 擴展開發中，接收來自用戶空間（PHP 代碼

PHP SPL 標準庫：被遺忘的寶藏——自動加載、迭代器、固定數組與數據結構實戰指南

SPL (Standard PHP Library) 從 P

PHP 實現無限層級資料 JSON 格式輸出與 JavaScript 遞迴解析

應用場景 Flash/前端需求呈現樹狀結構資料（如會員下線關

掃描同一 QR Code 依瀏覽器類型導向不同下載頁面（純 PHP 實作）

掃描同一 QR Code 依瀏覽器類型導向不同下載頁面 與上