PHP實現(xiàn)異步請求的四種方法

更新時間：2024年07月13日 15:40:46 投稿：yin

PHP中的cURL可用于發(fā)起HTTP請求,通常同步地等待服務(wù)器響應(yīng),如果你想要實現(xiàn)異步操作,即PHP程序繼續(xù)執(zhí)行而無需等待cURL請求完成,PHP實現(xiàn)異步請求有多種方法可供選擇,每種方法都有其特點和適用場景,選擇合適的方法取決于具體的需求和項目情況,

使用curl_multi

cURL 提供了設(shè)置 curl_multi 和 curl_multi_exec 來同時處理多個請求，這種方式下你需要編寫回調(diào)函數(shù)來處理每個請求的結(jié)果。

$urls = [
    'http://example.com/api/endpoint1',
    'http://example.com/api/endpoint2',
    // ...更多URLs
];
 
$multiHandle = curl_multi_init();
 
foreach ($urls as $url) {
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
    curl_multi_add_handle($multiHandle, $ch);
}
 
$running = null;
do {
    usleep(10000); // 可選：防止CPU全速運行
    curl_multi_exec($multiHandle, $running);
} while ($running > 0);
 
foreach ($urls as $url) {
    $ch = curl_multi_getcontent($ch);
    // 處理結(jié)果
    curl_multi_remove_handle($multiHandle, $ch);
}
 
curl_multi_close($multiHandle);

使用 pthreads

雖然 PHP 自身并不是原生支持多線程的語言，但是可以借助 pthreads 擴展創(chuàng)建并管理線程，讓 cURL 在另一個線程里運行。

<?php
require 'vendor/autoload.php';
$promise = new \React\Promise\Promise(function ($resolve, $reject) {
    // 創(chuàng)建 cURL 操作
    $ch = curl_init();
    // 設(shè)置請求選項...
    curl_setopt($ch, CURLOPT_URL, 'http://example.com');
    // 創(chuàng)建一個新的 React 異步客戶端
    $client = new \React\Curl\Adapter\Curl();
    // 使用 React 異步庫發(fā)起請求
    $response = $client->enqueue($ch);
    // 當請求完成后，調(diào)用 resolve 或 reject 函數(shù)
    $response->then(
        function ($result) use ($resolve) { $resolve(json_decode($result)); },
        function ($error) use ($reject) { $reject($error); }
    );
});
// 同時，主線程繼續(xù)執(zhí)行其他任務(wù)
$promise->wait(); // 當 cURL 完成后，此處阻塞
?>

使用Guzzle庫

Guzzle是一個功能強大的HTTP客戶端庫，可以用于發(fā)送異步HTTP請求。它提供了方便的接口和功能，使得發(fā)送異步請求變得更加簡單。以下是一個使用Guzzle庫發(fā)送異步請求的示例代碼：

$client = new \GuzzleHttp\Client();
$promises = [
    'api1' => $client->getAsync('http://example.com/api1'),
    'api2' => $client->getAsync('http://example.com/api2'),
];
$results = \GuzzleHttp\Promise\Utils::settle($promises)->wait();
$response1 = $results['api1']['value']->getBody()->getContents();
$response2 = $results['api2']['value']->getBody()->getContents();
// 處理響應(yīng)數(shù)據(jù)
// …

上述代碼通過GuzzleHttp\Client類初始化一個HTTP客戶端實例，然后使用getAsync方法發(fā)送異步GET請求，并將返回的Promise對象存儲在$promises數(shù)組中。接著，通過\GuzzleHttp\Promise\Utils::settle方法等待所有的Promise對象，并通過getBody方法獲取響應(yīng)數(shù)據(jù)。最后，可以對獲取到的響應(yīng)數(shù)據(jù)進行處理。

使用Swoole擴展

Swoole是一個高性能的異步并行網(wǎng)絡(luò)通信框架，可以用于實現(xiàn)PHP的異步編程。通過使用Swoole擴展，可以輕松實現(xiàn)異步請求。以下是一個使用Swoole擴展發(fā)送異步請求的示例代碼：

$cli1 = new Swoole\Coroutine\Http\Client('example.com', 80);
$cli1->set(['timeout' => 10]);
$cli1->get('/api1');
$cli2 = new Swoole\Coroutine\Http\Client('example.com', 80);
$cli2->set(['timeout' => 10]);
$cli2->get('/api2');
Swoole\Event::wait();
$response1 = $cli1->body;
$response2 = $cli2->body;
// 處理響應(yīng)數(shù)據(jù)
// …

上述代碼使用Swoole\Coroutine\Http\Client類初始化兩個HTTP客戶端實例，然后通過get方法發(fā)送異步GET請求。接著，通過Swoole\Event::wait方法等待所有的請求完成，并通過body屬性獲取響應(yīng)數(shù)據(jù)。最后，可以對獲取到的響應(yīng)數(shù)據(jù)進行處理。