当前位置:首页 > 文章列表 > 文章 > php教程 > PHP curl_multi_exec 并发请求怎样正确取完所有响应

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

来源:17golang原创 2026-09-08 23:25:04 0浏览 收藏

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删除
Go encoding/hex 怎么把固定宽度字节转成可比较字符串Go encoding/hex 怎么把固定宽度字节转成可比较字符串
上一篇
Go encoding/hex 怎么把固定宽度字节转成可比较字符串
Go rows.Close 调用后 Err 还能不能发现驱动错误
下一篇
Go rows.Close 调用后 Err 还能不能发现驱动错误
查看更多
最新文章
查看更多
课程推荐
  • 前端进阶之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推荐
  • H2O EvalGPT:开源LLM大模型评估与排行榜工具
    H2O EvalGPT
    H2O EvalGPT是H2O.ai推出的开源LLM评估平台,提供详细的大模型性能排行榜、行业特定基准测试及A/B测试功能,助您快速选择最适合项目的高性能大语言模型。
    31次使用
  • SuperCLUE中文大模型评测基准:功能、能力维度与应用指南
    SuperCLUE
    SuperCLUE是权威的中文大语言模型综合评测基准,涵盖语言理解、知识应用、AI Agent智能体及安全性等12项核心能力。通过多轮对话与客观测试,定期发布榜单与技术报告,为模型研发、优化及行业选型提供科学依据。
    187次使用
  • C-Eval中文评测基准:大语言模型多学科能力评估指南
    C-Eval
    深入了解C-Eval中文评估套件,涵盖52个学科与4级难度。本文详解其功能特点、Zero-shot/Few-shot使用方法及代码示例,助您全面评测LLM中文理解与泛化能力。
    122次使用
  • AI Prompt Library:免费AI提示词库,助力ChatGPT高效创作与营销
    AI Prompt Library
    探索AI Prompt Library免费资源库,涵盖营销、写作及多场景AI提示词。兼容ChatGPT、Claude等工具,一键复制优化输出,提升工作效率。
    46次使用
  • Generrated:DALL·E 2/3 AI绘画提示词灵感库与图像对比平台
    Generrated
    Generrated汇集9300+张DALL·E生成图像及对应提示词,支持查看完整图集、对比DALL·E 2与3版本差异,是AI绘图新手学习Prompt设计与获取创作灵感的实用工具。
    31次使用
微信登录更方便
  • 密码登录
  • 注册账号
登录即同意 用户协议隐私政策
返回登录
  • 重置密码