登录
推荐 文章 Go 技术 课程 下载 专题 AI
首页 >  文章 >  php教程

PHP curl_multi_exec 并发请求怎样正确取完所有响应

来源:17golang原创

时间:2026-09-08 23:25:04 260浏览 收藏

PHP 的 curl_multi_exec 不会自动把所有响应整理成数组。正确做法是:先把多个 easy handle 放入同一个 multi handle,循环推进传输,再用 curl_multi_info_read 逐个取出完成消息,最后通过 curl_multi_getcontent 读取响应体。$stillRunning 只表示整体是否还有传输在进行,不能替代完成消息,也不能单独判断某个请求是否成功。

要点速览
  • curl_multi_exec 的返回值检查的是 multi 栈,单个请求还要看完成消息中的 result
  • 每轮都要把 curl_multi_info_read 读到 false,否则已完成响应可能留在消息队列里。
  • 仍有句柄运行时用 curl_multi_select 等待;结束后移除 easy handle 并关闭 multi handle。

先把并发请求放进同一个 multi handle

PHP curl_multi_exec 中 URL 请求、easy handle、multi handle 和请求标识映射的静态关系图
图1:多个 easy handle 共享同一个 multi handle,旁边的请求标识映射负责把完成结果还给调用方。

每个 URL 都需要自己的 easy handle,但这些句柄可以被加入同一个 multi handle。建议在映射表里保存业务请求名,而不是只依赖句柄数组下标;这样完成顺序和提交顺序不一致时,结果仍能回到正确的请求。

 'https://example.com/profile',
    'orders' => 'https://example.com/orders',
];

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

foreach ($urls as $key => $url) {
    $ch = curl_init($url);
    curl_setopt_array($ch, [
        CURLOPT_RETURNTRANSFER => true, // 把响应体留在句柄中,便于统一读取。
        CURLOPT_TIMEOUT => 10,          // 单个请求设置上限,避免拖住整组请求。
    ]);
    curl_multi_add_handle($multi, $ch); // 把 easy handle 放进并发管理栈。
    $handles[(int) $ch] = ['key' => $key, 'handle' => $ch];
}
?>

CURLOPT_RETURNTRANSFER 很重要:如果没有它,响应可能直接输出,后面就无法稳定地把内容保存到结果数组。句柄本身只负责传输,业务键则由 $handles 保存。

用完成消息取响应,而不是只看 still_running

PHP curl_multi_exec 中整体运行状态、完成消息、响应体和资源清理的静态调用关系图
图2:still_running 只描述整体是否仍在运行,完成消息才提供具体句柄、错误结果和响应体读取入口。

核心循环分成两件事:调用 curl_multi_exec 推进所有句柄,然后反复调用 curl_multi_info_read 消费已经完成的消息。前者返回 CURLM_OK,只说明 multi 栈没有整体错误;某个 URL 的 DNS、连接或 TLS 失败,仍要从消息的 result 判断。

 $meta['key'],
            'curl_code' => $info['result'],
            'http_code' => curl_getinfo($ch, CURLINFO_HTTP_CODE),
            'body' => $info['result'] === CURLE_OK
                ? curl_multi_getcontent($ch) // 只从已完成句柄读取响应体。
                : null,
        ];
        $results[$meta['key']] = $result;

        curl_multi_remove_handle($multi, $ch); // 读完结果后移出 multi 栈。
    }

    if ($stillRunning) {
        $ready = curl_multi_select($multi, 1.0); // 有活动前等待,避免 CPU 空转。
        if ($ready === -1) {
            usleep(1000); // select 失败时做极短退让,再让循环继续推进。
        }
    }
} while ($stillRunning);
?>

这里不能只写成“执行到 $stillRunning 为零,再遍历原句柄数组”。虽然某些场景仍能取到内容,但完成消息会被延迟消费,错误信息也容易丢失。把消息队列在每轮读空,才能及时处理先完成的请求。

正确区分三类结果并收口资源

一组并发请求至少有三层结果:第一层是 multi 栈错误,例如参数或整体调度失败;第二层是 CURLE_*,表示某个传输没有成功;第三层是 HTTP 状态码,网络请求成功并不代表接口业务成功。只有 CURLE_OK 时才把响应体当作正常内容解析,同时仍应检查 HTTP 状态。

所有完成消息都处理完后,再移除剩余句柄并关闭 multi handle。若代码在异常分支直接退出,建议用 try/finally 做统一清理,避免长驻 PHP 进程积累句柄。

排查“响应取不全”时按这张表检查

现象优先检查正确边界
只收到部分响应是否每轮读空 curl_multi_info_read完成消息逐条消费
CPU 持续很高仍运行时是否调用 curl_multi_select等待网络事件而非紧循环
返回 CURLM_OK 但接口失败是否检查 $info['result'] 和 HTTP 状态码栈结果与单请求结果分开
响应体为空是否设置 CURLOPT_RETURNTRANSFER从已完成句柄调用 curl_multi_getcontent

相关问题

curl_multi_select 返回 -1 应该怎么办?

把它当作等待层面的异常信号,做短暂退让后继续推进,或按应用的超时策略终止。不要在 -1 时无休止地立即重试。

为什么不能只用 curl_multi_getcontent 遍历句柄?

这样能拿到部分成功内容,却无法自然地关联完成顺序和单请求错误。先消费完成消息,再按消息里的句柄读取响应,结果更完整。

声明:本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>