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

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_DONEhandle 是对应的句柄,resultCURLE_* 结果码。先用完成消息定位请求,再调用 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删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>