最近在开发一个处理用户提交数据的程序时，遇到了一个棘手的问题：用户输入的文本中包含各种非ASCII字符，例如中文、日文、特殊符号等等。这些字符导致程序在处理字符串时效率低下，甚至出现错误。为了解决这个问题，我尝试了多种方法，最终找到了voku/portable-ascii这个库。Composer在线学习地址：学习地址
漫长等待的痛苦：传统PHP请求的瓶颈
想象一下，你的php应用需要从三个不同的微服务或第三方api获取数据，然后将它们整合展示给用户。最直观的做法可能是这样：
// 伪代码，模拟耗时操作function fetchDataFromApi(string $apiName): string{ echo "开始从 {$apiName} 获取数据...n"; sleep(rand(1, 3)); // 模拟网络延迟 echo "从 {$apiName} 获取数据完成。n"; return "{$apiName} 的数据";}$data1 = fetchDataFromApi('API A');$data2 = fetchDataFromApi('API B');$data3 = fetchDataFromApi('API C');echo "所有数据获取完毕：{$data1}, {$data2}, {$data3}n";这段代码会先等待 API A 的数据返回，然后才去请求 API B，最后才是 API C。如果每个API都需要2秒，那么总共就需要至少6秒！在Web应用中，这几乎是不可接受的响应时间。在命令行脚本中，也意味着漫长的等待。这种串行阻塞的执行方式，是PHP处理I/O密集型任务时的主要瓶颈。我们渴望一种能够“同时”发起请求，并在所有请求完成后再处理结果的方式。
救星登场：Composer与Guzzle Promises
如何才能让这些请求“同时”进行呢？在PHP中，我们通常会借助“Promise”（承诺）的概念来实现非阻塞的异步操作。而 guzzlehttp/promises 库正是PHP世界中一个强大且成熟的Promise实现。
Promise是什么？简单来说，Promise是一个表示异步操作最终完成（或失败）及其结果值的对象。它不会立即返回结果，而是承诺在未来某个时刻提供结果。你可以为这个“承诺”注册回调函数，当操作成功时执行一个函数（onFulfilled），失败时执行另一个函数（onRejected）。
Composer如何帮助我们？Composer是PHP的依赖管理工具，它让安装和管理像 guzzlehttp/promises 这样的库变得异常简单。你不再需要手动下载文件、配置路径，Composer会替你处理这一切。
要安装 guzzlehttp/promises，你只需要在项目根目录运行一行简单的命令：
composer require guzzlehttp/promisesComposer会自动下载库文件及其所有依赖，并生成自动加载文件，让你能够直接在代码中使用它。
立即学习“PHP免费学习笔记（深入）”；
实践出真知：使用Guzzle Promises实现并发
现在，让我们看看如何使用 guzzlehttp/promises 来改造上面的例子，实现非阻塞的并发请求。
音刻
AI音视频转录和笔记工具
97 查看详情
add(function() use ($resolve, $apiName, $delay) { sleep($delay); // 仍然是阻塞的，但展示了Promise的结构 echo " [{$apiName}] 完成获取数据。n"; $resolve("{$apiName} 的数据"); }); });}// 创建三个Promise，它们代表三个独立的异步操作$promiseA = createAsyncFetchPromise('API A');$promiseB = createAsyncFetchPromise('API B');$promiseC = createAsyncFetchPromise('API C');// 使用 Utils::all() 来等待所有Promise完成// Utils::all() 返回一个新的Promise，当其内部所有Promise都完成时，它才完成$allPromises = Utils::all([ 'api_a_result' => $promiseA, 'api_b_result' => $promiseB, 'api_c_result' => $promiseC,]);// 同步等待所有Promise完成并获取结果// wait() 方法会阻塞当前进程，直到Promise被解决或拒绝$results = $allPromises->wait();$endTime = microtime(true);$duration = round($endTime - $startTime, 2);echo "n所有数据获取完毕！n";echo "API A 结果: " . $results['api_a_result'] . "n";echo "API B 结果: " . $results['api_b_result'] . "n";echo "API C 结果: " . $results['api_c_result'] . "n";echo "总耗时: {$duration} 秒n";?>代码解析：
use GuzzleHttpPromisePromise; use GuzzleHttpPromiseUtils;: 导入所需的类。Promise 是核心，Utils 提供了像 all() 这样的辅助函数，用于处理多个Promise。createAsyncFetchPromise(): 这个函数现在返回一个 Promise 对象。在实际应用中，如果你使用 guzzlehttp/guzzle 库进行HTTP请求，它的 getAsync()、postAsync() 等方法会直接返回Promise。这里我们用 sleep() 和 Utils::queue()->add() 模拟异步行为，以展示Promise的工作方式。Utils::all([...]): 这是实现并发的关键。它接收一个Promise数组，并返回一个新的Promise。只有当数组中的所有Promise都成功解决后，这个新的Promise才会解决，其结果是一个包含所有子Promise结果的数组。如果任何一个子Promise被拒绝，则 all() 返回的Promise也会立即被拒绝。$allPromises->wait(): 调用 wait() 方法会强制Promise同步完成并返回其最终结果。这意味着脚本会在这里暂停，直到所有并发请求都完成。
运行这段代码，你会发现总耗时会显著减少。即使每个API请求都可能延迟3秒，但因为它们是“并发”发起的，总耗时将接近最长那个请求的时间（而不是所有请求时间之和），例如，可能只需要3秒多一点！
Guzzle Promises的更多亮点
除了并发处理，guzzlehttp/promises 还提供了许多强大的特性：
链式调用 (then): 你可以轻松地将多个异步操作串联起来，一个Promise的结果作为下一个Promise的输入。错误处理 (otherwise): 优雅地捕获和处理异步操作中的错误。取消 (cancel): 如果异步操作不再需要，可以尝试取消它。迭代式处理: 内部实现优化，即使有“无限”Promise链，也能保持恒定的堆栈大小，避免栈溢出。与现有系统集成: 能够与任何具有 then 方法的对象（如ReactPHP的Promise）进行互操作。
总结：效率与优雅并存
通过Composer引入 guzzlehttp/promises 库，我们成功地将PHP脚本中耗时的I/O操作从串行阻塞转变为非阻塞并发。这带来的好处是显而易见的：
显著提升性能: 大幅缩短脚本执行时间，尤其是在I/O密集型任务中。改善用户体验: 响应速度更快，减少用户等待时间。代码更清晰: Promise模式让异步逻辑的组织和管理变得更加结构化和可读。易于扩展: 面对更复杂的并发场景，如限制并发数量、处理部分成功等，Promise模式都能提供灵活的解决方案。
所以，下次当你再遇到PHP脚本因外部I/O而“慢如蜗牛”时，不妨考虑一下Composer和Guzzle Promises这对黄金搭档。它们将帮助你告别漫长等待，让你的PHP应用运行得更快、更高效！
以上就是告别漫长等待：如何使用Composer和GuzzlePromises加速PHP并发请求！的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/759940.html
微信扫一扫 
支付宝扫一扫 
