使用生成器时PHP异步HTTP请求变为同步的原因排查

正常的异步并行场景 #

Symfony HttpClient默认支持异步并行请求，比如下面的代码：

$response1 = $httpClient->request('GET', 'https://127.0.0.1:8000/service/a');
$response2 = $httpClient->request('GET', 'https://127.0.0.1:8000/service/b');

$array1 = $response1->toArray();
$array2 = $response2->toArray();

假设服务A、B各自需要5秒执行时间，这段代码总等待时间仅5秒——因为HttpClient会自动并行发起两个请求。

生成器方案的并行失效问题 #

实际开发中为了拆分逻辑，会用仓库类封装请求，有人尝试用生成器模拟类似JS的await效果，代码如下：

private function getResponse1(): Generator
{
    $response1 = $this->httpClient->request('GET', 'https://127.0.0.1:8000/service/a');

    return yield $response1->toArray();
}

private function getResponse2(): Generator
{
    $response2 = $this->httpClient->request('GET', 'https://127.0.0.1:8000/service/b');

    return yield $response2->toArray();
}

$response1 = $this->getResponse1();
$response2 = $this->getResponse2();

$array1 = $response1->current();
$array2 = $response2->current();

但测试发现，这段代码总等待时间变成了10秒，完全失去了并行能力。

问题根源 #

核心原因在于Symfony HttpClient的延迟执行机制：

• 调用request()方法时，并没有真正发起HTTP请求，只是创建了一个待执行的请求对象。
• 只有当你尝试读取响应内容（比如调用toArray()、getContent()）时，HttpClient才会真正调度并执行请求。

在生成器的写法中：

1. 调用$response1->current()时，会执行getResponse1()的代码，走到yield $response1->toArray()——此时才会发起请求A并等待5秒完成。
2. 等请求A完成后，再调用$response2->current()，才会发起请求B并等待5秒。
   两个请求变成了串行执行，所以总耗时10秒。

而正常写法中，先调用两次request()创建了两个请求对象，之后调用toArray()时，HttpClient会一次性调度所有待执行的请求，实现并行处理，因此总耗时5秒。

可行的解决方案 #

要在保留仓库类分离的同时，保留异步并行能力，可以用以下几种方式：

方案1：仓库返回请求对象，外层统一解析 #

修改仓库方法，返回ResponseInterface而不是直接解析后的数组，外层先收集所有请求，再统一触发并行执行：

// RepositoryA类
public function getRequest(): ResponseInterface
{
    return $this->httpClient->request('GET', 'https://127.0.0.1:8000/service/a');
}

// RepositoryB类
public function getRequest(): ResponseInterface
{
    return $this->httpClient->request('GET', 'https://127.0.0.1:8000/service/b');
}

// 业务逻辑代码
$responseA = $repositoryA->getRequest();
$responseB = $repositoryB->getRequest();

// 此时才会并行发起请求并等待结果
$dataA = $responseA->toArray();
$dataB = $responseB->toArray();

这种方式既保持了仓库类的职责分离，又能让HttpClient正常并行处理请求。

方案2：手动用stream()调度并行请求 #

如果一定要用生成器，可以先收集所有请求对象，再通过HttpClient::stream()方法手动触发并行执行：

// 仓库方法返回生成器，yield请求对象而非解析结果
private function getRequest1(): Generator
{
    yield $this->httpClient->request('GET', 'https://127.0.0.1:8000/service/a');
}

private function getRequest2(): Generator
{
    yield $this->httpClient->request('GET', 'https://127.0.0.1:8000/service/b');
}

// 收集所有待执行的请求
$requests = [];
$requests[] = $this->getRequest1()->current();
$requests[] = $this->getRequest2()->current();

// 用stream()并行处理所有请求
foreach ($this->httpClient->stream($requests) as $response => $chunk) {
    // 可以在这里处理响应块，比如实时读取内容
}

// 最后统一解析响应
$data1 = $requests[0]->toArray();
$data2 = $requests[1]->toArray();

stream()方法会一次性调度所有传入的请求对象，确保它们并行执行。

方案3：PHP 8.1+ 结合协程（Symfony Async组件） #

如果使用PHP 8.1及以上版本，可以安装symfony/async组件，用async/await风格的写法，本质还是确保先创建所有请求再统一等待，避免串行执行。

内容的提问来源于stack exchange，提问作者rela589n