浅析PHP如何并行异步处理HTTP请求_Php

在 php 中，由于其传统的同步阻塞模型，实现并行异步处理 http 请求并不像其他语言（如 go 或 node.js）那样直接。不过，仍然可以通过一些扩展和工具来实现并行异步处理。以下是几种常见的方法：

1. 使用 curl 的多线程功能

php 的 curl 扩展支持多线程处理，可以通过 curl_multi_* 系列函数实现并行 http 请求。

示例代码：

$urls = [
    'https://example.com/api/1',
    'https://example.com/api/2',
    'https://example.com/api/3',
];

$mh = curl_multi_init(); // 初始化多线程 curl
$handles = [];

foreach ($urls as $url) {
    $ch = curl_init();
    curl_setopt($ch, curlopt_url, $url);
    curl_setopt($ch, curlopt_returntransfer, true);
    curl_multi_add_handle($mh, $ch); // 将单个 curl 句柄添加到多线程中
    $handles[] = $ch;
}

$running = null;
do {
    curl_multi_exec($mh, $running); // 执行并行请求
    curl_multi_select($mh); // 等待活动
} while ($running > 0);

$responses = [];
foreach ($handles as $ch) {
    $responses[] = curl_multi_getcontent($ch); // 获取每个请求的响应
    curl_multi_remove_handle($mh, $ch); // 移除句柄
    curl_close($ch);
}

curl_multi_close($mh); // 关闭多线程 curl

print_r($responses);

优点：

原生支持，无需额外扩展。
可以并行处理多个 http 请求。

缺点：

代码复杂度较高。
需要手动管理句柄和状态。

2. 使用 guzzle 异步客户端

guzzle 是一个流行的 php http 客户端库，支持异步请求。

示例代码：

require 'vendor/autoload.php';

use guzzlehttp\client;
use guzzlehttp\promise;

$client = new client();

$urls = [
    'https://example.com/api/1',
    'https://example.com/api/2',
    'https://example.com/api/3',
];

$promises = [];
foreach ($urls as $url) {
    $promises[] = $client->getasync($url); // 发起异步请求
}

$responses = promise\utils::settle($promises)->wait(); // 等待所有请求完成

foreach ($responses as $response) {
    if ($response['state'] === 'fulfilled') {
        echo $response['value']->getbody() . "\n"; // 输出响应内容
    } else {
        echo 'request failed: ' . $response['reason']->getmessage() . "\n";
    }
}

优点：

代码简洁，易于使用。
支持并发请求和异步处理。

缺点：

需要安装 guzzle 库。

3. 使用 swoole 扩展

swoole 是一个高性能的 php 扩展，支持异步、协程和并行处理。

示例代码：

swoole\runtime::enablecoroutine(); // 启用协程

$urls = [
    'https://example.com/api/1',
    'https://example.com/api/2',
    'https://example.com/api/3',
];

$responses = [];

go(function () use ($urls, &$responses) {
    $client = new swoole\coroutine\http\client('example.com', 443, true);
    foreach ($urls as $url) {
        $client->get($url);
        $responses[] = $client->body;
    }
});

swoole\event::wait(); // 等待所有协程完成

print_r($responses);

优点：

高性能，支持协程和异步 i/o。
适合高并发场景。

缺点：

需要安装 swoole 扩展。
学习曲线较高。

4. 使用 reactphp

reactphp 是一个基于事件驱动的 php 库，支持异步编程。

示例代码：

require 'vendor/autoload.php';

use react\eventloop\factory;
use react\httpclient\client;
use react\httpclient\response;

$loop = factory::create();
$client = new client($loop);

$urls = [
    'https://example.com/api/1',
    'https://example.com/api/2',
    'https://example.com/api/3',
];

foreach ($urls as $url) {
    $request = $client->request('get', $url);
    $request->on('response', function (response $response) {
        $response->on('data', function ($chunk) {
            echo $chunk;
        });
    });
    $request->end();
}

$loop->run();

优点：

基于事件驱动，适合异步编程。
支持长连接和流式处理。

缺点：

需要安装 reactphp 库。
代码复杂度较高。

5. 使用多进程（pcntl 扩展）

php 的 pcntl 扩展支持多进程编程，可以通过创建子进程来实现并行处理。

示例代码：

$urls = [
    'https://example.com/api/1',
    'https://example.com/api/2',
    'https://example.com/api/3',
];

$children = [];

foreach ($urls as $url) {
    $pid = pcntl_fork();
    if ($pid == -1) {
        die('could not fork');
    } elseif ($pid) {
        $children[] = $pid; // 父进程记录子进程 id
    } else {
        // 子进程处理请求
        echo file_get_contents($url) . "\n";
        exit(); // 子进程退出
    }
}

// 父进程等待所有子进程完成
foreach ($children as $pid) {
    pcntl_waitpid($pid, $status);
}

优点：