PHP 异步处理 HTTP 请求的并行处理策略

在处理高并发和大规模数据交互的 Web 应用中，PHP 的传统同步处理方式往往面临性能瓶颈。为了提升效率和响应速度，PHP 提供了多种技术来实现异步处理 HTTP 请求，其中最常用的方法包括使用 cURL 库的异步请求、Guzzle 客户端库以及结合 ReactPHP 或 Swoole 等扩展来实现真正的异步非阻塞 I/O 操作。本文将深入探讨这些技术，并解释如何利用它们来并行处理 HTTP 请求。

1. cURL 异步请求

cURL 是 PHP 中一个强大的库，支持多种协议，包括 HTTP、HTTPS、FTP 等。在 cURL 中，可以通过多句柄的方式来实现异步请求。每个句柄代表一个独立的请求，可以同时发送多个请求而不会阻塞主脚本的执行。

示例代码：

```php
$urls = ['http://example.com/api/data1', 'http://example.com/api/data2'];
$ch = [];

foreach ($urls as $url) {
$ch[] = curlinit($url); curlsetopt($ch[count($ch) - 1], CURLOPTRETURNTRANSFER, true); curlmultiaddhandle($mh, $ch[count($ch) - 1]);
}

$active = null;
$running = 0;

do {
$status = curlmultiexec($mh, $running);
if ($status === false) {
foreach(curlmultiselect($mh) as $id => $status) {
if ($status == CURLMCALLMULTIPERFORM) { curlmultiexec($mh, $running); } else { if ($id == $active) { $active = null; // 移除当前活动句柄的连接并重置为 null } } } } else { foreach ($ch as $key => $curl) { if (curlmultiinforead($mh, $key) === false) { // 检查是否还有待处理的句柄
break; // 结束循环并清理资源
} else {
$response = curlmultigetcontent($curl); // 获取响应内容
echo "Response from " . curlgetinfo($curl, CURLINFOURL) . "\n"; // 输出响应信息
echo $response; // 输出响应体内容
curlmultiremove_handle($mh, $curl); // 从句柄数组中移除并关闭该句柄
}
}
}
} while ($running > 0); // 继续循环直到所有请求完成或失败
```

2. Guzzle HTTP 客户端库

Guzzle 是 PHP 的一个 HTTP 客户端库，它支持同步和异步请求。使用 Guzzle 的异步功能，可以很方便地实现并发请求。通过 Promises 和 async/await，可以非常直观地处理异步操作。Guzzle 也是 PSR-7 的实现者之一，因此可以很好地与其他库和框架集成。

示例代码（使用 GuzzleHttp\Promise\promise_map）：

```php
use GuzzleHttp\Client;
use GuzzleHttp\Promise;
use GuzzleHttp\Psr7\Request;
use GuzzleHttp\Exception\RequestException;
use GuzzleHttp\Promise; // 引入 Promise 命名空间以使用 promise_map 方法
require 'vendor/autoload.php'; // 引入 Composer 的自动加载文件（需先安装 Guzzle）

$client = new Client(); // 创建 Guzzle HTTP 客户端实例
$urls = ['http://example.com/api/data1', 'http://example.com/api/data2']; // 要请求的 URLs 数组
$promises = []; // 创建空数组以存储 Promise 对象
foreach ($urls as $url) { // 为每个 URL 创建一个 Promise 对象并存入数组中
$promises[] = $client->getAsync($url)->then(function ($response) { // 使用 then 方法定义成功回调函数（将 response 输出）并返回它自身以保持链式调用特性（尽管此例中未使用）
return $response->getBody()->getContents(); // 获取响应体内容并返回之（这里以字符串形式）但注意保持 promise 的链式调用特性以便于后续处理或错误捕获（本例未显示错误处理）使用 Promise\promisemap 方法将所有 Promises 同时发起并收集结果：当所有请求都完成时（无更多 requests 被加入），Promise::wait 方法将执行 resolve（或 reject）并收集所有结果返回一个数组形式的结果集合。该数组中每个元素对应一个原始 Promise 的结果。本例中未展示此部分逻辑但理论上你应当如此收集并处理所有响应结果。 return $response->getBody()->getContents(); // 注意上述返回并非在 Promise\promisemap 方法内但用于示意你应如何获取并处理结果 })->otherwise(function ($e) { // 错误处理回调 }); // 当某个请求失败时将执行此回调函数 // 使用 promisemap 同时发起所有请求并收集结果 Promise\promisemap($promises, function ($promise) { return $promise->wait(); }); // 实际上这行代码是调用了 wait 方法等待所有 Promise 都 resolve 后返回一个包含所有结果的数组或 throw 一个包含所有拒绝的错误数组 但本例中我们只简单展示了如何使用 promise_map 同时发起多个请求 注意实际使用中你可能需要处理 wait 方法返回的 result 或 reject 结果 在本例中我们仅展示了如何设置这些操作逻辑 但并未实际执行等待操作（因为那样会阻塞脚本直到所有请求完成）} catch (Exception $e) { echo 'Caught exception: ' . $e->getMessage(); } catch (Error $e) { echo 'Caught error: ' . $e->getMessage(); } finally { echo 'Finally block'; } ```