快捷導(dǎo)航

淺析PHP如何并行異步處理HTTP請(qǐng)求

更新時(shí)間：2025年02月24日 09:42:42 作者：Ai?編碼

在?PHP?中,由于其傳統(tǒng)的同步阻塞模型,實(shí)現(xiàn)并行異步處理?HTTP?請(qǐng)求并不像其他語言那樣直接,但也可以通過一些擴(kuò)展和工具來實(shí)現(xiàn),下面小編就來講講具體實(shí)現(xiàn)方法吧

在 PHP 中，由于其傳統(tǒng)的同步阻塞模型，實(shí)現(xiàn)并行異步處理 HTTP 請(qǐng)求并不像其他語言（如 Go 或 Node.js）那樣直接。不過，仍然可以通過一些擴(kuò)展和工具來實(shí)現(xiàn)并行異步處理。以下是幾種常見的方法：

1. 使用 cURL 的多線程功能

PHP 的 cURL 擴(kuò)展支持多線程處理，可以通過 curl_multi_* 系列函數(shù)實(shí)現(xiàn)并行 HTTP 請(qǐng)求。

示例代碼：

$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); // 將單個(gè) cURL 句柄添加到多線程中
    $handles[] = $ch;
}

$running = null;
do {
    curl_multi_exec($mh, $running); // 執(zhí)行并行請(qǐng)求
    curl_multi_select($mh); // 等待活動(dòng)
} while ($running > 0);

$responses = [];
foreach ($handles as $ch) {
    $responses[] = curl_multi_getcontent($ch); // 獲取每個(gè)請(qǐng)求的響應(yīng)
    curl_multi_remove_handle($mh, $ch); // 移除句柄
    curl_close($ch);
}

curl_multi_close($mh); // 關(guān)閉多線程 cURL

print_r($responses);

優(yōu)點(diǎn)：

原生支持，無需額外擴(kuò)展。
可以并行處理多個(gè) HTTP 請(qǐng)求。

缺點(diǎn)：

代碼復(fù)雜度較高。
需要手動(dòng)管理句柄和狀態(tài)。

2. 使用 Guzzle 異步客戶端

Guzzle 是一個(gè)流行的 PHP HTTP 客戶端庫，支持異步請(qǐng)求。

示例代碼：

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); // 發(fā)起異步請(qǐng)求
}

$responses = Promise\Utils::settle($promises)->wait(); // 等待所有請(qǐng)求完成

foreach ($responses as $response) {
    if ($response['state'] === 'fulfilled') {
        echo $response['value']->getBody() . "\n"; // 輸出響應(yīng)內(nèi)容
    } else {
        echo 'Request failed: ' . $response['reason']->getMessage() . "\n";
    }
}

優(yōu)點(diǎn)：

代碼簡(jiǎn)潔，易于使用。
支持并發(fā)請(qǐng)求和異步處理。

缺點(diǎn)：

需要安裝 Guzzle 庫。

3. 使用 Swoole 擴(kuò)展

Swoole 是一個(gè)高性能的 PHP 擴(kuò)展，支持異步、協(xié)程和并行處理。

示例代碼：

Swoole\Runtime::enableCoroutine(); // 啟用協(xié)程

$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(); // 等待所有協(xié)程完成

print_r($responses);

優(yōu)點(diǎn)：

高性能，支持協(xié)程和異步 I/O。
適合高并發(fā)場(chǎng)景。

缺點(diǎn)：

需要安裝 Swoole 擴(kuò)展。
學(xué)習(xí)曲線較高。

4. 使用 ReactPHP

ReactPHP 是一個(gè)基于事件驅(qū)動(dòng)的 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();

優(yōu)點(diǎn)：

基于事件驅(qū)動(dòng)，適合異步編程。
支持長(zhǎng)連接和流式處理。

缺點(diǎn)：

需要安裝 ReactPHP 庫。
代碼復(fù)雜度較高。

5. 使用多進(jìn)程（pcntl 擴(kuò)展）

PHP 的 pcntl 擴(kuò)展支持多進(jìn)程編程，可以通過創(chuàng)建子進(jìn)程來實(shí)現(xiàn)并行處理。

示例代碼：

$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; // 父進(jìn)程記錄子進(jìn)程 ID
    } else {
        // 子進(jìn)程處理請(qǐng)求
        echo file_get_contents($url) . "\n";
        exit(); // 子進(jìn)程退出
    }
}

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

優(yōu)點(diǎn)：