如何解决PHP应用中多API请求的并发瓶颈，使用Composer与GuzzlePromises可以。-composer-PHP中文网

如何解决PHP应用中多API请求的并发瓶颈，使用Composer与GuzzlePromises可以。

WBOY

发布： 2025-09-02 12:46:37

原创

381人浏览过

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

告别“龟速”响应：PHP应用中多API请求的并发挑战

最近，我负责开发一个复杂的电商后台系统。其中一个核心功能是展示商品的详细信息，但这些信息分散在不同的微服务中：商品基本信息来自“商品服务”，库存数据来自“库存服务”，用户评价来自“评论服务”，甚至还有一些推荐商品来自“推荐算法服务”。

最初，我的代码是这样写的：

<pre class="brush:php;toolbar:false;">// 伪代码
$productInfo = $productService->getProductDetails($productId); // 耗时200ms
$stockInfo = $stockService->getStockLevel($productId);       // 耗时150ms
$reviews = $commentService->getReviews($productId);         // 耗时300ms
$recommendations = $recommendationService->getRecommendations($productId); // 耗时250ms

// 总耗时：200 + 150 + 300 + 250 = 900ms (不含网络开销和PHP自身处理时间)
// 这仅仅是一个页面的数据聚合，如果请求更多，等待时间会更长！

登录后复制

这种顺序执行的方式，导致用户每次加载商品详情页都要等待将近一秒钟，这在如今追求极致体验的互联网时代是完全不可接受的。我尝试优化每个服务的响应时间，但即使每个服务都快如闪电，串行执行的本质决定了整体响应时间依然是累加的。我迫切需要一种方法，让这些独立的API请求能够“同时”发起，然后等待所有结果回来，大大缩短总等待时间。

拥抱异步思维：Composer与Guzzle Promises的强强联合

正当我为如何让PHP这个传统上同步的语言实现并发请求而苦恼时，我发现了解决这个问题的“瑞士军刀”——

guzzlehttp/promises

登录后复制

库。当然，要使用这个库，首先你需要一个强大的PHP依赖管理工具：Composer。

Composer 是PHP生态系统中不可或缺的一部分，它帮助我们轻松地管理项目依赖。通过Composer，我们可以快速地将

guzzlehttp/promises

登录后复制

引入到我们的项目中。

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

guzzlehttp/promises

登录后复制

库提供了一个符合 Promises/A+ 规范的实现，它让我们能够以一种更优雅、更具可读性的方式来处理异步操作的“最终结果”。虽然PHP本身并没有像JavaScript那样原生的事件循环来处理真正的非阻塞I/O（除非结合ReactPHP等异步框架），但

guzzlehttp/promises

登录后复制

配合像 Guzzle HTTP 客户端这样的库，可以模拟并管理并发的I/O操作，极大地提升效率。

如何使用Guzzle Promises解决并发请求问题

首先，我们通过Composer安装

guzzlehttp/promises

登录后复制

：

百度智能云·曦灵

百度旗下的AI数字人平台

查看详情

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

登录后复制

如果你还没有安装 Guzzle HTTP 客户端（通常与 promises 库一起使用以发起HTTP请求），也一并安装：

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

登录后复制

现在，我们可以改造之前的串行请求，使其并行执行。核心思路是：

为每个API请求创建一个“Promise”。
使用
```
GuzzleHttp\Promise\Utils::settle()
```
登录后复制
或
```
GuzzleHttp\Promise\Utils::all()
```
登录后复制
等工具函数，等待所有Promise完成（无论是成功还是失败）。
处理每个Promise的最终结果。

下面是一个实际的代码示例：

<pre class="brush:php;toolbar:false;"><?php

require 'vendor/autoload.php';

use GuzzleHttp\Client;
use GuzzleHttp\Promise\Utils;
use GuzzleHttp\Exception\RequestException;

// 假设我们有一个Guzzle HTTP客户端实例
$client = new Client([
    'timeout'  => 5.0, // 请求超时时间
]);

$productId = 123;

echo "开始并发请求...\n";
$startTime = microtime(true);

// 1. 创建一系列Promise，每个Promise代表一个异步API请求
$promises = [
    'productInfo' => $client->getAsync("http://product-service.example.com/products/{$productId}"),
    'stockInfo' => $client->getAsync("http://stock-service.example.com/stock/{$productId}"),
    'reviews' => $client->getAsync("http://comment-service.example.com/reviews/{$productId}"),
    'recommendations' => $client->getAsync("http://recommendation-service.example.com/recommendations/{$productId}"),
];

// 2. 使用 Utils::settle() 等待所有Promise完成
// Utils::settle() 会等待所有Promise都解决（fulfilled或rejected），并返回一个包含每个Promise状态和结果的数组。
// 如果你想所有请求都成功才继续，可以使用 Utils::all()。
$results = Utils::settle($promises)->wait();

$endTime = microtime(true);
echo "所有请求完成，总耗时：" . round(($endTime - $startTime) * 1000) . "ms\n";

// 3. 处理每个Promise的最终结果
$productData = null;
$stockData = null;
$reviewsData = null;
$recommendationsData = null;

if ($results['productInfo']['state'] === 'fulfilled') {
    $productData = json_decode($results['productInfo']['value']->getBody(), true);
    echo "商品信息获取成功: " . json_encode($productData) . "\n";
} else {
    echo "商品信息获取失败: " . $results['productInfo']['reason']->getMessage() . "\n";
}

if ($results['stockInfo']['state'] === 'fulfilled') {
    $stockData = json_decode($results['stockInfo']['value']->getBody(), true);
    echo "库存信息获取成功: " . json_encode($stockData) . "\n";
} else {
    echo "库存信息获取失败: " . $results['stockInfo']['reason']->getMessage() . "\n";
}

if ($results['reviews']['state'] === 'fulfilled') {
    $reviewsData = json_decode($results['reviews']['value']->getBody(), true);
    echo "评论信息获取成功: " . json_encode($reviewsData) . "\n";
} else {
    echo "评论信息获取失败: " . $results['reviews']['reason']->getMessage() . "\n";
}

if ($results['recommendations']['state'] === 'fulfilled') {
    $recommendationsData = json_decode($results['recommendations']['value']->getBody(), true);
    echo "推荐信息获取成功: " . json_encode($recommendationsData) . "\n";
} else {
    echo "推荐信息获取失败: " . $results['recommendations']['reason']->getMessage() . "\n";
}

// 最终将所有数据聚合，渲染页面
$pageData = [
    'product' => $productData,
    'stock' => $stockData,
    'reviews' => $reviewsData,
    'recommendations' => $recommendationsData,
];

// var_dump($pageData);

登录后复制

代码说明：

```
$client->getAsync()
```
登录后复制
：Guzzle HTTP 客户端的异步方法，它不会立即返回响应，而是返回一个 Promise 对象。
```
$promises
```
登录后复制
数组：我们把所有异步请求返回的 Promise 收集起来。
```
Utils::settle($promises)
```
登录后复制
：这个函数会创建一个新的 Promise，当
```
$promises
```
登录后复制
数组中的所有 Promise 都完成（无论成功或失败）时，这个新的 Promise 才会解决。
```
->wait()
```
登录后复制
：这是一个阻塞调用，它会暂停当前脚本的执行，直到
```
Utils::settle()
```
登录后复制
返回的 Promise 解决。在等待过程中，
```
guzzlehttp/promises
```
登录后复制
会运行其内部的任务队列，处理所有已发起的异步请求。
```
$results
```
登录后复制
：
```
settle()
```
登录后复制
返回的结果是一个关联数组，键是原始 Promise 的键，值是一个包含
```
state
```
登录后复制
（
```
fulfilled
```
登录后复制
或
```
rejected
```
登录后复制
）和
```
value
```
登录后复制
（成功时的响应对象）或
```
reason
```
登录后复制
（失败时的异常对象）的数组。这让我们可以精细地处理每个请求的成功或失败。

通过这种方式，即使每个服务单独耗时较长，但由于它们是并行发起的，总等待时间理论上约等于其中最慢的那个请求的耗时，而不是所有请求耗时的总和。

Guzzle Promises带来的优势与实际应用效果

使用 Composer 和

guzzlehttp/promises

登录后复制

解决多API请求并发问题，带来了显著的优势：

性能飞跃： 最直接的效果就是页面加载速度的显著提升。从之前的900ms缩短到最慢请求的300ms左右（加上一点点并行处理的开销），用户体验大大改善。
代码优雅与可读性： Promise 模式使得异步逻辑的编写更加清晰。通过
```
then()
```
登录后复制
链式调用，你可以明确地定义数据流和错误处理，避免了传统回调地狱的混乱。
健壮的错误处理：
```
settle()
```
登录后复制
方法允许我们即使某个请求失败，也能获取其他成功请求的结果，从而构建更容错的应用。
```
reject()
```
登录后复制
和
```
otherwise()
```
登录后复制
提供了统一的错误处理机制。
资源利用率提升： 在等待外部I/O（如网络请求）时，PHP进程不再是空闲等待，而是可以同时处理其他网络请求，提高了服务器资源的利用效率。
灵活性高：
```
guzzlehttp/promises
```
登录后复制
提供了
```
wait()
```
登录后复制
（同步等待）、
```
cancel()
```
登录后复制
（取消请求）、
```
all()
```
登录后复制
（所有成功才继续）、
```
settle()
```
登录后复制
（所有完成，无论成功失败）等多种处理方式，满足不同场景的需求。