PHP curl_multi_init函数（建议收藏）

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

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

• 新项目:《从零手撸：仿小红书（微服务架构）》 正在持续爆肝中，基于 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+ 小伙伴加入学习 ，欢迎点击围观

引言：从单线程到多线程的性能跃迁

在PHP开发中，HTTP请求是与外部服务交互的核心操作。传统的单线程cURL请求虽然简单易用，但当需要同时发起多个请求时，其效率瓶颈便显露无疑。例如，若需同时获取5个API接口的数据，单线程方式会逐个执行，总耗时等于各请求耗时之和。而curl_multi_init函数的出现，正是为了解决这一问题，它通过多线程机制让多个请求并行执行，显著提升程序响应速度。

本文将从基础概念、实现原理到实战案例，系统讲解如何利用curl_multi_init优化PHP程序的网络请求性能，并通过对比实验验证其优势。

一、单线程请求的痛点与多线程的解决方案

1.1 单线程请求的局限性

以电商系统为例，假设需要同时获取商品详情、库存状态、用户评价三个接口的数据：

// 单线程请求示例
function fetch_data_single() {
    $ch1 = curl_init('https://api.example.com/product');
    curl_setopt($ch1, CURLOPT_RETURNTRANSFER, true);
    $product = curl_exec($ch1);
    curl_close($ch1);

    $ch2 = curl_init('https://api.example.com/stock');
    $stock = curl_exec($ch2);
    curl_close($ch2);

    $ch3 = curl_init('https://api.example.com/reviews');
    $reviews = curl_exec($ch3);
    curl_close($ch3);
    return [$product, $stock, $reviews];
}

上述代码中，三个请求必须按顺序执行，总耗时为三个API响应时间的总和。若每个接口平均耗时1秒，则总耗时3秒。

1.2 多线程请求的核心价值

curl_multi_init通过创建一个"请求管理器"，允许将多个cURL句柄（handles）添加到同一管理器中并行执行。这就像同时派发多个快递员，让他们各自前往不同地址取件，最终统一回收包裹。其核心优势在于：

• 时间并行：多个请求同时发起，耗时由最长单个请求决定
• 资源复用：共享底层的网络连接和内存资源
• 异步处理：可结合事件循环实现非阻塞操作

二、curl_multi_init函数的核心用法

2.1 基础语法与执行流程

函数原型：

resource curl_multi_init()  

使用流程分为5个关键步骤：

1. 初始化多线程句柄
2. 添加多个cURL句柄
3. 执行请求循环
4. 获取响应结果
5. 清理资源

示例代码：同步多线程请求

function fetch_data_multi() {
    // 1. 初始化多线程句柄
    $mh = curl_multi_init();

    // 2. 创建并添加多个cURL句柄
    $urls = [
        'product' => 'https://api.example.com/product',
        'stock' => 'https://api.example.com/stock',
        'reviews' => 'https://api.example.com/reviews',
    ];
    $handles = [];
    foreach ($urls as $key => $url) {
        $ch = curl_init($url);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_multi_add_handle($mh, $ch);
        $handles[$key] = $ch;
    }

    // 3. 执行请求循环
    do {
        $status = curl_multi_exec($mh, $active);
    } while ($active > 0);

    // 4. 获取响应结果
    $responses = [];
    foreach ($handles as $key => $ch) {
        $responses[$key] = curl_multi_getcontent($ch);
        curl_multi_remove_handle($mh, $ch);
        curl_close($ch);
    }

    // 5. 清理资源
    curl_multi_close($mh);
    return $responses;
}

注意：curl_multi_exec()会阻塞脚本直到所有请求完成，若需非阻塞异步处理，需结合curl_multi_select()实现事件驱动。

2.2 关键函数详解

三、深度解析：多线程请求的底层原理

3.1 非阻塞I/O模型的实现

curl_multi_init基于事件驱动模型工作，其核心是通过curl_multi_select()函数监听多个文件描述符的状态变化。当某个请求完成时，系统会触发回调，从而实现资源的高效利用。

对比单线程与多线程的性能差异

假设三个接口的响应时间分别为：

• 商品接口：2秒
• 库存接口：1秒
• 评价接口：3秒

3.2 响应处理的三种模式

1. 同步阻塞模式
   通过curl_multi_exec()持续轮询直到所有请求完成，适用于简单场景。

2. 异步非阻塞模式
   结合curl_multi_select()实现事件循环，示例代码：

do {
    $status = curl_multi_exec($mh, $active);
    if ($status == CURLM_CALL_MULTI_PERFORM) {
        continue;
    }
    if ($active > 0) {
        curl_multi_select($mh);
    }
} while ($active && $status == CURLM_OK);

3. 回调通知模式
   通过设置CURLOPT_HEADERFUNCTION和CURLOPT_WRITEFUNCTION实现响应分块处理，适合大文件下载等场景。

四、实战案例：电商系统多API并行查询

4.1 场景描述

假设需要同时查询商品信息、库存状态和用户评价，且各接口响应时间分别为：

• 商品接口：平均200ms
• 库存接口：平均150ms
• 评价接口：平均250ms

4.2 代码实现

// 多线程版本
function fetch_parallel() {
    $mh = curl_multi_init();
    $urls = [
        'product' => 'https://api.example.com/product',
        'stock' => 'https://api.example.com/stock',
        'reviews' => 'https://api.example.com/reviews',
    ];
    $handles = [];
    foreach ($urls as $key => $url) {
        $ch = curl_init($url);
        curl_setopt_array($ch, [
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_CONNECTTIMEOUT => 5,
            CURLOPT_TIMEOUT => 10,
        ]);
        curl_multi_add_handle($mh, $ch);
        $handles[$key] = $ch;
    }

    // 执行循环
    $running = null;
    do {
        $status = curl_multi_exec($mh, $running);
    } while ($status === CURLM_CALL_MULTI_PERFORM || $running > 0);

    // 获取结果
    $result = [];
    foreach ($handles as $key => $ch) {
        $result[$key] = [
            'data' => curl_multi_getcontent($ch),
            'info' => curl_getinfo($ch),
        ];
        curl_multi_remove_handle($mh, $ch);
        curl_close($ch);
    }
    curl_multi_close($mh);
    return $result;
}

4.3 性能对比测试

五、进阶技巧与常见问题

5.1 请求超时与错误处理

// 设置全局超时
curl_setopt($ch, CURLOPT_TIMEOUT, 5); // 总超时时间
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 3); // 连接超时时间

// 错误检测
do {
    $status = curl_multi_exec($mh, $running);
    if ($status === CURLM_OK) {
        foreach ($handles as $ch) {
            $errno = curl_errno($ch);
            if ($errno) {
                echo "Error: " . curl_error($ch);
            }
        }
    }
} while ($status === CURLM_OK && $running > 0);

5.2 资源管理最佳实践

• 每个请求完成后立即移除句柄（curl_multi_remove_handle）
• 使用curl_multi_info_read()获取已完成的句柄
• 对大量并发请求，可限制同时活跃的连接数（curl_multi_setopt($mh, CURLMOPT_MAXCONNECTS, 5)）

六、总结：多线程请求的最佳应用场景

curl_multi_init函数在以下场景中能显著提升PHP程序性能：

1. 需要并行获取多个外部接口数据的聚合服务
2. 实时数据采集系统（如价格监控、舆情分析）
3. API网关中需要批量处理的请求路由

但需注意其局限性：

• 不适用于需要严格顺序执行的场景
• 需谨慎处理高并发下的资源竞争
• 部分服务器配置可能限制同时打开的连接数

掌握curl_multi_init的正确使用方法，能够帮助开发者在PHP项目中实现高效、稳定的网络通信，尤其在微服务架构和API集成场景中具有重要价值。