如何確保curl_multi_close 不會干擾請求的中間過程

gitbox 2025-05-29

在 PHP 中使用 cURL 扩展时，curl_multi_* 函数通常用于处理多个并发请求。这些函数能够显著提高程序的性能，尤其是在同时发送多个 HTTP 请求时。然而，在使用 curl_multi_close 函数时，某些开发者可能会遇到请求处理中产生干扰的问题，导致请求没有正确完成或返回错误。

本文将探讨如何避免在请求处理中产生干扰，并分享一些实际的代码示例和解决方案。

1. curl_multi_* 函数概述

PHP 提供了 curl_multi_* 函数来执行多个并发的 cURL 请求。其主要函数有：

curl_multi_init()：初始化一个 cURL 多重句柄。
curl_multi_add_handle()：将多个 cURL 句柄添加到一个多重句柄中。
curl_multi_exec()：执行所有的 cURL 请求。
curl_multi_getcontent()：获取一个 cURL 请求的内容。
curl_multi_remove_handle()：从多重句柄中移除某个 cURL 句柄。
curl_multi_close()：关闭所有 cURL 句柄并释放资源。

示例代码

<?php

$multiHandle = curl_multi_init();

$urls = [
    'https://gitbox.net/api/endpoint1',
    'https://gitbox.net/api/endpoint2',
    'https://gitbox.net/api/endpoint3'
];

$handles = [];

// 初始化多個請求句柄
foreach ($urls as $url) {
    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_multi_add_handle($multiHandle, $ch);
    $handles[] = $ch;
}

// 執行請求
$running = null;
do {
    curl_multi_exec($multiHandle, $running);
} while ($running);

// 獲取響應數據
foreach ($handles as $ch) {
    $response = curl_multi_getcontent($ch);
    echo $response . "\n";
    curl_multi_remove_handle($multiHandle, $ch);
}

// 關閉句柄
curl_multi_close($multiHandle);

?>

2. curl_multi_close 的问题

尽管 curl_multi_close 函数是一个很方便的清理函数，但有时它在请求处理的最后阶段可能会产生干扰，尤其是在请求没有完成时就调用 curl_multi_close。这种干扰可能导致一些请求未能正确完成，或者获取到的响应不完整。

常见的干扰原因

并发请求的完成时间不一致：由于不同请求的响应时间不同，可能在调用 curl_multi_close 时，某些请求还没有完成，导致请求提前关闭。
资源释放问题：在某些情况下，资源未完全释放就调用 curl_multi_close，可能会影响其他的请求或导致连接断开。

3. 如何避免干扰？

为了避免 curl_multi_close 函数在请求处理中产生干扰，可以采取以下策略：

3.1 确保所有请求完成

确保在调用 curl_multi_close 之前，所有请求都已完成。可以通过检查 curl_multi_exec 返回的 running 状态来确认请求是否都已完成。只有当所有请求都处理完毕时，才应该调用 curl_multi_close。

改进后的代码示例：

<?php

$multiHandle = curl_multi_init();

$urls = [
    'https://gitbox.net/api/endpoint1',
    'https://gitbox.net/api/endpoint2',
    'https://gitbox.net/api/endpoint3'
];

$handles = [];

// 初始化多個請求句柄
foreach ($urls as $url) {
    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_multi_add_handle($multiHandle, $ch);
    $handles[] = $ch;
}

// 執行請求
$running = null;
do {
    $mrc = curl_multi_exec($multiHandle, $running);
    if ($mrc > 0) {
        echo "CURL exec error: " . curl_multi_strerror($mrc);
    }
} while ($running);

// 獲取響應數據
foreach ($handles as $ch) {
    $response = curl_multi_getcontent($ch);
    echo $response . "\n";
    curl_multi_remove_handle($multiHandle, $ch);
}

// 關閉句柄
curl_multi_close($multiHandle);

?>

3.2 使用 curl_multi_select 改进性能

在某些情况下，可以通过 curl_multi_select() 来优化请求处理的性能。它可以在等待 cURL 请求完成时阻塞进程，而不是不断地轮询 curl_multi_exec，这样可以减少 CPU 使用率，并确保请求处理顺畅。

代码示例：

<?php

$multiHandle = curl_multi_init();

$urls = [
    'https://gitbox.net/api/endpoint1',
    'https://gitbox.net/api/endpoint2',
    'https://gitbox.net/api/endpoint3'
];

$handles = [];

// 初始化多個請求句柄
foreach ($urls as $url) {
    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_multi_add_handle($multiHandle, $ch);
    $handles[] = $ch;
}

// 執行請求并使用 curl_multi_select 提高性能
$running = null;
do {
    $mrc = curl_multi_exec($multiHandle, $running);
    if ($mrc > 0) {
        echo "CURL exec error: " . curl_multi_strerror($mrc);
    }
    curl_multi_select($multiHandle);
} while ($running);

// 獲取響應數據
foreach ($handles as $ch) {
    $response = curl_multi_getcontent($ch);
    echo $response . "\n";
    curl_multi_remove_handle($multiHandle, $ch);
}

// 關閉句柄
curl_multi_close($multiHandle);

?>

4. 总结

避免 curl_multi_close 函数在请求处理中产生干扰，主要需要确保所有的请求都已经完成且响应已正确返回。可以通过监控请求的执行状态，使用 curl_multi_select 优化性能，并确保在请求完成后再调用 curl_multi_close 来避免可能的干扰。

通过这些方法，可以有效提高 PHP 中并发请求的稳定性和性能，确保请求处理过程顺畅，不会受到不必要的干扰。