PHP异步编程的利器：如何使用GuzzlePromises优雅地处理并发请求，提升应用响应速度

<pre class="brush:php;toolbar:false;"><?php
// 模拟同步API请求函数
function getRecommendations() { sleep(0.3); return '个性化推荐数据'; }
function getPromotions() { sleep(0.2); return '最新促销活动数据'; }
function getHotProducts() { sleep(0.4); return '热门商品列表数据'; }

$startTime = microtime(true);

$recommendations = getRecommendations(); // 等待300ms
$promotions = getPromotions();           // 等待200ms
$hotProducts = getHotProducts();         // 等待400ms

$endTime = microtime(true);
$totalTime = round(($endTime - $startTime) * 1000);

echo "获取到推荐：{$recommendations}\n";
echo "获取到促销：{$promotions}\n";
echo "获取到商品：{$hotProducts}\n";
echo "总耗时：{$totalTime} 毫秒\n";
// 预期总耗时：300 + 200 + 400 = 900ms

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

<pre class="brush:php;toolbar:false;"><?php
require 'vendor/autoload.php';

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于处理Promise集合，如all()

/**
 * 模拟一个异步API请求，返回一个Promise。
 * 在实际应用中，这通常是GuzzleHttp\Client::requestAsync()的返回值。
 * 为了演示，我们手动创建一个Promise，并在其waitFn中模拟耗时操作。
 */
function simulateAsyncApiCall(string $name, int $delayMs): Promise
{
    echo "[$name] 请求已发出，模拟等待 $delayMs ms...\n";

    // 创建一个Promise，并提供一个可选的waitFn。
    // 当这个Promise的wait()方法被调用时，waitFn会被执行。
    // 在真实场景中，Guzzle HTTP客户端的requestAsync方法会返回一个Promise，
    // 并在请求完成后自动resolve/reject，无需我们手动创建和管理waitFn。
    return new Promise(function () use (&$promise, $name, $delayMs) {
        // 模拟网络I/O延迟
        usleep($delayMs * 1000);
        echo "[$name] 请求完成。\n";
        // 通过resolve方法将结果传递给Promise
        // $promise是闭包内部的引用，指向当前正在构建的Promise实例
        $promise->resolve("来自 {$name} 的数据");
    });
}

echo "--- 开始并发请求模拟 ---\n";
$startTime = microtime(true);

// 发起三个并发请求，每个都返回一个Promise
$promiseRecommendations = simulateAsyncApiCall('推荐服务', 300);
$promisePromotions = simulateAsyncApiCall('营销服务', 200);
$promiseHotProducts = simulateAsyncApiCall('商品服务', 400);

echo "所有异步请求已发出，等待结果聚合...\n";

// 使用GuzzleHttp\Promise\Utils::all()等待所有Promise完成
// 它接收一个Promise数组（或关联数组），并返回一个新的Promise。
// 当所有内部Promise都成功时，这个新的Promise才会成功，其结果是一个包含所有内部Promise结果的数组。
$allPromises = Utils::all([
    'recommendations' => $promiseRecommendations,
    'promotions'      => $promisePromotions,
    'products'        => $promiseHotProducts,
]);

try {
    // 调用wait()方法同步等待$allPromises完成。
    // 这会触发所有内部Promise的waitFn执行。
    // 由于这些模拟的“请求”是并发启动的，实际等待时间将接近最慢的那个Promise（400ms），
    // 而不是所有请求耗时之和（900ms）。
    $results = $allPromises->wait();

    $endTime = microtime(true);
    $totalTime = round(($endTime - $startTime) * 1000);

    echo "\n--- 所有数据已成功获取 ---\n";
    echo "获取到推荐：{$results['recommendations']}\n";
    echo "获取到促销：{$results['promotions']}\n";
    echo "获取到商品：{$results['products']}\n";
    echo "总耗时：{$totalTime} 毫秒\n"; // 预期接近400ms

    // 假设这里是组合数据并渲染页面的逻辑
    echo "\n页面渲染完成！总耗时远低于串行执行的900ms，接近最长请求的400ms。\n";

} catch (Exception $e) {
    echo "\n请求失败: " . $e->getMessage() . "\n";
}
echo "--- 模拟结束 ---\n";