告别漫长等待：如何使用Composer和GuzzlePromises实现PHP异步请求优化

<code class="bash">composer require guzzlehttp/promises</code>

<code class="php"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于并行处理多个Promise

// 模拟异步API调用
function callApi(string $name, int $delayMs): Promise
{
    return new Promise(function ($resolve, $reject) use ($name, $delayMs) {
        // 在真实场景中，这里会发起一个非阻塞的HTTP请求
        // 例如使用GuzzleHttp\Client的异步方法或ReactPHP等
        echo "[$name] 开始调用，预计延迟 {$delayMs}ms...\n";

        // 模拟异步延迟
        // 注意：在实际的异步环境中，你不会在这里使用sleep()，因为它会阻塞。
        // 这里只是为了演示Promise的机制，在真正的事件循环中，这些操作是非阻塞的。
        \React\EventLoop\Factory::create()->addTimer($delayMs / 1000, function() use ($name, $resolve, $reject) {
            if (rand(0, 9) < 8) { // 80% 成功率
                echo "[$name] 调用成功！\n";
                $resolve("数据来自 {$name}");
            } else {
                echo "[$name] 调用失败！\n";
                $reject(new \Exception("{$name} 服务不可用"));
            }
        });
    });
}

echo "订单处理开始！\n";
$startTime = microtime(true);

// 创建多个Promise，模拟并行调用库存、支付、物流API
$stockPromise = callApi('库存服务', 300);
$paymentPromise = callApi('支付服务', 400);
$shippingPromise = callApi('物流服务', 250);

// 使用 GuzzleHttp\Promise\Utils::all() 等待所有Promise完成
// 这将并行执行这些Promise，而不是顺序执行
$allPromises = Utils::all([
    'stock' => $stockPromise,
    'payment' => $paymentPromise,
    'shipping' => $shippingPromise,
]);

// 注册回调函数，处理所有Promise完成后的结果
$allPromises->then(
    function (array $results) use ($startTime) {
        echo "\n所有API调用成功！\n";
        print_r($results);
        $endTime = microtime(true);
        echo "总耗时: " . round(($endTime - $startTime) * 1000) . "ms\n";
        echo "订单处理完成！\n";
    },
    function (\Throwable $reason) use ($startTime) {
        echo "\n至少一个API调用失败！\n";
        echo "失败原因: " . $reason->getMessage() . "\n";
        $endTime = microtime(true);
        echo "总耗时: " . round(($endTime - $startTime) * 1000) . "ms\n";
        echo "订单处理中断！\n";
    }
);

// !!! 关键步骤：运行事件循环 !!!
// Guzzle Promises本身是基于任务队列的，需要一个事件循环来驱动。
// 在实际项目中，你会集成到ReactPHP、Swoole等异步框架的事件循环中。
// 这里为了演示，我们使用一个简单的ReactPHP事件循环。
$loop = \React\EventLoop\Factory::create();
$loop->addPeriodicTimer(0.001, function () {
    // 每次循环都运行Guzzle Promises的任务队列
    GuzzleHttp\Promise\Utils::queue()->run();
});
$loop->run();

// 如果你只是想简单地同步等待结果（不推荐用于真正的异步场景），可以使用 wait()
// $results = $allPromises->wait();
// echo "所有API调用成功 (同步等待)！\n";
// print_r($results);

?></code>