如何解决PHP中多外部API调用导致的页面加载缓慢问题，并使用GuzzlePromises优化异步操作

200 + 150 + 300 + 250 = 900ms

curl_multi_exec

curl_multi_exec

guzzlehttp/promises

guzzlehttp/promises

guzzlehttp/promises

fulfilled

rejected

guzzlehttp/promises

<pre class="brush:php;toolbar:false;">composer require guzzlehttp/promises

<pre class="brush:php;toolbar:false;"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils;

// 模拟一个异步操作，例如一个API请求
function simulateApiCall(string $name, int $delayMs): Promise
{
    // 创建一个新的Promise
    $promise = new Promise();

    // 实际项目中，这里会是发起HTTP请求、数据库查询等
    // 为了演示，我们用一个微小的延时来模拟异步操作
    // 注意：PHP本身是同步的，这里的“异步”是逻辑上的，
    // 实际并发需要结合事件循环或多进程/线程，
    // 但Promise提供的是管理异步结果的模式。
    // 在Guzzle HTTP客户端中，它会与底层的异步IO结合。

    echo "[$name] 请求已发起，预计 {$delayMs}ms 后完成...\n";

    // 模拟在未来某个时刻解决Promise
    // 在真实异步环境中，这通常由底层的IO事件驱动
    Utils::queue()->add(function() use ($promise, $name, $delayMs) {
        usleep($delayMs * 1000); // 模拟耗时
        if (rand(0, 9) < 8) { // 80% 成功率
            $promise->resolve("[$name] 数据获取成功！耗时 {$delayMs}ms");
        } else {
            $promise->reject("[$name] 数据获取失败！");
        }
    });

    return $promise;
}

// ------------------- 实际应用 -------------------

echo "开始处理多个API请求...\n";
$startTime = microtime(true);

// 创建多个Promise，代表不同的异步操作
$promise1 = simulateApiCall('商品信息', 300);
$promise2 = simulateApiCall('库存检查', 150);
$promise3 = simulateApiCall('用户评论', 400);

// 使用 GuzzleHttp\Promise\Utils::all() 等待所有Promise完成
// all() 会返回一个新的Promise，当所有输入的Promise都成功时，它才成功
// 任何一个Promise失败，all() 就会立即失败
$allPromises = Utils::all([$promise1, $promise2, $promise3]);

// 使用 wait() 方法同步地等待所有Promise完成并获取结果
// 在一个事件循环环境中，你可能不会直接调用 wait()，而是将结果传递给下一个异步任务
try {
    $results = $allPromises->wait(); // 阻塞直到所有Promise完成

    echo "\n所有请求处理完成！\n";
    foreach ($results as $result) {
        echo "- " . $result . "\n";
    }
} catch (Throwable $e) {
    echo "\n部分请求失败： " . $e->getMessage() . "\n";
}

$endTime = microtime(true);
echo "总耗时: " . round(($endTime - $startTime) * 1000) . "ms\n";

// 如果没有事件循环，需要手动运行任务队列来确保 Promise 得到解决
// 在 Guzzle HTTP 客户端等集成中，这一步通常是自动的
// Utils::queue()->run();
?>

guzzlehttp/promises

guzzlehttp/promises