如何在PHP中优雅处理异步操作？GuzzlePromises助你告别回调地狱！

可以通过一下地址学习composer：学习地址

在日常的 php 开发中，我们经常会遇到这样的场景：需要从多个外部服务获取数据，或者执行一系列相互依赖但又耗时的操作。比如，你正在开发一个聚合新闻的平台，需要同时从 cnn、bbc 和 reuters 的 api 获取最新头条，然后将它们合并展示给用户。

我遇到的困境：传统 PHP 异步处理的痛点

最初，我可能会选择最直接的办法：顺序调用这些 API。

<pre class="brush:php;toolbar:false;">$cnnData = fetchFromCnnApi(); // 等待 CNN 响应
$bbcData = fetchFromBbcApi(); // 等待 BBC 响应
$reutersData = fetchFromReutersApi(); // 等待 Reuters 响应

// 合并并处理数据

这种方式的问题显而易见：如果每个 API 调用都需要 500 毫秒，那么用户至少要等待 1.5 秒才能看到结果。这在追求极致用户体验的今天，是完全不可接受的。

为了提升性能，我尝试过一些“土法炼钢”的并行方案，例如使用

curl_multi_exec

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

Guzzle Promises：PHP 异步编程的救星

就在我为如何优雅地管理这些异步任务而苦恼时，我发现了

guzzlehttp/promises

guzzlehttp/promises

Composer 安装与核心概念

使用 Composer 安装

guzzlehttp/promises

SpeakingPass-打造你的专属雅思口语语料

使用chatGPT帮你快速备考雅思口语，提升分数

25

查看详情

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

Promise 的核心思想是：一个 Promise 对象代表了一个异步操作的最终结果。这个结果可能在未来某个时间点成功（

fulfilled

rejected

then()

如何使用 Guzzle Promises 解决问题

1. 结构化异步流程，告别回调地狱：

   guzzlehttp/promises

   登录后复制
   允许你以链式调用的方式组织异步操作。每个

   then()

   登录后复制
   方法都会返回一个新的 Promise，使得异步逻辑清晰、线性，极大地提升了代码的可读性和可维护性。

   <pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;
   
   $promise = new Promise(); // 假设这是从某个异步任务返回的 Promise
   
   $promise
       ->then(function ($value) {
           echo "第一步完成，接收到值: " . $value . "\n";
           // 返回一个新的值，它会传递给下一个 then
           return "处理后的 " . $value;
       })
       ->then(function ($newValue) {
           echo "第二步完成，接收到值: " . $newValue . "\n";
           // 你也可以返回另一个 Promise，实现 Promise 链的动态扩展
           // return someOtherAsyncOperation();
       })
       ->then(function ($finalValue) {
           echo "所有异步操作完成，最终结果: " . $finalValue . "\n";
       });
   
   // 假设异步操作成功，并传入初始值
   $promise->resolve('原始数据');
   // 预期输出:
   // 第一步完成，接收到值: 原始数据
   // 第二步完成，接收到值: 处理后的 原始数据
   // 所有异步操作完成，最终结果: 处理后的 原始数据

   登录后复制

2. 优雅的错误处理： Promise 提供了统一的错误处理机制。当一个 Promise 被拒绝（

   reject

   登录后复制
   ）时，错误会沿着 Promise 链向下传递，直到被最近的

   onRejected

   登录后复制
   回调（

   then()

   登录后复制
   的第二个参数）或

   otherwise()

   登录后复制
   方法捕获。这避免了在每个异步操作中都添加

   try-catch

   登录后复制
   块的冗余。

   <pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;
   
   $promise = new Promise();
   
   $promise
       ->then(function ($value) {
           echo "尝试处理: " . $value . "\n";
           throw new \Exception("处理过程中发生了错误！"); // 抛出异常，Promise 将被拒绝
       })
       ->then(function ($value) {
           echo "这一步不会执行\n";
       })
       ->otherwise(function (\Exception $reason) { // 捕获链中任何地方的拒绝
           echo "捕获到错误: " . $reason->getMessage() . "\n";
           // 你可以选择返回一个值来恢复 Promise 链，或者再次抛出异常继续拒绝
           return "错误已处理，返回默认值";
       })
       ->then(function ($value) {
           echo "错误处理后继续执行: " . $value . "\n";
       });
   
   $promise->resolve('一些数据');
   // 预期输出:
   // 尝试处理: 一些数据
   // 捕获到错误: 处理过程中发生了错误！
   // 错误处理后继续执行: 错误已处理，返回默认值

   登录后复制

3. 同步等待与解包： 尽管 Promise 主要用于管理异步流，但在某些场景下，你可能需要同步地等待一个 Promise 完成并获取其最终结果（或抛出异常）。

   wait()

   登录后复制
   方法就是为此而生。

   <pre class="brush:php;toolbar:false;">use GuzzleHttp\Promise\Promise;
   
   $promise = new Promise(function () use (&$promise) {
       // 模拟一个耗时操作，例如读取文件或完成一个网络请求
       sleep(2); // 阻塞 2 秒
       $promise->resolve('这是异步操作的结果');
   });
   
   echo "开始等待异步操作...\n";
   $result = $promise->wait(); // 阻塞当前脚本，直到 $promise 完成
   echo "异步操作完成，结果是: " . $result . "\n";
   // 预期输出:
   // 开始等待异步操作...
   // (等待 2 秒)
   // 异步操作完成，结果是: 这是异步操作的结果

   登录后复制

   这在需要确保所有后台任务在脚本结束前都已完成时非常有用。

4. 取消机制： 对于那些尚未完成的异步操作，

   guzzlehttp/promises

   登录后复制
   还提供了

   cancel()

   登录后复制
   方法，允许你尝试取消它们，从而释放资源或避免不必要的计算。

实际应用效果与优势

通过引入

guzzlehttp/promises

• 提升用户体验： 页面加载速度更快，因为多个独立的数据获取或计算任务可以逻辑上并行进行，减少了总等待时间。
• 代码可读性与可维护性： 链式调用和统一的错误处理机制使得异步逻辑清晰明了，易于理解和调试，大大降低了维护成本。
• 健壮性： 结构化的错误处理减少了未捕获异常的风险，提高了应用的稳定性。
• 与 Guzzle HTTP 客户端完美结合： Guzzle HTTP 客户端本身就大量使用了 Promises 来处理异步 HTTP 请求，因此两者结合使用能发挥最大效力，轻松实现高效的并发 HTTP 请求。

总结

guzzlehttp/promises

以上就是如何在PHP中优雅处理异步操作？GuzzlePromises助你告别回调地狱！的详细内容，更多请关注php中文网其它相关文章！