PHP实现异步请求的四种方法

$urls = [
    'http://example.com/api/endpoint1',
    'http://example.com/api/endpoint2',
    // ...更多URLs
];
 
$multiHandle = curl_multi_init();
 
foreach ($urls as $url) {
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
    curl_multi_add_handle($multiHandle, $ch);
}
 
$running = null;
do {
    usleep(10000); // 可选：防止CPU全速运行
    curl_multi_exec($multiHandle, $running);
} while ($running > 0);
 
foreach ($urls as $url) {
    $ch = curl_multi_getcontent($ch);
    // 处理结果
    curl_multi_remove_handle($multiHandle, $ch);
}
 
curl_multi_close($multiHandle);

<?php
require 'vendor/autoload.php';
$promise = new \React\Promise\Promise(function ($resolve, $reject) {
    // 创建 cURL 操作
    $ch = curl_init();
    // 设置请求选项...
    curl_setopt($ch, CURLOPT_URL, 'http://example.com');
    // 创建一个新的 React 异步客户端
    $client = new \React\Curl\Adapter\Curl();
    // 使用 React 异步库发起请求
    $response = $client->enqueue($ch);
    // 当请求完成后，调用 resolve 或 reject 函数
    $response->then(
        function ($result) use ($resolve) { $resolve(json_decode($result)); },
        function ($error) use ($reject) { $reject($error); }
    );
});
// 同时，主线程继续执行其他任务
$promise->wait(); // 当 cURL 完成后，此处阻塞
?>

$client = new \GuzzleHttp\Client();
$promises = [
    'api1' => $client->getAsync('http://example.com/api1'),
    'api2' => $client->getAsync('http://example.com/api2'),
];
$results = \GuzzleHttp\Promise\Utils::settle($promises)->wait();
$response1 = $results['api1']['value']->getBody()->getContents();
$response2 = $results['api2']['value']->getBody()->getContents();
// 处理响应数据
// …

$cli1 = new Swoole\Coroutine\Http\Client('example.com', 80);
$cli1->set(['timeout' => 10]);
$cli1->get('/api1');
$cli2 = new Swoole\Coroutine\Http\Client('example.com', 80);
$cli2->set(['timeout' => 10]);
$cli2->get('/api2');
Swoole\Event::wait();
$response1 = $cli1->body;
$response2 = $cli2->body;
// 处理响应数据
// …