composer在线学习地址：[学习地址](https://pan.quark.cn/s/371f7205c512]
最近在开发一个电商后台服务时，我遇到了一个典型的性能瓶颈。我们的系统需要在一个请求中，同时从用户服务获取用户信息、从商品服务获取商品详情、再从库存服务查询库存量，最终整合数据后返回。起初，我按照最直观的方式，一个接一个地调用这些内部 api。结果可想而知：每个 api 调用都需要几十到上百毫秒，三个服务加起来，一个请求的响应时间轻松突破300毫秒，高峰期甚至更高，用户体验极差。
我尝试过一些简单的优化，比如缓存，但对于实时性要求较高的场景，缓存并不是万能药。真正的痛点在于，这三个 API 调用之间并没有严格的先后依赖关系，它们可以“同时”进行。但在 php 的同步执行模型下，我们却不得不等待一个完成后再开始下一个。这就像去银行办三项业务，明明三个窗口都能办，你却非要在一个窗口排队办完一项再换下一个窗口，效率自然低下。
就在我为如何优化这些“伪并发”操作而苦恼时，我偶然接触到了
guzzlehttp/promises
这个库。虽然它名字里带着
guzzlehttp
，但它其实是一个独立的、通用的 PHP Promise 库，完全符合 Promises/A+ 规范。它为 PHP 带来了处理异步操作的全新思维，让我看到了解决问题的曙光。
guzzlehttp/promises
guzzlehttp/promises
如何破局？
guzzlehttp/promises
的核心思想是“Promise”（承诺）。一个 Promise 代表了一个异步操作的最终结果，这个结果可能成功（fulfilled），也可能失败（rejected），但在 Promise 被创建时，结果是未知的（pending）。通过 Promise，我们可以注册回调函数，当异步操作完成时，这些回调函数会被触发。
首先，通过 Composer 轻松安装这个库：
立即学习“PHP免费学习笔记（深入）”；
<pre class="brush:php;toolbar:false;">composer require guzzlehttp/promises
现在，我们来看看如何用它来解决之前的多服务调用问题。假设我们有三个模拟的异步函数，它们会返回一个 Promise：
<pre class="brush:php;toolbar:false;">use GuzzleHttpPromisePromise; use GuzzleHttpPromiseUtils; function getUserInfoPromise(int $userId): Promise { return new Promise(function () use (&$promise, $userId) { // 模拟网络延迟 sleep(1); $promise->resolve(['id' => $userId, 'name' => '用户' . $userId]); }); } function getProductInfoPromise(int $productId): Promise { return new Promise(function () use (&$promise, $productId) { // 模拟网络延迟 sleep(0.8); $promise->resolve(['id' => $productId, 'title' => '商品' . $productId]); }); } function getStockInfoPromise(int $productId): Promise { return new Promise(function () use (&$promise, $productId) { // 模拟网络延迟 sleep(0.5); $promise->resolve(['productId' => $productId, 'stock' => rand(1, 100)]); }); } // 假设要获取的用户ID和商品ID $userId = 123; $productId = 456; $startTime = microtime(true); // 创建所有 Promise $promises = [ 'user' => getUserInfoPromise($userId), 'product' => getProductInfoPromise($productId), 'stock' => getStockInfoPromise($productId), ]; // 使用 Utils::all() 等待所有 Promise 完成 Utils::all($promises)->then( function (array $results) use ($startTime) { $endTime = microtime(true); echo "所有数据获取完成，耗时：" . round($endTime - $startTime, 2) . "秒n"; echo "用户信息: " . JSon_encode($results['user']) . "n"; echo "商品信息: " . json_encode($results['product']) . "n"; echo "库存信息: " . json_encode($results['stock']) . "n"; }, function (Throwable $reason) use ($startTime) { $endTime = microtime(true); echo "数据获取失败，耗时：" . round($endTime - $startTime, 2) . "秒n"; echo "错误原因: " . $reason->getMessage() . "n"; } )->wait(); // 强制同步等待所有 Promise 解决
运行这段代码，你会发现总耗时不再是三个
sleep
时间的总和（1s + 0.8s + 0.5s = 2.3s），而是最长那个
sleep
的时间（大约 1s）！这就是
guzzlehttp/promises
的魔力所在。
Utils::all()
函数会等待所有 Promise 都成功解决后才触发
then
的第一个回调，或者只要有一个 Promise 失败就触发第二个回调。
guzzlehttp/promises
guzzlehttp/promises
的优势和实际应用效果
- 提升性能和响应速度： 这是最直接的优势。通过并发（或更准确地说是“非阻塞等待”）处理多个独立任务，可以显著减少总的等待时间，从而提高应用的响应速度和吞吐量。
- 代码可读性和可维护性： Promise 模式提供了一种结构化的方式来处理异步流程。通过
then()
方法进行链式调用，代码逻辑清晰，易于理解和维护，避免了传统回调地狱的困扰。
- 强大的错误处理机制： Promise 提供了统一的错误处理机制 (
then(NULL, $onRejected)
或
otherwise()
)，可以集中处理异步操作中可能出现的异常，让错误管理更加健壮。
- 灵活的同步/异步切换： 尽管 Promise 旨在解决异步问题，但它也提供了
wait()
方法，允许你在需要时同步地等待 Promise 的结果。这在某些场景下非常有用，例如当你的主线程确实需要某个异步操作的结果才能继续时。
- 迭代式 Promise 链：
guzzlehttp/promises
的一个技术亮点是其迭代式的 Promise 链处理，即使是“无限”长的 Promise 链也能保持恒定的栈大小，避免了递归深度限制。
在我的电商后台服务中，引入
guzzlehttp/promises
后，多个内部 API 的调用从串行变成了“并行”。现在，一个请求的响应时间从原来的 300+ 毫秒直接降到了 100 毫秒以内，用户体验得到了质的飞跃。开发团队也发现，处理复杂数据聚合逻辑的代码变得更加清晰和易于管理。
总而言之，
guzzlehttp/promises
是 PHP 开发者处理异步操作和提升应用性能的利器。它将复杂的并发逻辑抽象化，让我们可以用更优雅、更高效的方式构建高性能的 PHP 应用。如果你也正面临类似的性能挑战，不妨尝试一下
guzzlehttp/promises
，它或许能为你打开一扇新的大门。
评论（已关闭）
评论已关闭