最近在开发一个高性能Web服务时，我遇到了一个常见的“性能瓶颈”：大量的外部API调用和数据库查询。按照传统的PHP同步编程模式，每一次调用都会让程序停下来，等待响应。这在单个请求中可能不明显，但当并发请求量上来时，整个系统就会变得异常缓慢，用户不得不面对漫长的加载页面，甚至出现超时错误。这种“同步阻塞”的模式，不仅严重影响了用户体验，也导致服务器资源无法得到有效利用——CPU和内存都在空闲等待I/O操作完成。
我尝试过一些简单的并行方案，比如通过curl_multi_init来批量发送http请求，但很快发现，管理这些复杂的异步回调、处理错误以及确保数据流正确传递，变得异常困难，代码也变得难以维护，充斥着“回调地狱”的噩梦。我急需一种更优雅、更现代的方式来处理这些异步操作。
正当我为此苦恼时，我发现了guzzlehttp/promises这个库。它基于Promises/A+规范，为PHP带来了强大的异步编程能力。简单来说，一个Promise（承诺）代表了一个异步操作的最终结果。这个结果可能在未来某个时间点成功（履行），也可能失败（拒绝）。而你可以在Promise上注册回调函数，以便在结果可用时执行相应的逻辑，而无需阻塞当前程序的执行。
通过以下地址可以学习Composer：学习地址
安装 Guzzle Promises
首先，使用Composer轻松地将guzzlehttp/promises集成到你的项目中：
立即学习“PHP免费学习笔记（深入）”；
<code class="bash">composer require guzzlehttp/promises</code>
如何使用 Guzzle Promises 解决问题
以一个典型的场景为例：我们需要同时调用两个不同的外部API，然后将它们的结果合并处理。如果使用同步方式，我们会先调用API A，等待其返回，再调用API B，再次等待。而使用Promises，我们可以同时发起这两个调用，然后等待它们都完成。
<code class="php"><?php
require 'vendor/autoload.php';
use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Promise\Utils; // 用于同时等待多个Promise
// 模拟一个异步API调用，返回一个Promise
function callApiA(): Promise
{
$promise = new Promise();
echo "API A 调用开始...\n";
// 模拟耗时操作，例如网络请求
// 实际应用中，这里可能是 Guzzle HTTP 客户端返回的 Promise
$time = rand(1, 3);
\React\EventLoop\Factory::create()->addTimer($time, function() use ($promise, $time) {
$promise->resolve("API A 数据 (耗时 {$time}s)");
echo "API A 调用完成。\n";
})->run(); // 注意：这里为了演示，直接运行了事件循环，实际应用中通常是全局的
return $promise;
}
function callApiB(): Promise
{
$promise = new Promise();
echo "API B 调用开始...\n";
$time = rand(1, 4);
\React\EventLoop\Factory::create()->addTimer($time, function() use ($promise, $time) {
$promise->resolve("API B 数据 (耗时 {$time}s)");
echo "API B 调用完成。\n";
})->run(); // 同上
return $promise;
}
echo "主程序开始执行...\n";
// 同时发起两个异步调用
$promiseA = callApiA();
$promiseB = callApiB();
// 使用 Utils::all() 等待所有 Promise 完成
// 这会返回一个新的 Promise，当所有子 Promise 都成功时，它才成功
$combinedPromise = Utils::all([$promiseA, $promiseB]);
// 注册回调，当所有 Promise 都成功时执行
$combinedPromise->then(
function (array $results) {
echo "所有API调用完成！\n";
echo "结果 A: " . $results[0] . "\n";
echo "结果 B: " . $results[1] . "\n";
echo "可以继续处理合并后的数据了。\n";
},
function (\Throwable $reason) {
echo "有API调用失败: " . $reason->getMessage() . "\n";
}
);
// Guzzle Promises 内部使用一个任务队列来处理回调。
// 在异步场景下，你需要在一个事件循环中定期运行这个队列。
// 如果是同步等待，wait() 方法会自动运行队列。
// 这里我们模拟异步，所以需要在某个地方驱动事件循环。
// 对于简单的脚本，或者在CLI工具中，你也可以使用 `wait()` 强制同步等待结果：
// $results = $combinedPromise->wait();
// var_dump($results);
echo "主程序继续执行，无需等待API调用完成...\n";
// 可以在这里执行其他不依赖API结果的逻辑
// 实际应用中，你可能需要一个全局的事件循环来驱动所有异步操作，
// 例如结合 ReactPHP 或 Amp 等库。
// 在这个简单的例子中，我们通过在每个模拟函数中运行 addTimer().run() 来演示。
// 如果是在web环境下，通常由框架或HTTP客户端（如Guzzle HTTP Client）的底层机制来驱动。</code>核心概念解析：
pending（进行中）、fulfilled（已完成/成功）和rejected（已拒绝/失败）。then() 方法: Promise的核心。你可以用它注册两个回调函数：一个在Promise成功时执行（onFulfilled），另一个在Promise失败时执行（onRejected）。then() 方法总是返回一个新的Promise，这使得链式调用成为可能，避免了回调地狱。then()回调返回一个值时，这个值会被传递给下一个then()。如果返回的是另一个Promise，则下一个then()会等待这个新的Promise完成。wait() 方法: 虽然Guzzle Promises主要用于异步，但wait()方法允许你强制一个Promise同步完成并获取其结果。这在某些需要阻塞的场景（如CLI工具）中非常有用。onRejected回调或otherwise()方法，可以优雅地捕获和处理异步操作中的错误。使用guzzlehttp/promises，我的项目获得了显著的提升：
then().then()）取代了层层嵌套的回调函数，使得异步逻辑的编写和阅读变得更加直观和可维护。onRejected回调捕获，简化了错误管理。在实际应用中，我利用Guzzle Promises实现了：
总而言之，guzzlehttp/promises为PHP开发者打开了异步编程的大门，让我们可以构建出响应更快、效率更高、用户体验更好的应用。告别阻塞，拥抱异步，让你的PHP程序真正“飞”起来！
以上就是如何优雅地处理PHP异步操作？GuzzlePromises助你实现非阻塞编程的详细内容，更多请关注php中文网其它相关文章！
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移，垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是，许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
933
收藏
