PHP多进程并行执行脚本：使用pcntl_fork实现

原理与目标

PHP的多进程方案核心在于“分而治之”。主进程（父进程）负责生成任务队列并fork出多个子进程，每个子进程通过pcntl_exec加载新的PHP解释器并执行特定的业务脚本。这样，多个相同的PHP脚本实例可以同时运行，共享CPU时间片，从而显著缩短整体处理时间。

准备条件

• 服务器环境为Linux或Unix系统（Windows环境下不支持pcntl扩展）。
• PHP编译安装时必须启用pcntl扩展。
• 具备可执行的PHP脚本路径及对应的业务逻辑文件。

真实操作顺序

第1步：定义任务命令队列

首先，我们需要将所有需要并行执行的指令组织成一个二维数组。每个子数组代表一个独立的执行命令及其参数。在实际生产中，建议根据服务器负载合理控制任务数量，避免资源耗尽。

#!/usr/bin/env php
<?php
$cmds = array(
    array('/apps/bin/launcher.php', 'charge/promotion_props_stat.php', 'mobile', 1),
    array('/apps/bin/launcher.php', 'charge/promotion_props_stat.php', 'mobile', 2),
    array('/apps/bin/launcher.php', 'charge/promotion_props_stat.php', 'click', 1),
    array('/apps/bin/launcher.php', 'charge/promotion_props_stat.php', 'click', 2),
    array('/apps/bin/launcher.php', 'charge/promotion_props_stat.php', 1),
    array('/apps/bin/launcher.php', 'charge/promotion_props_stat.php', 2)
);

上述代码定义了6个不同的任务场景，分别针对mobile、click等不同渠道及批次进行统计。

第2步：遍历任务并创建子进程

通过foreach循环遍历任务列表，对每个任务调用pcntl_fork()。pcntl_fork()会返回三个值：-1表示失败，正整数表示父进程中获取的子进程ID（PID），0表示当前位于子进程中。

第3步：父进程与子进程的逻辑分离

根据pcntl_fork的返回值，我们需要编写分支逻辑来处理不同角色的任务：

• 父进程（$pid > 0）：主要负责清理僵尸进程以释放资源。这里使用pcntl_wait($status, WNOHANG)非阻塞地等待子进程结束。注意：在生产环境中，建议记录所有子进程PID并在最后统一使用waitpid或信号量进行管理，简单的WNOHANG轮询适合轻量级测试场景。
• 子进程（$pid == 0）：使用pcntl_exec()替换当前进程的执行映像。它将加载指定的PHP二进制文件和脚本来执行具体业务。

完整代码实现

将上述步骤整合，形成完整的控制脚本。请注意备份重要数据，因为进程创建失败直接会导致服务中断。

foreach ($cmds as $cmd) {
    // 创建新进程
    $pid = pcntl_fork();
    
    if ($pid == -1) {
        // 进程创建失败
        die('fork child process failure!');
    } else if ($pid) {
        // 父进程逻辑
        // 非阻塞式等待子进程退出，防止产生僵尸进程
        pcntl_wait($status, WNOHANG);
    } else {
        // 子进程逻辑
        // 执行具体的PHP脚本，替换当前进程内存
        pcntl_exec('/usr/local/bin/php', $cmd);
    }
}

完成判断与排错

完成判断：脚本运行后，通过ps aux | grep php可以看到多个处于S(睡眠)或R(运行)状态的PHP进程，且PID各不相同，即表示多进程并行已生效。

常见排错： - 如果遇到“Call to undefined function pcntl_fork()”错误，请检查php.ini是否启用了extension=pcntl.so。 - WNOHANG模式下父进程可能不会等待子进程完全结束就退出，若需确保任务全部完成，建议在循环结束后增加while (count(get_defined_vars()['pid_list'] ?? []) > 0) { pcntl_wait($status); }等更严谨的资源回收机制。

简要总结

本文展示了如何利用PHP原生能力解决单线程限制问题。通过pcntl_fork拆分任务，配合pcntl_exec隔离执行环境，实现了高效的批量处理。对于大规模数据处理场景，这是一种经典且有效的解决方案。以上就是PHP实现多进程并行执行脚本的详细内容，更多关于PHP多进程优化的资料请关注本站其它相关文章！