告别PHP同步阻塞：如何用Composer和GuzzlePromise实现高效异步API调用

curl_multi

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

then()

sleep()

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

require 'vendor/autoload.php'; // 引入Composer的自动加载

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于同时等待多个Promise

/**
 * 模拟一个耗时操作，例如API请求
 * 实际项目中这里会是 GuzzleHttp\Client->getAsync() 等
 *
 * @param string $name 操作名称
 * @param int $delay 模拟延迟时间（秒）
 * @return Promise
 */
function simulateApiCall(string $name, int $delay): Promise
{
    return new Promise(function ($resolve, $reject) use ($name, $delay) {
        echo "【" . date('H:i:s') . "】开始调用 {$name} API... (预计等待 {$delay} 秒)\n";

        // 模拟网络延迟或耗时计算
        sleep($delay); 

        // 模拟成功或失败
        if (rand(0, 10) > 1) { // 90% 的几率成功
            $resolve("【" . date('H:i:s') . "】{$name} API 数据已获取！");
        } else {
            $reject(new Exception("【" . date('H:i:s') . "】{$name} API 调用失败！"));
        }
    });
}

// --- 同步阻塞的例子 (对比) ---
echo "--- 同步阻塞开始 ---\n";
// simulateApiCall('订单基本信息', 2)->wait();
// simulateApiCall('商品详细信息', 1)->wait();
// simulateApiCall('用户详细资料', 3)->wait();
// simulateApiCall('物流状态', 2)->wait();
// echo "--- 同步阻塞结束 ---\n\n";
// (如果执行上面注释的代码，总耗时将是 2+1+3+2 = 8秒)


// --- 使用 GuzzleHttp/Promise 实现异步并行 ---
echo "--- 异步并行开始 ---\n";

// 同时发起多个异步请求
$promiseOrder = simulateApiCall('订单基本信息', 2);
$promiseProducts = simulateApiCall('商品详细信息', 1);
$promiseUser = simulateApiCall('用户详细资料', 3);
$promiseLogistics = simulateApiCall('物流状态', 2);

// 使用 GuzzleHttp\Promise\Utils::all() 等待所有Promise完成
// all() 会返回一个新的Promise，当所有输入的Promise都成功时，它才成功
// 如果其中任何一个Promise失败，all() 返回的Promise就会失败
try {
    $results = Utils::all([
        'order' => $promiseOrder,
        'products' => $promiseProducts,
        'user' => $promiseUser,
        'logistics' => $promiseLogistics,
    ])->wait(); // wait() 会阻塞当前执行，直到所有Promise完成

    echo "\n--- 所有API调用成功完成，总耗时远小于同步执行！---\n";
    foreach ($results as $key => $value) {
        echo "{$key}: {$value}\n";
    }

} catch (Exception $e) {
    echo "\n--- 异步API调用中发生错误！---\n";
    echo "错误信息: " . $e->getMessage() . "\n";
}

echo "--- 异步并行结束 ---\n";

// 预期输出：所有API会在几乎同时开始，并在最长的那个（3秒）完成后得到所有结果。
// 总耗时大约是 3 秒，而不是 2+1+3+2 = 8 秒。

wait()

用户详细资料