PHP多线程网络请求高效并发方案

• 初始化一个 curl_multi 句柄（curl_multi_init）
• 为每个URL创建独立的cURL句柄，并设置选项
• 使用 curl_multi_add_handle 将每个句柄加入多请求管理器
• 调用 curl_multi_exec 并配合 curl_multi_select 等待状态变化
• 检查完成的请求，获取结果并清理句柄

$urls = ['http://api.example.com/1', 'http://api.example.com/2', 'http://api.example.com/3'];
$mh = curl_multi_init();
$handles = [];

foreach ($urls as $url) {
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_multi_add_handle($mh, $ch);
    $handles[] = $ch;
}

$running = null;
do {
    curl_multi_exec($mh, $running);
    curl_multi_select($mh);
} while ($running > 0);

$results = [];
foreach ($handles as $ch) {
    $results[] = curl_multi_getcontent($ch);
    curl_multi_remove_handle($mh, $ch);
    curl_close($ch);
}
curl_multi_close($mh);

• 安装Swoole扩展（pecl install swoole）
• 使用 Swoole\Coroutine\Http\Client 发起非阻塞请求
• 通过 go() 函数启动多个协程并发执行

use Swoole\Coroutine as Co;

Co\run(function () {
    $clients = [];
    $urls = ['http://api.example.com/1', 'http://api.example.com/2'];

    foreach ($urls as $url) {
        go(function () use ($url) {
            $client = new Co\Http\Client('api.example.com', 80);
            $client->set(['timeout' => 5]);
            $client->get(parse_url($url)['path']);
            echo "Response from {$url}: " . strlen($client->body) . " bytes\n";
            $client->close();
        });
    }
});

• 安装 react/http-client 或更现代的 react/http
• 创建EventLoop，注册多个异步HTTP请求
• 所有请求并行发送，回调中处理响应

• 控制并发数量，避免系统资源耗尽（如同时发起上千请求可能导致DNS超时或连接池满）
• 设置合理的超时时间，防止某个请求长时间阻塞整体流程
• 错误处理要完善，网络请求可能失败，需捕获异常或检查返回状态
• 生产环境推荐使用Swoole或curl_multi，传统FPM环境下慎用多进程模拟