PHP curl_multi 批量请求怎么判断单个句柄完成
来源:17golang原创
时间:2026-09-10 03:26:26 223浏览 收藏
用 PHP 的 curl_multi_* 同时发起多个请求时,判断某个请求是否完成,关键不是看数组下标,也不是只看 $stillRunning。正确入口是反复调用 curl_multi_info_read():它返回的 handle 就是已经结束的那个 CurlHandle,result 则告诉你传输层是否成功。
curl_multi_exec()推进状态,curl_multi_info_read()消费完成消息。- 用
CURLOPT_PRIVATE给句柄绑定业务键,完成顺序变化也不会认错请求。 result === CURLE_OK只代表 cURL 传输成功,还要单独检查 HTTP 状态和响应内容。
curl_multi_info_read 返回的 handle 才是完成的单个请求
curl_multi_exec() 的 $stillRunning 是整个 multi 栈是否还有活动请求的标记,并不指向某个句柄。某个请求完成后,完成消息会进入队列;必须把 curl_multi_info_read() 读到 false,才能确认这一轮消息已经取完。
返回数组中的 msg 通常是 CURLMSG_DONE,handle 是对应的句柄,result 是 CURLE_* 结果码。先用完成消息定位请求,再调用 curl_multi_getcontent() 读取响应。

把 handle 与业务键一起保存
并发请求的完成顺序通常不等于加入顺序,因此建议在创建句柄时设置 CURLOPT_PRIVATE。之后用 curl_getinfo($handle, CURLINFO_PRIVATE) 取回订单号、接口名或任务键,不需要依赖对象比较或手工维护脆弱的数组位置。
'https://api.example.com/profile',
'quota' => 'https://api.example.com/quota',
] as $key => $url) {
$ch = curl_init($url);
curl_setopt_array($ch, [
CURLOPT_RETURNTRANSFER => true,
CURLOPT_TIMEOUT => 10,
CURLOPT_PRIVATE => $key, // 将业务键写入当前句柄的私有信息
]);
curl_multi_add_handle($mh, $ch);
$handles[$key] = $ch; // 保留引用,便于完成后取内容并清理
}
$active = null;
do {
// 推进所有连接;返回码描述的是 multi 栈,不是单个请求。
$multiCode = curl_multi_exec($mh, $active);
if ($multiCode !== CURLM_OK) {
throw new RuntimeException(curl_multi_strerror($multiCode));
}
// 一轮可能完成多个请求,必须读到 false 才算消息队列暂时为空。
while ($info = curl_multi_info_read($mh)) {
if ($info['msg'] !== CURLMSG_DONE) {
continue;
}
$ch = $info['handle'];
$key = curl_getinfo($ch, CURLINFO_PRIVATE);
$body = curl_multi_getcontent($ch);
$httpCode = (int) curl_getinfo($ch, CURLINFO_HTTP_CODE);
if ($info['result'] !== CURLE_OK) {
// 这是 DNS、超时等传输失败,不能当成 HTTP 错误处理。
$results[$key] = ['ok' => false, 'error' => curl_error($ch)];
} elseif ($httpCode = 300) {
// cURL 成功不等于业务接口返回了成功状态。
$results[$key] = ['ok' => false, 'http_code' => $httpCode, 'body' => $body];
} else {
$results[$key] = ['ok' => true, 'http_code' => $httpCode, 'body' => $body];
}
curl_multi_remove_handle($mh, $ch); // 先从 multi 栈移除已完成句柄
curl_close($ch); // 再释放句柄资源
}
if ($active) {
// select 返回 -1 时短暂让出 CPU,避免无活动描述符时忙等。
$selected = curl_multi_select($mh, 1.0);
if ($selected === -1) {
usleep(10000);
}
}
} while ($active);
curl_multi_close($mh); // 所有句柄处理完后关闭 multi 句柄
?>
这里的 CURLOPT_PRIVATE 只保存关联信息,cURL 不会替你解释它。业务键仍应保持唯一,并在完成分支中立刻读取;调用 curl_multi_remove_handle() 后,不要再依赖完成消息里的句柄数据。
循环读取消息并处理失败分支
每次推进 multi 栈后,可能同时有多个句柄完成,所以要用 while 消费消息,而不是只调用一次。result 判断传输层,CURLINFO_HTTP_CODE 判断 HTTP 层,响应体再交给 JSON 或业务协议解析。三层分开,日志才知道问题到底发生在哪里。

为什么 still_running 不能代替完成判断
$active 只适合控制“整个集合是否还在工作”。它可能仍为真,表示还有其他请求未完成;也可能变为假,但上一轮消息队列仍需要被消费。因此完整逻辑是:先执行 curl_multi_exec(),再循环读取 curl_multi_info_read(),最后用 $active 决定是否等待下一次活动。
curl_multi_select() 返回 0 代表超时或没有可观察活动,不代表请求失败;返回 -1 才是 select 层异常信号。此时短暂休眠后继续执行,避免在没有文件描述符时占满 CPU。
常见问题
curl_multi_info_read() 返回 false 是失败吗?
不一定。它也表示当前没有更多完成消息;应结合 $active 判断是否还要等待,而不是直接当成请求失败。
curl_multi_exec() 返回 CURLM_OK 就是所有接口成功吗?
不是。它只说明 multi 栈本身没有报告错误,单个传输仍要检查 $info['result'],HTTP 层还要检查状态码。
什么时候可以 remove_handle?
收到对应的完成消息、读取完需要的内容和信息后再移除;移除后不要继续使用该完成消息指向的数据。
-
501 收藏
-
501 收藏
-
501 收藏
-
501 收藏
-
501 收藏
-
文章 · php教程 | 8小时前 | 网络编程 · 故障排查 · php教程 · 流处理 · eof PHP stream_set_timeout stream_get_meta_data timed_out199 收藏
-
467 收藏
-
100 收藏
-
488 收藏
-
232 收藏
-
298 收藏
-
501 收藏
-
194 收藏
-
380 收藏
-
468 收藏
-
260 收藏
-
277 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 485次学习