在curl_multi_info_read 裡怎樣有效管理和處理多個cURL 請求的返回數據？

gitbox 2025-06-19

在PHP 中， curl_multi_*函數提供了一種高效的方式來同時發送多個HTTP 請求。尤其是curl_multi_info_read函數，它能幫助我們在發起多個cURL 請求時管理和處理它們的返回數據。本文將詳細探討如何在使用curl_multi_info_read時，充分管理和處理多個cURL 請求的返回數據，確保高效和準確。

1. 背景介紹

在PHP 中， curl擴展提供了豐富的API 來進行HTTP 請求。當你需要發起多個HTTP 請求時，通常會使用curl_multi_*函數來並行執行這些請求。 curl_multi_exec用於執行多個請求，而curl_multi_info_read則用於獲取每個請求的執行信息及其返回數據。

2. 如何使用curl_multi_*函數？

首先，使用curl_multi_init()初始化一個多cURL 句柄，然後為每個請求創建單獨的cURL 句柄，並將它們添加到多cURL 句柄中。以下是一個簡單的示例：

 <?php
// 初始化一個多 cURL 句柄
$multiCurl = curl_multi_init();

// 創建多個單獨的 cURL 請求句柄
$curlHandles = [];
$urls = ['https://gitbox.net/api/data1', 'https://gitbox.net/api/data2', 'https://gitbox.net/api/data3'];

foreach ($urls as $url) {
    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_multi_add_handle($multiCurl, $ch);
    $curlHandles[] = $ch;
}

// 執行請求
do {
    $status = curl_multi_exec($multiCurl, $active);
    if ($active) {
        // 等待活動完成
        curl_multi_select($multiCurl);
    }
} while ($active && $status == CURLM_OK);

// 處理每個請求的結果
foreach ($curlHandles as $ch) {
    $response = curl_multi_getcontent($ch);
    // 處理返回數據
    echo $response . PHP_EOL;
    // 關閉句柄
    curl_multi_remove_handle($multiCurl, $ch);
    curl_close($ch);
}

// 關閉多 cURL 句柄
curl_multi_close($multiCurl);
?>

在上面的代碼中，我們通過curl_multi_add_handle把每個cURL 請求句柄添加到多cURL 句柄$multiCurl中，然後通過curl_multi_exec同時執行這些請求。

3. 使用curl_multi_info_read獲取請求狀態

curl_multi_info_read函數用於從多cURL 句柄中獲取每個請求的返回信息。通過此函數，我們可以獲得請求的執行狀態、錯誤信息以及請求的返回內容。以下是如何使用它來管理和處理多個請求的返回數據：

 <?php
// 假設已經初始化並執行了多 cURL 請求（見上文）

// 获取每个請求的执行信息
while ($done = curl_multi_info_read($multiCurl)) {
    // 获取請求状态
    $status = $done['result'];
    $ch = $done['handle'];

    if ($status === CURLE_OK) {
        // 請求成功
        $response = curl_multi_getcontent($ch);
        echo "請求成功，返回數據： " . $response . PHP_EOL;
    } else {
        // 請求失败
        echo "請求失败，錯誤訊息：" . curl_error($ch) . PHP_EOL;
    }

    // 移除已完成的句柄
    curl_multi_remove_handle($multiCurl, $ch);
    curl_close($ch);
}

// 關閉多 cURL 句柄
curl_multi_close($multiCurl);
?>

在這個示例中，我們使用curl_multi_info_read獲取每個請求的返回信息。如果請求成功，我們會通過curl_multi_getcontent獲取返回的數據。否則，我們會打印出錯誤信息。

4. 如何處理請求的返回數據？

當多個請求並行執行時，每個請求的返回數據可能有不同的結構或內容。因此，在處理返回數據時，我們需要考慮以下幾個方面：

數據格式的統一性：確保所有請求返回的數據格式一致，便於後續處理。例如，可以考慮將返回的數據轉化為JSON 格式，統一進行解析。
錯誤處理：對於每個請求，必須處理請求失敗的情況。通過curl_multi_info_read可以獲取請求的錯誤信息，幫助調試和分析問題。
異步數據處理：在某些情況下，返回的數據需要進一步異步處理，例如存入數據庫或進行其他的API 調用。在這種情況下，可以使用隊列系統或將數據存儲到緩存中，稍後再處理。

以下是一個結合數據格式處理和錯誤處理的例子：

 <?php
// 假設已經執行了多個 cURL 請求并获取了返回數據

while ($done = curl_multi_info_read($multiCurl)) {
    $ch = $done['handle'];
    $status = $done['result'];

    // 检查請求是否成功
    if ($status === CURLE_OK) {
        $response = curl_multi_getcontent($ch);
        // 假設返回的是 JSON 數據
        $data = json_decode($response, true);

        if ($data === null) {
            echo "解析 JSON 數據失败：" . json_last_error_msg() . PHP_EOL;
        } else {
            // 处理數據
            echo "成功获取數據：" . print_r($data, true) . PHP_EOL;
        }
    } else {
        // 請求失败，输出錯誤訊息
        echo "請求失败，錯誤訊息：" . curl_error($ch) . PHP_EOL;
    }

    // 移除并關閉句柄
    curl_multi_remove_handle($multiCurl, $ch);
    curl_close($ch);
}

curl_multi_close($multiCurl);
?>

在此代碼中，我們通過json_decode解析返回的JSON 數據，並處理解析錯誤。

5. 性能優化建議

雖然curl_multi_*函數已經允許並行請求，但在高並發環境下，我們依然需要考慮以下優化措施：

批量請求：將請求分批次發送而不是一次性發送所有請求，避免過多並發請求導致資源耗盡或性能下降。
請求超時設置：通過設置合適的超時限制，防止某個請求一直阻塞，影響其他請求的執行。使用CURLOPT_TIMEOUT或CURLOPT_TIMEOUT_MS來設置請求超時。
連接池：利用cURL 的連接復用機制，減少重複建立連接的開銷，可以通過設置CURLOPT_FORBID_REUSE和CURLOPT_FRESH_CONNECT來優化連接的複用。

6. 總結

通過curl_multi_info_read和curl_multi_*函數，PHP 可以非常高效地管理和處理多個並行的HTTP 請求。在實際應用中，我們不僅要關注請求的並行執行，還要有效處理返回的數據，確保處理的可靠性和性能。

希望這篇文章能幫助你更好地理解如何在PHP 中利用curl_multi_info_read來管理多個請求並處理它們的返回數據。

相關標籤:
cURL