PHP实现异步请求的四种方法

发布:smiling　来源: PHP粉丝网　添加日期：2024-09-29 19:14:51　浏览: 评论：0　

PHP中的cURL可用于发起 HTTP 请求，通常同步地等待服务器响应。如果你想要实现异步操作，即 PHP 程序继续执行而无需等待 cURL 请求完成，你可以考虑以下几种方式：

使用curl_multi

cURL 提供了设置 curl_multi 和 curl_multi_exec 来同时处理多个请求，这种方式下你需要编写回调函数来处理每个请求的结果。

$urls = [

    'http://www.phpfensi.com/api/endpoint1',

    'http://www.phpfensi.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);

    // 处理结果

    curl_multi_remove_handle($multiHandle, $ch);

}

curl_multi_close($multiHandle);

使用 pthreads

虽然 PHP 自身并不是原生支持多线程的语言，但是可以借助 pthreads 扩展创建并管理线程，让 cURL 在另一个线程里运行。

<?php

require 'vendor/autoload.php';

$promise = new \React\Promise\Promise(function ($resolve, $reject) {

    // 创建 cURL 操作

    $ch = curl_init();

    // 设置请求选项...

    curl_setopt($ch, CURLOPT_URL, 'http://www.phpfensi.com');

    // 创建一个新的 React 异步客户端

    $client = new \React\Curl\Adapter\Curl();

    // 使用 React 异步库发起请求

    $response = $client->enqueue($ch);

    // 当请求完成后，调用 resolve 或 reject 函数

    $response->then(

        function ($result) use ($resolve) { $resolve(json_decode($result)); },

        function ($error) use ($reject) { $reject($error); }

    );

});

// 同时，主线程继续执行其他任务

$promise->wait(); // 当 cURL 完成后，此处阻塞

?>

使用Guzzle库

Guzzle是一个功能强大的HTTP客户端库，可以用于发送异步HTTP请求。它提供了方便的接口和功能，使得发送异步请求变得更加简单。以下是一个使用Guzzle库发送异步请求的示例代码：

$client = new \GuzzleHttp\Client();

$promises = [

'api1' => $client->getAsync('http://www.phpfensi.com/api1'),

'api2' => $client->getAsync('http://www.phpfensi.com/api2'),

];

$results = \GuzzleHttp\Promise\Utils::settle($promises)->wait();

$response1 = $results['api1']['value']->getBody()->getContents();

$response2 = $results['api2']['value']->getBody()->getContents();

// 处理响应数据

// …

上述代码通过GuzzleHttp\Client类初始化一个HTTP客户端实例，然后使用getAsync方法发送异步GET请求，并将返回的Promise对象存储在$promises数组中。接着，通过\GuzzleHttp\Promise\Utils::settle方法等待所有的Promise对象，并通过getBody方法获取响应数据。最后，可以对获取到的响应数据进行处理。

使用Swoole扩展

Swoole是一个高性能的异步并行网络通信框架，可以用于实现PHP的异步编程。通过使用Swoole扩展，可以轻松实现异步请求。以下是一个使用Swoole扩展发送异步请求的示例代码：

$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;

// 处理响应数据

// …