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

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


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

￥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);
    // 处理结果
    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://example.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://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();
// 处理响应数据
// …
上述代码通过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;
// 处理响应数据
// …
上述代码使用Swoole\Coroutine\Http\Client类初始化两个HTTP客户端实例，然后通过get方法发送异步GET请求。接着，通过Swoole\Event::wait方法等待所有的请求完成，并通过body属性获取响应数据。最后，可以对获取到的响应数据进行处理。


总结
以上是几种常用的在PHP中实现异步请求的方法，可以根据具体的需求选择合适的方法来实现异步化。总的来说，PHP实现异步请求有多种方法可供选择，每种方法都有其特点和适用场景。选择合适的方法取决于具体的需求和项目情况。

小二CMS介绍

我们立足合肥，业务覆盖安徽、全国及全球市场。我们凭借一支经验丰富、富有创意、协作无间的专业技术团队，专注于将前沿技术通过高效简捷的途径呈现给客户，量身打造优质解决方案。我们致力于通过持续努力，成为客户在信息化领域值得托付、共创价值的长期战略合作伙伴，协助客户在新经济时代敏锐捕捉商机，拓展发展空间，构筑强大竞争力。小二CMS专注企业数字化转型的智能建站与营销系统，提供从官网搭建、品牌推广到运营增长的一站式服务，助力中小企业低门槛拥有专业级互联网阵地。

网站建设 移动相关开发 营销推广与优化 域名主机邮箱 产品与技术 企业服务

了解全部业务

扫码咨询 · 关注微信