PHP异步编程痛点如何解决？GuzzlePromises助你构建高性能应用！

在 PHP 后端开发中，我们经常会遇到这样的场景：需要调用多个外部 API，或者执行一些耗时的数据处理任务。传统的做法是按顺序一个接一个地执行这些操作。比如，你需要先调用 A 服务获取数据，等待其响应后，再用 A 的数据去调用 B 服务，最后处理 B 的结果。这个过程是完全同步的，意味着在 A 服务响应之前，你的 PHP 脚本会一直“卡”在那里等待，什么也做不了。如果 A 服务响应慢，或者需要调用的服务数量很多，整个请求的响应时间就会变得非常长，用户只能眼睁睁地看着页面转圈圈，最终可能因为超时而放弃。

这种“串行”执行的模式，不仅浪费了宝贵的服务器资源（因为 cpu 在等待 i/o），也严重影响了用户体验。我们渴望一种机制，能让 php 脚本在等待一个耗时操作完成的同时，去处理其他任务，或者同时发起多个独立的耗时操作，待它们全部完成后再统一处理结果。这正是异步编程的魅力所在，而

guzzlehttp/promises

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

引入救星：Guzzle Promises

guzzlehttp/promises

安装 Guzzle Promises

首先，使用 Composer 轻而易举地将

guzzlehttp/promises

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

composer require guzzlehttp/promises

Promise 的基本用法

让我们看一个简单的例子，模拟一个耗时操作：

Magician

Figma插件，AI生成图标、图片和UX文案

下载

then(
    // 成功回调：当 Promise 被“解决”（fulfilled）时执行
    function ($value) {
        echo "操作成功，得到结果: " . $value . "\n";
    },
    // 失败回调：当 Promise 被“拒绝”（rejected）时执行
    function ($reason) {
        echo "操作失败，原因: " . $reason . "\n";
    }
);

echo "我先去干点别的事...\n";

// 模拟异步操作完成，并“解决”Promise
// 这将在某个未来的时间点发生，例如在一个异步请求的回调中
$promise->resolve('这是异步操作的结果！');

// 模拟异步操作失败，并“拒绝”Promise
// $promise->reject('出错了，无法完成操作！');

echo "异步操作的结果已经处理了，继续。\n";

运行上述代码，你会发现输出顺序是：

我先去干点别的事...
操作成功，得到结果: 这是异步操作的结果！
异步操作的结果已经处理了，继续。

这正是异步的魅力！

echo "我先去干点别的事..."

告别“回调地狱”：Promise 链式调用

guzzlehttp/promises

then

add(function () use ($promise) {
        sleep(2); // 模拟耗时
        $promise->resolve(123); // 假设用户ID是123
    });
    return $promise;
}

// 模拟第二个异步操作：根据用户ID获取用户详情
function fetchUserDetailsAsync(int $userId): Promise
{
    $promise = new Promise();
    echo "正在获取用户 {$userId} 的详情...\n";
    \GuzzleHttp\Promise\Utils::queue()->add(function () use ($promise, $userId) {
        sleep(1); // 模拟耗时
        if ($userId === 123) {
            $promise->resolve(['name' => '张三', 'email' => 'zhangsan@example.com']);
        } else {
            $promise->reject('用户不存在');
        }
    });
    return $promise;
}

// 链式调用：先获取用户ID，再获取用户详情
fetchUserIdAsync()
    ->then(function ($userId) {
        echo "成功获取用户ID: {$userId}\n";
        return fetchUserDetailsAsync($userId); // 返回一个新的 Promise，继续链式调用
    })
    ->then(function ($userDetails) {
        echo "成功获取用户详情: " . json_encode($userDetails, JSON_UNESCAPED_UNICODE) . "\n";
    })
    ->otherwise(function ($reason) { // 统一处理链中任何环节的错误
        echo "操作链中出现错误: " . $reason . "\n";
    });

echo "主程序继续执行，不等待异步操作...\n";

// 在 PHP 中，如果你的应用没有事件循环，你需要手动运行 Promise 队列来确保回调被触发
// GuzzleHttp\Promise\Utils::queue() 是全局任务队列，在实际应用中通常与事件循环集成
\GuzzleHttp\Promise\Utils::queue()->run();

echo "所有异步操作（如果已完成）都已处理完毕。\n";

通过链式调用，代码逻辑变得异常清晰：先做什么，然后做什么，最后怎么处理。任何一步出错，都会直接跳到

otherwise

then

更多实用功能

• 同步等待 (

  wait

  ): 尽管我们提倡异步，但在某些情况下，你可能需要强制等待 Promise 完成并获取其结果。

  $promise->wait()

  方法可以做到这一点。如果 Promise 被拒绝，它会抛出异常。

  $promise = new Promise(function () use (&$promise) {
      $promise->resolve('foo');
  });
  echo $promise->wait(); // 输出 "foo"

• 取消 (

  cancel

  ): 如果一个异步操作不再需要，你可以尝试取消它（如果 Promise 内部支持）。

  $promise = new Promise(
      function () use (&$promise) { /* ... */ },
      function () {
          // 可以在这里执行取消操作，例如关闭连接
          echo "Promise 已被取消！\n";
      }
  );
  $promise->cancel();

• Promise 互操作性:

  guzzlehttp/promises

  能够与任何实现了

  then

  方法的对象（即符合 Promises/A+ 规范的其他 Promise 库）进行互操作，这意味着你可以轻松地将它与其他异步库结合使用。
• 迭代式解析: Guzzle Promises 的一个重要实现细节是，它通过迭代而非递归的方式处理 Promise 的解析和链式调用，这使得它能够支持“无限”的 Promise 链，同时保持固定的栈大小，避免了栈溢出问题，提升了性能和稳定性。

总结与实际应用效果

guzzlehttp/promises

1. 提升性能和并发能力: 应用程序不再需要等待每个耗时操作完成，可以同时发起多个请求，大大缩短了总响应时间，提升了吞吐量。
2. 改善用户体验: 对于 Web 应用而言，更快的响应意味着更好的用户体验，减少了用户的等待时间。
3. 代码更清晰、可维护: 通过链式调用和统一的错误处理机制，代码逻辑更加扁平化，摆脱了“回调地狱”的困扰。
4. 应对复杂业务逻辑: 对于需要协调多个异步任务才能完成的复杂业务流程，Promise 模式提供了一种优雅的解决方案。
5. 模块化和可测试性: 异步操作被封装在 Promise 中，使得每个环节都更加独立，易于测试和重用。

在实际项目中，

guzzlehttp/promises

拥抱

guzzlehttp/promises