PHP中伪多线程与多进程的模拟及并发处理方案

PHP中的“伪多线程”实现

首先需要明确，PHP本身不支持真正意义上的多线程（即单个进程中拥有多个OS级别的线程）。但在实际开发中，我们经常需要并行处理任务以节省时间。所谓的“伪多线程”，其实是利用了Web服务器的并发处理能力。当用户访问一个PHP页面时，如果程序在后台发起一个新的HTTP请求去调用另一个脚本，服务器会将其视为独立的请求进行处理。虽然这两个过程在当前脚本看来是同步发出的，但实际上它们可能在不同的子进程中并行运行。

原理：利用Web服务器并发

当我们从a.php通过socket向localhost发送一个请求调用b.php时，只要客户端不强制断开连接，Web服务器就会启动另一个进程来处理b.php。此时a.php和b.php可以同时执行。

操作步骤：

1. 准备测试环境：确保服务器支持PHP且已配置好基本的Web服务（如Apache或Nginx）。
2. 编写调度逻辑：使用fsockopen创建一个非阻塞的连接，向本地端口80发送HTTP GET/POST请求。注意，发送完毕后立即关闭连接或不读取返回结果，以确保当前主程序不会等待响应而阻塞。
3. 参数分发：在被调用的脚本（如b.php）中，通过$_GET参数判断具体要执行哪一段业务逻辑。

示例代码与对比验证

以下代码演示了如何在一个文件中同时触发两个任务的执行。

<?php
// 模拟“伪多线程”调度函数
function runThread() {
    // 使用fsockopen向自身发送请求，触发另一段代码执行
    $fp = fsockopen('localhost', 80, $errno, $errmsg);
    if ($fp) {
        // 构造HTTP请求头
        fputs($fp, "GET /test_pseudo_thread.php?act=task_b HTTP/1.1\r\n");
        fputs($fp, "Host: localhost\r\n");
        fputs($fp, "Connection: Close\r\n\r\n");
        fclose($fp);
        // 关键：不读取返回数据，让主程序继续向下执行
    }
}

// 主任务 A
function task_a() {
    $file = fopen('result_a.log', 'w');
    fwrite($file, "Task A executed at: " . date('h:i:s') . " - Microtime: " . microtime() . "\n");
    fclose($file);
}

// 任务 B （被远程触发）
if (isset($_GET['act']) && $_GET['act'] == 'task_b') {
    $file = fopen('result_b.log', 'w');
    fwrite($file, "Task B executed at: " . date('h:i:s') . " - Microtime: " . microtime() . "\n");
    fclose($file);
    exit(); // 结束该次请求
}

// 主程序入口
if (!isset($_GET['act'])) {
    echo "Starting parallel tasks...\n";
    runThread();      // 触发B任务（后台异步）
    task_a();         // 执行A任务（前台同步）
    echo "Tasks dispatched.\n";
}
?>

检查生成的result_a.log和result_b.log，你会发现它们的写入时间戳非常接近甚至相同，证明了它们在服务器层面是并发执行的。这种方法常用于爬虫抓取多个独立网页资源，以解决网络IO等待带来的耗时问题。

伪多线程的局限与同步

由于没有真正的线程同步机制（如Java的synchronized），在处理共享资源时需格外小心：

• 文件冲突：避免多个并发进程同时写入同一个文件。如果必须写，请使用flock()进行文件加锁，或使用临时文件并在主程序中轮询等待其消失。
• 通信困难：fsockopen通常用于单向通知。若需获取子任务的结果，不建议在主流程中直接读取Socket返回（这会变成阻塞模式，丧失并发意义），而是应通过数据库、文件或消息队列等外部介质进行数据交换。

Linux/Unix下的真·多进程方案：PCNTL扩展

在命令行（CLI）环境下，PHP提供了pcntl扩展，允许使用pcntl_fork()创建真正的子进程。这是最正统的多进程并发方式，但不适用于Web服务器环境（可能导致进程失控）。

操作前准备

1. 系统要求：必须在Linux/Unix-like系统上运行，Windows不支持此功能。
2. 编译安装：编译PHP时必须添加--enable-pcntl选项。
3. 运行环境：强烈建议仅在CLI模式下使用，严禁在Web Server（如FPM/Apache模块）中使用，否则无法控制产生的僵尸进程。

步骤与代码实现

第1步：启用信号处理
为了正确处理子进程退出后的状态，建议在脚本开头设置时钟节拍：

declare(ticks=1); // 每执行一条低级语句就检查一次信号，通常用于信号处理，此处也可省略，视具体需求而定

第2步：创建子进程循环
使用pcntl_fork()克隆当前进程。该函数在父进程中返回子进程PID，在子进程中返回0。我们需要根据返回值区分父子进程的执行路径。

$intNum = 5; // 并发进程数
$pids = array();
echo "Start creating processes...\n";

for ($i = 0; $i < $intNum; $i++) {
    $pid = pcntl_fork();
    
    if ($pid == -1) {
        die("Could not fork!");
    } elseif ($pid) {
        // 父进程：保存PID数组
        $pids[] = $pid;
    } else {
        // 子进程：执行具体任务
        // 注意：子进程继承父进程的数据拷贝，互不影响
        sleep($i + 1); // 模拟不同耗时的任务
        echo "Child Process $i finished at: " . time() . "\n";
        exit(0);       // 子进程必须exit，否则会执行父进程剩余代码
    }
}

第3步：同步等待（可选）
如果不希望父进程过早退出，可以使用pcntl_waitpid()等待特定子进程结束，或者在循环中等待所有子进程完成，避免产生孤儿进程。

// 同步等待所有子进程
foreach ($pids as $pid) {
    pcntl_waitpid($pid, $status, WUNTRACED);
    echo "Waited for process $pid\n";
}
echo "All processes completed.\n";

跨平台兼容方案：Popen与Proc_open

对于未开启pcntl或未部署在Linux环境的场景，可以使用popen()或proc_open()来实现类似并发的效果。这些函数基于底层的C库API，在某些平台上兼容性更好。

Popen并发执行Shell命令

popen()可以打开一个指向进程的管道。我们可以通过同时打开多个只读或只写管道，来并行执行多个PHP子脚本。

// 假设有一个子脚本 sub_task.php
$handle1 = popen('php sub_task.php --arg=1', 'r');
$handle2 = popen('php sub_task.php --arg=2', 'r');
$handle3 = popen('php sub_task.php --arg=3', 'r');

echo "Main script launched tasks...\n";

// 循环读取输出，直到所有进程结束
while (!feof($handle1) || !feof($handle2) || !feof($handle3)) {
    $output1 = fgets($handle1);
    $output2 = fgets($handle2);
    $output3 = fgets($handle3);
    
    if ($output1 !== false) echo $output1;
    if ($output2 !== false) echo $output2;
    if ($output3 !== false) echo $output3;
}

// 关闭管道
pclose($handle1);
pclose($handle2);
pclose($handle3);

优点：不需要额外的PCNTL扩展，且在Windows下部分版本的支持较好（取决于PHP环境）。实现了并发启动和输出收集。

缺点：句柄是单向的（只能读或只能写），如果要双向交互数据，需要使用更复杂的proc_open()；管理大量管道句柄时需要良好的数据结构支持，否则容易遗漏。

总结

PHP虽无原生线程，但通过合理利用操作系统的特性，完全可以实现高性能的并发处理：

1. 伪多线程（Fsockopen/Web Server）：适合Web环境下简单的后端任务分发，无需特殊权限，但同步和数据回传困难。
2. PCNTL多进程：Linux CLI环境下的首选方案，功能强大，支持完善的信号处理和进程同步，适合复杂的高并发计算。
3. Popen/Proc_open：适合跨平台或对系统底层依赖较低的场景，通过管道并发执行外部命令或子脚本。

在选择方案时，请充分考虑运行环境、是否需要结果回传以及资源的并发安全性。以上就是PHP中(伪)多线程与多进程实现的详细内容，更多关于PHP并发编程的资料请关注本站其它相关文章！