curl_multi_close 与 curl_getinfo 配合使用时的数据同步问题

gitbox 2025-05-12

在 PHP 中，curl_multi_* 系列函数提供了异步处理多个 cURL 请求的能力，这对于需要同时请求多个 URL 并等待结果的场景非常有用。在这些异步请求中，curl_getinfo 用于获取有关每个请求的详细信息，比如 HTTP 状态码、请求的 URL、传输的时间等。然而，在使用 curl_multi_close 关闭一个多 cURL 会话时，如何正确地获取和处理每个请求的返回信息，避免数据同步问题，成为开发者在实际开发中常常遇到的难题。

本文将讨论如何在使用 curl_multi_close 进行多个请求的处理时，确保通过 curl_getinfo 正确地获取请求的详细信息，并避免由于请求关闭时机不当而产生的数据同步问题。

1. 了解 curl_multi_* 函数和 curl_getinfo 的基本用法

在 PHP 中，curl_multi_* 函数允许我们同时发起多个 cURL 请求，通过多线程并行处理它们。例如，使用 curl_multi_init 来初始化一个 cURL 句柄集，使用 curl_multi_add_handle 添加多个 cURL 句柄，然后通过 curl_multi_exec 执行并等待所有请求完成。最后，使用 curl_multi_close 关闭会话。

以下是一个简单的示例：

$mh = curl_multi_init();  // 初始化 multi curl 句柄
$ch1 = curl_init("http://gitbox.net/api/data1");  // 请求 1
$ch2 = curl_init("http://gitbox.net/api/data2");  // 请求 2

curl_multi_add_handle($mh, $ch1);  // 添加请求 1
curl_multi_add_handle($mh, $ch2);  // 添加请求 2

do {
    $mrc = curl_multi_exec($mh, $active);
} while ($active && $mrc == CURLM_OK);

curl_multi_remove_handle($mh, $ch1);  // 移除请求 1
curl_multi_remove_handle($mh, $ch2);  // 移除请求 2

curl_multi_close($mh);  // 关闭 multi curl 句柄

2. 数据同步问题的根源

当多个请求同时执行时，通常我们会希望能够在所有请求完成后获取它们的详细信息。curl_getinfo 函数用于获取每个 cURL 请求的执行信息，比如返回的状态码（CURLINFO_HTTP_CODE）和其他元数据。然而，由于多个请求是异步并行进行的，curl_getinfo 需要在适当的时机调用，确保不会在请求还没有完全执行完毕时就获取到数据。

如果你在请求完成之前调用 curl_getinfo，你可能会得到错误的或不完整的数据。因此，合理的同步时机非常重要。

3. 正确的使用顺序和同步策略

3.1 通过 curl_multi_select 来处理并发请求

当你调用 curl_multi_exec 执行多个请求时，PHP 会进入一个循环，直到所有请求都执行完成。在这个过程中，curl_multi_select 也可以帮助我们处理事件的等待，使得我们能够更好地控制何时获取请求的结果。

do {
    // 等待请求完成
    $mrc = curl_multi_exec($mh, $active);

    // 等待直到有数据准备好
    if ($active) {
        curl_multi_select($mh);
    }
} while ($active && $mrc == CURLM_OK);

3.2 确保在移除句柄后再获取数据

一旦所有请求完成并且所有句柄都被移除，才是获取请求信息的合适时机。否则，如果你提前关闭句柄，可能会错过一些请求的结果。

// 获取请求信息
$info1 = curl_getinfo($ch1);
$info2 = curl_getinfo($ch2);

// 输出信息
echo "Request 1 HTTP Code: " . $info1['http_code'] . "\n";
echo "Request 2 HTTP Code: " . $info2['http_code'] . "\n";

3.3 使用 curl_multi_remove_handle 来移除句柄

在获取数据之后，记得将每个句柄从 curl_multi 会话中移除，并在最后关闭它们。这样可以确保不会再尝试获取已经关闭的请求的结果。

curl_multi_remove_handle($mh, $ch1);
curl_multi_remove_handle($mh, $ch2);

4. 代码示例：综合应用

结合前面提到的内容，以下是一个更完整的示例，展示了如何正确地获取每个请求的详细信息，并确保没有数据同步问题：

$mh = curl_multi_init();  // 初始化 multi curl 句柄
$ch1 = curl_init("http://gitbox.net/api/data1");  // 请求 1
$ch2 = curl_init("http://gitbox.net/api/data2");  // 请求 2

curl_multi_add_handle($mh, $ch1);  // 添加请求 1
curl_multi_add_handle($mh, $ch2);  // 添加请求 2

// 执行请求并等待完成
do {
    $mrc = curl_multi_exec($mh, $active);
    if ($active) {
        curl_multi_select($mh);  // 等待数据准备好
    }
} while ($active && $mrc == CURLM_OK);

// 获取请求的执行信息
$info1 = curl_getinfo($ch1);
$info2 = curl_getinfo($ch2);

// 输出请求信息
echo "Request 1 HTTP Code: " . $info1['http_code'] . "\n";
echo "Request 2 HTTP Code: " . $info2['http_code'] . "\n";

// 移除句柄
curl_multi_remove_handle($mh, $ch1);
curl_multi_remove_handle($mh, $ch2);

// 关闭 multi curl 句柄
curl_multi_close($mh);

结论

通过正确使用 curl_multi_exec 和 curl_multi_select，以及确保在请求完成后再通过 curl_getinfo 获取信息，可以有效避免由于异步请求而导致的数据同步问题。对于并发请求的处理，时机的把握至关重要，合理的调用顺序和同步策略能够确保获取到正确的数据。