异常教程

PHP curl_multi_select函数（建议收藏）

更新时间:

💡一则或许对你有用的小广告

欢迎加入小哈的星球 ，你将获得：专属的项目实战(已更新的所有项目都能学习) / 1v1 提问 / Java 学习路线 / 学习打卡 / 每月赠书 / 社群讨论

  • 新开坑项目:《Spring AI 项目实战》 正在持续爆肝中，基于 Spring AI + Spring Boot 3.x + JDK 21...， 点击查看 ;
  • 《从零手撸：仿小红书（微服务架构）》 已完结，基于 Spring Cloud Alibaba + Spring Boot 3.x + JDK 17...，点击查看项目介绍 ;演示链接： http://116.62.199.48:7070 ;
  • 《从零手撸：前后端分离博客项目（全栈开发）》 2 期已完结，演示链接： http://116.62.199.48/ ;

截止目前， 星球 内专栏累计输出 90w+ 字，讲解图 3441+ 张，还在持续爆肝中.. 后续还会上新更多项目，目标是将 Java 领域典型的项目都整一波，如秒杀系统, 在线商城, IM 即时通讯，权限管理，Spring Cloud Alibaba 微服务等等，已有 3100+ 小伙伴加入学习 ，欢迎点击围观

一、前言：为什么需要多线程HTTP请求？

在Web开发中，HTTP请求是数据交互的核心操作。然而，当需要同时发起多个请求（例如爬取多个网页、调用多个API）时，传统的单线程逐个处理方式会显著降低效率。例如，假设每个请求需要1秒完成，发起10个请求就需要10秒。而通过多线程处理，理论上可以将总时间压缩到接近1秒。

PHP的cURL库提供了多线程处理功能，而curl_multi_select函数正是其中关键的“交通指挥官”。它负责管理多个请求的“等待状态”，让PHP程序在等待响应时不会“傻等”，而是可以处理其他任务或继续发起新请求。

本文将从基础概念讲起，通过案例和代码示例，帮助读者理解curl_multi_select的核心作用，以及如何在实际项目中高效使用它。

二、curl多线程处理基础：从单线程到多线程的比喻

1. 单线程的“串行排队”问题

想象一家快餐店，只有一个收银员（单线程）。当顾客（请求）一个接一个排队时，每个顾客的等待时间会叠加。例如，5个顾客各需要1分钟结账，总耗时就是5分钟。

在PHP中，单线程请求的代码示例如下：

// 单线程示例  
$urls = ['https://api1.example.com', 'https://api2.example.com'];  
foreach ($urls as $url) {  
    $ch = curl_init($url);  
    curl_exec($ch);  
    curl_close($ch);  
}

这段代码会依次处理每个URL，无法并行执行。

2. 多线程的“并行工作台”模式

引入多线程后，可以想象快餐店新增多个收银台（多线程）。顾客可以被分配到不同的收银台同时处理，总耗时接近单个请求的时间。

PHP的cURL多线程通过curl_multi_init()创建“多线程池”，并使用curl_multi_add_handle()将多个请求“分配”到不同的“工作台”。

三、curl_multi_select函数详解：多线程的“等待调度器”

1. 函数的核心作用

curl_multi_select函数负责监控所有正在运行的cURL句柄，检测哪些请求已经完成或可以继续处理。它的返回值表示：

  • >0：有句柄已就绪，可以继续处理
  • 0：所有句柄均未就绪，进入等待
  • -1：超时或错误

2. 函数的语法与参数

int curl_multi_select ( resource $mh [, float $timeout = 0.0 ] )
  • $mh：由curl_multi_init()返回的多线程资源
  • $timeout：等待超时时间（单位：秒），默认0表示立即返回

3. 函数的工作流程比喻

将curl_multi_select比作交通信号灯：

  • 当所有请求都在“等待红灯”时（无数据可读/写），它会“暂停”程序，直到有信号（绿灯）
  • 当有请求完成（绿灯亮起），它会通知程序“可以继续处理”

四、完整案例：多线程请求与curl_multi_select的协作

1. 案例目标

同时请求两个API，并输出响应时间：

请求1耗时：0.2秒  
请求2耗时：0.3秒  
总耗时：0.3秒（而非单线程的0.5秒）

2. 分步实现代码

步骤1：初始化多线程

$mh = curl_multi_init();  
$handles = [];  

// 创建两个cURL句柄  
$urls = ['https://api1.example.com', 'https://api2.example.com'];  
foreach ($urls as $url) {  
    $ch = curl_init($url);  
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);  
    curl_multi_add_handle($mh, $ch);  
    $handles[] = $ch;  
}

步骤2：循环等待并处理响应

$running = null;  
do {  
    // 监控句柄状态，等待就绪  
    $status = curl_multi_exec($mh, $running);  

    // 如果仍有未完成的请求，调用curl_multi_select等待  
    if ($running > 0) {  
        curl_multi_select($mh, 1.0); // 超时时间设为1秒  
    }  
} while ($running > 0);

步骤3：获取结果并清理

// 遍历所有句柄获取响应  
foreach ($handles as $ch) {  
    $content = curl_multi_getcontent($ch);  
    $info = curl_getinfo($ch);  
    echo "URL: " . $info['url'] . " 耗时：" . $info['total_time'] . "秒\n";  
    curl_close($ch);  
}  

// 关闭多线程资源  
curl_multi_close($mh);

3. 代码关键点解析

  • curl_multi_exec：执行所有句柄，返回状态码和剩余句柄数
  • curl_multi_select：在等待时“释放”CPU资源，避免忙等
  • 循环结构：通过do...while持续检查请求状态，直到所有完成

五、常见问题与注意事项

1. 为什么需要curl_multi_select？

  • 避免阻塞：若不使用curl_multi_select，程序可能因“忙等”消耗过多CPU资源
  • 超时控制：通过设置$timeout参数，可以避免无限等待

2. 如何调试多线程请求？

在循环中添加日志输出，例如：

do {  
    curl_multi_exec($mh, $running);  
    echo "剩余句柄数：" . $running . "\n";  
    curl_multi_select($mh, 1.0);  
} while ($running > 0);

3. 性能优化建议

  • 合理设置超时时间：避免过长的等待（如设置为0.1秒）
  • 句柄管理：及时关闭不再使用的句柄，避免资源泄漏

六、进阶技巧：结合其他cURL多线程函数

1. curl_multi_info_read：实时获取完成状态

当某个句柄完成时，可以立即获取其结果，而非等待所有完成：

do {  
    $status = curl_multi_exec($mh, $running);  
    if ($status === CURLM_CALL_MULTI_PERFORM) {  
        continue;  
    }  

    // 检查是否有已完成的句柄  
    while ($info = curl_multi_info_read($mh)) {  
        $ch = $info['handle'];  
        $content = curl_multi_getcontent($ch);  
        // 处理响应数据...  
        curl_multi_remove_handle($mh, $ch);  
    }  

    if ($running > 0) {  
        curl_multi_select($mh);  
    }  
} while ($running > 0 && $status === CURLM_OK);

2. 处理超时与错误

通过curl_setopt设置CURLOPT_TIMEOUT和CURLOPT_CONNECTTIMEOUT，并结合curl_error检查异常：

curl_setopt($ch, CURLOPT_TIMEOUT, 5); // 总超时时间5秒  
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 2); // 连接超时2秒  

// 处理错误  
if ($error = curl_error($ch)) {  
    echo "请求出错：" . $error;  
}

七、总结：PHP多线程HTTP请求的高效实践

通过curl_multi_select函数，开发者可以实现：

  • 并行请求：显著减少总响应时间
  • 资源优化：避免CPU因“忙等”而过度占用
  • 灵活控制：通过超时和状态检测提升程序健壮性

在实际项目中，建议：

  1. 从简单案例入手，逐步增加并发数
  2. 使用日志输出监控请求状态
  3. 结合curl_multi_info_read实现实时数据处理

掌握PHP curl_multi_select函数不仅是技术能力的提升，更是对异步编程思维的深刻理解。通过合理运用多线程技术，开发者可以构建出更高效、更可靠的网络交互系统。

（全文约1800字）

最新发布

查看更多文章