PHP最新版怎么用Hyperf导入数据_PHP最新版怎么用Hyperf导入数据【协程】-php教程-PHP中文网

hyperf 在 php 8.1+ 协程下 excel 导入的核心难点是 phpspreadsheet 的同步 io 阻塞协程调度，需禁用 opcache.enable_cli、排除 swoole_hook_file、流式读取、手动 gc 及优先使用 csv。

php最新版怎么用hyperf导入数据_php最新版怎么用hyperf导入数据【协程】

Hyperf 在 PHP 8.1+（尤其是 8.2/8.3）下做 Excel 导入，核心难点不是“能不能用”，而是协程环境下 PhpSpreadsheet 的 IO 阻塞会直接拖垮整个协程调度 —— 它默认所有文件读取都走同步 fopen/fread，不兼容 Swoole 协程 Hook。

为什么 PhpSpreadsheet 在 Hyperf 协程里容易卡死或内存暴涨

常见错误现象：IOFactory::load($path) 调用后响应超时、worker 进程 CPU 100%、导入大文件（>5MB）时内存溢出（OOM）。

根本原因：

PhpSpreadsheet 内部大量使用 file_get_contents、fopen 等原生 PHP 文件函数，即使 Swoole 开启了 SWOOLE_HOOK_FILE，部分底层 ZIP 解压逻辑（如 ZipArchive）仍无法完全协程化
Excel 文件（尤其是 .xlsx）需解压 + 解析 XML + 构建内存对象树，单次导入常驻内存达几十 MB，协程间无法 GC 共享，反复调用易堆积
Hyperf 默认未禁用 opcache.enable_cli=1，而 PhpSpreadsheet 的动态类加载在 CLI 模式下与 opcache 冲突，引发 Class not found 或解析失败

必须关闭的配置和必须加的参数

不改这些，哪怕代码写对也大概率失败。

在 php.ini 或 bin/hyperf.php 启动前强制关闭：ini_set('opcache.enable_cli', '0');
确保 Swoole\Runtime::enableCoroutine(true, SWOOLE_HOOK_ALL & ~SWOOLE_HOOK_FILE); —— 显式排除 SWOOLE_HOOK_FILE，避免 Hook 干扰 ZipArchive
导入前调用 gc_disable();，导入完成后立即 gc_collect_cycles();，防止临时对象滞留
对 IOFactory::load() 加超时控制：用 set_time_limit(60) 或封装为 pcntl_alarm（仅 CLI 场景），避免单次卡死阻塞整个进程

推荐的导入方式：流式读取 + 分块处理

不要用 getActiveSheet()->toArray() 一次性载入全量数据 —— 这是协程环境下的最大陷阱。

正确做法是用 WorksheetIterator + RowIterator 流式遍历，边读边处理：

PHP 8.5.5

PHP 8.5.5 是 PHP 8.5 分支的维护更新版本。该版本延续了“小步快跑”的迭代逻辑，通过深度错误修复、底层性能微调以及安全加固，旨在为开发者提供一个更健壮、更高效的运行环境。该版本严格遵守语义化版本规范，不包含破坏性变更。

下载

$reader = IOFactory::createReader('Xlsx');
$reader->setReadDataOnly(true); // 关键：跳过样式、公式等无用元数据
$spreadsheet = $reader->load($uploadedFile->getPathname());
$worksheet = $spreadsheet->getActiveSheet();

// 从第二行开始（跳过表头）
$highestRow = $worksheet->getHighestRow();
for ($row = 2; $row getHighestColumn()) as $column) {
        $cellValues[] = $worksheet->getCell($column . $row)->getValue();
    }
    // 此处插入你的业务逻辑，例如入库、校验、投递到协程任务池
    // 注意：不要在此处做耗时 DB 写入，应投递给 hyperf/task 或 go() 异步处理
}

关键点：

setReadDataOnly(true) 可降低 60%+ 内存占用
避免调用 getCellByColumnAndRow()，它比 getCell('A1') 慢 3 倍以上
若需校验格式（如日期、数字），用 getDataType() 判断类型，而非 is_numeric() 字符串判断
每 100 行手动触发一次 gc_collect_cycles()，防内存缓存累积

更安全的替代方案：用 csv 替代 xlsx

如果业务允许，优先让用户上传 .csv。它没有 ZIP 解压开销，纯文本流式读取天然协程友好。

示例（配合 Hyperf 的 SwooleStream）：

$stream = new SwooleStream($uploadedFile->getPathname(), 'r');
while ($line = $stream->readLine()) {
    $row = str_getcsv($line, ',', '"'); // 自动处理带引号的字段
    // 校验、转换、入库...
}

优势：