当前位置:首页 > 文章列表 > 文章 > php教程 > PHP curl_multi 批量请求怎么判断单个句柄完成

PHP curl_multi 批量请求怎么判断单个句柄完成

来源:17golang原创 2026-09-10 03:26:26 0浏览 收藏

用 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() 读取响应。

PHP curl_multi 完成消息、CurlHandle、业务键和响应结果的静态关系框图
图1:完成消息中的 handle 连接具体 CurlHandle,再由业务键找到对应结果;still_running 只描述整个请求集合。

把 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 或业务协议解析。三层分开,日志才知道问题到底发生在哪里。

PHP curl_multi 传输结果、HTTP 状态、响应体和业务结果的静态边界关系图
图2:把 cURL 传输结果、HTTP 状态、响应体和业务结果分成不同判断边界,避免把 CURLM_OK 当成接口成功。

为什么 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?

收到对应的完成消息、读取完需要的内容和信息后再移除;移除后不要继续使用该完成消息指向的数据。

版本声明
本文转载于:17golang原创 如有侵犯,请联系study_golang@163.com删除
Go utf8.DecodeRuneInString 遇到非法字节时会返回什么Go utf8.DecodeRuneInString 遇到非法字节时会返回什么
上一篇
Go utf8.DecodeRuneInString 遇到非法字节时会返回什么
MySQL 时区转换后日期跨天怎么正确统计
下一篇
MySQL 时区转换后日期跨天怎么正确统计
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之JavaScript设计模式
    前端进阶之JavaScript设计模式
    设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
    543次学习
  • GO语言核心编程课程
    GO语言核心编程课程
    本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
    516次学习
  • 简单聊聊mysql8与网络通信
    简单聊聊mysql8与网络通信
    如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
    500次学习
  • JavaScript正则表达式基础与实战
    JavaScript正则表达式基础与实战
    在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
    487次学习
  • 从零制作响应式网站—Grid布局
    从零制作响应式网站—Grid布局
    本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
    485次学习
查看更多
AI推荐
  • PubMedQA数据集详解:生物医学问答基准、功能与应用指南
    PubMedQA
    深入了解PubMedQA生物医学问答数据集,涵盖其核心功能、使用方法及在临床决策、药物研发等场景的应用,助力提升NLP模型性能。
    686次使用
  • H2O EvalGPT:开源LLM大模型评估与排行榜工具
    H2O EvalGPT
    H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
    702次使用
  • LMArena是什么?伯克利AI模型评估平台使用指南与功能解析
    LMArena
    LMArena是加州大学伯克利分校推出的AI模型匿名评测平台。通过盲测投票机制,用户可对比不同大模型回答并生成实时排行榜,助力开发者优化模型及用户选择最佳AI工具。
    759次使用
  • 斯坦福HELM:大语言模型Holistic Evaluation整体评估框架详解
    HELM
    深入了解斯坦福推出的HELM(Holistic Evaluation of Language Models)大模型评测体系。本文解析其核心功能、安装配置步骤及应用场景,涵盖准确性、公平性、鲁棒性等多维度指标,助力开发者全面优化语言模型性能。
    723次使用
  • MMBench详解:多模态大模型基准测试、功能特点与使用指南
    MMBench
    MMBench是由上海人工智能实验室等机构联合推出的多模态基准测试平台,提供细粒度能力评估、大规模数据集及VLMEvalKit工具。本文详细介绍其核心功能、安装使用方法及应用场景,助力开发者全面评估多模态模型性能。
    561次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议 和 隐私政策
返回登录
  • 重置密码