在 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