登录
首页 >  文章 >  php教程

php代码示例如何实现异步请求_php异步请求代码示例【示例】

时间:2026-05-03 08:56:41 273浏览 收藏

在IT行业这个发展更新速度很快的行业,只有不停止的学习,才不会被行业所淘汰。如果你是文章学习者,那么本文《php代码示例如何实现异步请求_php异步请求代码示例【示例】》就很适合你!本篇内容主要包括##content_title##,希望对大家的知识积累有所帮助,助力实战开发!

PHP无原生async/await,所谓“异步”实为并发模拟:curl_multi_exec实现多请求并行等待,stream_socket_client+stream_select实现轻量非阻塞,Swoole/ReactPHP才是真异步但需重构环境。

php代码示例如何实现异步请求_php异步请求代码示例【示例】

PHP 里没有原生 async/await,别被名字骗了

PHP 是同步阻塞语言,所谓“异步请求”实际是模拟非阻塞行为:用 fsockopencURL + CURLOPT_NOSIGNALcurl_multi_exec 实现并发发包,但 PHP 进程本身仍会等待响应(除非配合 pcntl 或 Swoole)。直接写 async function 会报错 —— 那是 JavaScript 的语法。

用 curl_multi_exec 实现真正的并发 HTTP 请求

这是最常用、不依赖扩展的方案,适合同时发多个请求(如批量查第三方 API),避免串行等待。关键不是“不等”,而是“一起等”。

  • curl_multi_init() 创建批处理句柄
  • 每个请求用 curl_init() 单独配置,再用 curl_multi_add_handle() 加入批次
  • curl_multi_exec() 启动并发执行,返回 CURLM_CALL_MULTI_PERFORM 表示需轮询;用 curl_multi_select() 阻塞等待 I/O 就绪(避免空转 CPU)
  • 所有请求完成后,用 curl_multi_getcontent()curl_multi_info_read() 拿结果

示例片段:

$urls = ['https://httpbin.org/delay/1', 'https://httpbin.org/delay/2'];
$mh = curl_multi_init();
$chs = [];

foreach ($urls as $i => $url) {
    $ch = curl_init($url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_TIMEOUT, 5);
    curl_multi_add_handle($mh, $ch);
    $chs[$i] = $ch;
}

$active = null;
do {
    $mrc = curl_multi_exec($mh, $active);
} while ($mrc == CURLM_CALL_MULTI_PERFORM || $active);

while ($info = curl_multi_info_read($mh)) {
    $index = array_search($info['handle'], $chs);
    echo "Request $index done: " . strlen(curl_multi_getcontent($info['handle'])) . " bytes\n";
    curl_multi_remove_handle($mh, $info['handle']);
    curl_close($info['handle']);
}
curl_multi_close($mh);

用 stream_socket_client + stream_set_blocking 实现轻量级非阻塞连接

适用于需要控制 TCP 层、或不想引入 cURL 的场景(比如发裸 HTTP 请求头)。但注意:它只做到“连接非阻塞”,后续 fwrite/fread 仍可能阻塞,必须配合 stream_select() 判断可读/可写。

  • stream_socket_client($addr, $errno, $errstr, 0.1, STREAM_CLIENT_ASYNC_CONNECT) 设置超时为 0.1 秒并启用异步连接
  • 调用 stream_set_blocking($fp, false) 确保后续 I/O 不卡住
  • stream_select($read, $write, $except, 0, 50000) 等待最多 50ms,检查 socket 是否就绪

容易漏掉的是错误处理:stream_socket_client 失败时返回 false,但 $errno 才是真实错误码(如 115 表示连接进行中)。

Swoole 或 ReactPHP 才算真异步,但代价是重构运行环境

如果你真需要事件驱动、协程调度、无回调地狱的异步体验,PHP 原生做不到。必须换运行时:

  • Swoole:用 Swoole\Coroutine\Http\Client,支持 co::sleep()go(function () { ... }),但要求安装 swoole 扩展且不能跑在 Apache mod_php 下
  • ReactPHP:基于事件循环,用 React\Http\Browser 发请求,但整个应用要基于 Loop::run() 启动,传统脚本式写法得重写

常见误判是以为加个 pcntl_fork() 就是异步 —— 那只是多进程,资源开销大、进程间通信麻烦,和异步 I/O 完全是两回事。

真正难的不是写几行并发代码,而是分清「并发」、「并行」、「非阻塞 I/O」和「异步编程模型」的区别。大部分业务场景,curl_multi_exec 足够;想彻底摆脱阻塞,就得接受运行环境变更的成本。

今天关于《php代码示例如何实现异步请求_php异步请求代码示例【示例】》的内容介绍就到此结束,如果有什么疑问或者建议,可以在golang学习网公众号下多多回复交流;文中若有不正之处,也希望回复留言以告知!

资料下载
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>