如何解决PHP应用多API请求慢的问题？GuzzlePromises助你实现异步并行处理

在开发PHP应用时，我们经常会遇到需要调用多个外部API的场景。想象一下，你正在构建一个聚合新闻的仪表盘，需要从A、B、C三个不同的新闻源获取最新头条；或者是一个电商平台的订单处理系统，需要依次调用库存检查、支付网关、物流通知等多个微服务。如果这些请求都是同步执行的，那么你的PHP脚本将不得不等待每一个请求完成才能继续下一个，这就像在高速公路上排队，一个接一个地缓慢前进。当某个外部服务响应缓慢时，整个应用都会被拖慢，用户只能对着加载动画干瞪眼，这无疑是灾难性的用户体验。

我曾经也深陷这样的困境。一个需要聚合多个第三方数据源的报表页面，每次加载都要等待十几秒甚至更久。我尝试过各种优化数据库查询、缓存数据的方法，但瓶颈始终在外部api的同步调用上。代码看起来是这样的：

// 伪代码，模拟同步API调用
$dataFromApiA = callApiA(); // 等待1000ms
$dataFromApiB = callApiB(); // 等待1500ms
$dataFromApiC = callApiC(); // 等待800ms

// 总耗时：1000 + 1500 + 800 = 3300ms

这种模式下，即使某些API请求之间没有依赖关系，它们也必须排队执行。我迫切需要一种方式，能让这些独立的请求“并行”或“非阻塞”地执行，然后在我需要结果的时候再统一处理。

Composer在线学习地址：学习地址

救星登场：

guzzlehttp/promises

在苦苦寻找解决方案的过程中，我发现了

guzzlehttp/promises

通过 Composer 安装它非常简单：

立即学习“PHP免费学习笔记（深入）”；

composer require guzzlehttp/promises

安装完成后，你就可以在项目中使用它了。

什么是 Promise？

简单来说，Promise 代表了一个异步操作的最终结果。这个结果可能在未来某个时间点成功（

fulfilled

rejected

pending

ImgCreator AI

一款AI图像生成工具，适合创建插图、动画和概念设计图像。

下载

guzzlehttp/promises

Promise

1. 注册回调函数 (

   then

   )：当 Promise 完成（成功或失败）时，执行相应的逻辑。
2. 链式调用 (

   then().then()

   )：将多个异步操作串联起来，前一个 Promise 的结果作为后一个的输入。
3. 同步等待 (

   wait

   )：如果你确实需要在某个点阻塞并获取 Promise 的最终结果，可以使用

   wait()

   方法。

如何解决问题：用 Promise 实现“并行”处理

回到我们最初的问题：如何让多个API请求非阻塞地执行？

guzzlehttp/promises

让我们看一个简化版的例子，演示 Promise 的核心用法：

> 发起获取用户 {$userId} 数据的请求...\n";

    // 假设这是后台某个耗时操作，最终会resolve或reject
    // 在真正的异步框架中，这个resolve/reject会被事件循环触发
    // 在本例中，我们会在后面通过一个统一的等待机制来触发它
    // 或者，更直接地，我们可以立即resolve一个值，但那就不“异步”了
    // 这里我们先不直接resolve，而是让它保持pending，等待外部机制来驱动。

    // 更符合实际场景的 Promise 构造方式，包含一个 waitFn
    return new Promise(function () use (&$promise, $userId, $delayMs) {
        // 这是一个“等待函数”，当调用 $promise->wait() 时会被执行
        // 在这里模拟实际的阻塞操作，然后 resolve
        usleep($delayMs * 1000); // 模拟延迟
        echo "  << 完成获取用户 {$userId} 数据。\n";
        $promise->resolve("用户 {$userId} 的数据 (延迟 {$delayMs}ms)");
    });
}

// 同时发起多个“异步”请求
$promise1 = fetchUserData('user_a', 1000); // 模拟1秒延迟
$promise2 = fetchUserData('user_b', 1500); // 模拟1.5秒延迟
$promise3 = fetchUserData('user_c', 800);  // 模拟0.8秒延迟

echo "所有请求已发起，程序继续执行其他逻辑...\n";

// 假设这里有一些不依赖API结果的同步代码
echo "执行一些不相关的同步任务...\n";
usleep(200 * 1000); // 模拟200ms的其他任务

echo "现在需要等待所有API请求的结果...\n";

try {
    // 使用 Utils::all() 等待所有 Promise 完成
    // 这会阻塞当前进程，直到所有 Promise 都被解决或拒绝
    $results = Utils::all([$promise1, $promise2, $promise3])->wait();

    echo "\n所有API请求结果已获取：\n";
    foreach ($results as $index => $result) {
        echo "  结果 " . ($index + 1) . ": " . $result . "\n";
    }

} catch (Exception $e) {
    echo "发生错误：" . $e->getMessage() . "\n";
}

echo "所有操作完成。\n";

?>

运行上述代码，你会发现：

1. “发起获取用户数据”的日志会几乎同时出现，因为

   fetchUserData

   函数立即返回了 Promise，而没有等待实际的延迟。
2. “程序继续执行其他逻辑”会紧接着出现，说明在等待API结果的同时，PHP程序可以处理其他任务。
3. 只有当调用

   Utils::all(...)->wait()

   时，程序才会阻塞，等待所有 Promise 的最终结果。
4. 总的执行时间会接近最长那个 Promise 的延迟时间（约1500ms），而不是所有延迟时间之和（3300ms）。这正是我们想要的“并行”效果！

then()

和链式调用

guzzlehttp/promises

then(function ($value) {
        echo "第一步成功：接收到 '{$value}'\n";
        return "处理后的 " . $value; // 返回一个新值，传递给下一个 then
    })
    ->then(function ($value) {
        echo "第二步成功：接收到 '{$value}'\n";
        // 也可以返回一个新的 Promise，实现更复杂的异步链
        $nextPromise = new Promise();
        $nextPromise->resolve("最终结果: " . $value);
        return $nextPromise;
    })
    ->then(function ($value) {
        echo "第三步成功：接收到 '{$value}'\n";
    }, function ($reason) {
        echo "第三步失败：原因 '{$reason}'\n";
    });

// 解决原始 Promise，触发链式调用
$promise->resolve('原始数据');

// 同步等待最终结果（如果需要）
$promise->wait(); // 确保所有链式操作完成
?>

优势与实际应用效果

1. 显著提升性能：通过非阻塞地发起多个耗时操作，将总等待时间从“所有耗时之和”优化为“最长耗时”，大大缩短了响应时间。
2. 改善用户体验：快速响应意味着用户无需长时间等待，提升了应用的流畅度和满意度。
3. 代码结构更清晰：Promise 模式让异步逻辑的编写更加直观和易于维护，避免了回调地狱（Callback Hell）。
4. 优雅的错误处理：通过

   then()

   的第二个参数或

   otherwise()

   方法，可以集中处理异步操作中可能出现的错误。
5. 与Guzzle HTTP客户端无缝集成：Guzzle HTTP客户端本身就支持返回 Promise 对象进行异步请求，

   guzzlehttp/promises

   正是其背后的核心。

在我的报表页面项目中，引入

guzzlehttp/promises

总结

guzzlehttp/promises