PHP curl_multi_exec 如何处理多个并发请求

PHP 的 curl_multi_exec() 不是“同时返回多个结果”的函数，它负责反复推进同一个 multi handle 里的网络传输。正确做法是：先为每个 URL 创建 easy handle 并加入 multi handle，再循环调用 curl_multi_exec()，用 $stillRunning 判断是否还有未完成请求，用 curl_multi_info_read() 逐个取完成事件。

多个请求先进入同一个 multi handle

每个 URL 都要有自己的 easy handle；multi handle 只是调度容器。不要在循环里直接调用 curl_exec()，否则请求会重新变成逐个阻塞。下面的例子把 URL 和句柄放进关联数组，后面拿到完成事件时可以准确找回请求。

 'https://api.example.test/profile',
    'orders'  => 'https://api.example.test/orders',
    'quota'   => 'https://api.example.test/quota',
];

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

foreach ($urls as $key => $url) {
    // 返回响应体而不是直接输出，连接和总耗时都设上上限。
    $handle = curl_init($url);
    curl_setopt_array($handle, [
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_CONNECTTIMEOUT => 3,
        CURLOPT_TIMEOUT => 10,
        CURLOPT_HTTPHEADER => ['Accept: application/json'],
    ]);
    curl_multi_add_handle($multi, $handle);
    $handles[(int) $handle] = ['key' => $key, 'url' => $url, 'handle' => $handle];
}
?>

这里的整数键只用于给句柄建立稳定映射，不能把它当成业务请求的顺序。并发完成顺序可能与 $urls 的声明顺序不同，业务代码应使用映射里的 key 或 url 区分结果。

curl_multi_exec 要和 still_running 配合使用

首次调用 curl_multi_exec() 会启动一批传输，后续调用则继续推进状态。它的返回值用于判断 multi 栈是否出错，第二个参数 $stillRunning 用于判断是否仍有活动句柄；两者不是一回事。

 0) {
        // 阻塞到连接可继续推进；返回 -1 时短暂让出 CPU 后重试。
        $ready = curl_multi_select($multi, 1.0);
        if ($ready === -1) {
            usleep(10000); // 10 毫秒只是退避值，生产环境应结合请求量调节。
        }
    }
} while ($stillRunning > 0);
?>

纯粹写成“不断执行直到归零”的紧循环，会在网络没有新事件时持续占用 CPU。curl_multi_select() 的作用是等待读写就绪或超时后再进入下一次推进；它返回 0 不等于请求失败，只表示这次等待期间没有描述符活动。

完成事件里才判断每个请求是否成功

处理完成事件时要看 $info['result']。只有它是 CURLE_OK，才适合读取响应体；之后仍要用 curl_getinfo() 取 HTTP 状态码，因为 HTTP 404 或 500 可能是一次传输成功、业务响应失败。

 'unknown', 'url' => ''];

        if ($info['result'] === CURLE_OK) {
            // 传输层成功不代表 HTTP 业务成功，单独保留状态码。
            $results[$meta['key']] = [
                'ok' => true,
                'status' => curl_getinfo($handle, CURLINFO_HTTP_CODE),
                'body' => curl_multi_getcontent($handle),
                'url' => $meta['url'],
            ];
        } else {
            // 记录单个句柄的错误，不能只看 multi 层的 CURLM_OK。
            $results[$meta['key']] = [
                'ok' => false,
                'error' => curl_error($handle),
                'url' => $meta['url'],
            ];
        }

        // 处理完消息就从 multi 中移除，避免重复消费或遗留活动句柄。
        curl_multi_remove_handle($multi, $handle);
    }

    if ($stillRunning > 0) {
        $ready = curl_multi_select($multi, 1.0);
        if ($ready === -1) {
            usleep(10000); // 没有可监听描述符时，短暂退避再推进。
        }
    }
} while ($stillRunning > 0);

// multi 关闭后，逐个关闭仍由本地变量持有的 easy handle。
curl_multi_close($multi);
foreach ($handles as $meta) {
    curl_close($meta['handle']);
}
?>

几个容易误判的边界

如果请求量很大，建议给业务层增加并发上限、单个请求超时和结果大小限制；curl_multi_exec() 解决的是多个句柄的调度，不会替你完成重试、限流、鉴权刷新或业务状态机。

常见问题

为什么 curl_multi_exec 返回 CURLM_OK 仍有失败请求？

因为它主要报告 multi 栈错误。单个传输要看 curl_multi_info_read() 返回消息中的 result，再读取 curl_error()。

still_running 为 0 后还要读完成消息吗？

要读。它只表示没有活动传输；完成消息队列中的响应体、错误和 HTTP 状态仍需要消费并保存。

curl_multi_select 返回 -1 要不要立刻判错？

不必。它表示底层没有可监听描述符或 select 失败场景，通常应短暂退避后再次调用 curl_multi_exec()，并设置整体超时防止异常循环。