PHP多进程编程：pcntl扩展实战教程

PHP实现多进程编程的核心是pcntl扩展，通过pcntl_fork()创建子进程，使程序具备并发执行能力；2. 父进程通过返回的子进程PID进行管理，子进程返回0并执行独立逻辑，需调用exit(0)避免继续执行父进程代码；3. 多进程适用于CPU密集型、I/O密集型、高隔离性要求及长生命周期服务场景，相比多线程更稳定且易于维护；4. 常见陷阱包括僵尸进程（需用pcntl_waitpid或信号处理器回收）、资源句柄继承问题（子进程应重新建立数据库连接）、信号处理（注册SIGTERM等信号实现优雅退出）和日志混乱（建议每个进程独立日志文件）；5. 进程间通信（IPC）方式包括：信号（用于简单通知）、管道（父子进程间流式通信）、共享内存（高效但需同步机制如信号量）、套接字（灵活支持本地或跨机器通信）；6. 应根据数据量、通信频率、是否跨机器等因素选择合适的IPC方式，可组合使用以满足复杂需求。PHP多进程编程通过合理使用pcntl及相关技术，能够有效提升程序并发能力和系统级处理效率，是一种强大且实用的编程模式。

PHP实现多进程编程，核心在于利用pcntl（Process Control）扩展。这个扩展提供了一系列类Unix系统调用，比如fork，允许PHP脚本创建子进程，从而实现并发执行任务。这对于处理耗时操作、构建后台守护进程或需要高并发处理的场景来说，是一种非常有效的手段，它让PHP跳出了传统Web请求的单线程、短生命周期限制，具备了更强大的系统编程能力。

解决方案

要让PHP程序拥有“分身术”，pcntl_fork()是那个关键的咒语。当你调用它时，当前进程会一分为二，变成一个父进程和一个子进程。它们几乎拥有相同的代码、内存空间副本（写时复制），但在pcntl_fork()的返回值上有所不同：父进程会得到子进程的PID（进程ID），而子进程则会得到0。正是通过这个返回值，我们才能区分父子进程，让它们执行不同的逻辑。

这段代码展示了最基本的fork用法。父进程创建子进程后，可以继续自己的工作，或者像示例中那样，等待子进程完成。子进程则执行自己的任务，并在完成后显式exit(0)，这至关重要，否则它会继续执行父进程的代码，导致意想不到的行为。

PHP多进程与多线程：如何选择与适用场景？

在PHP里谈到并发，很多人会自然而然地想到多线程。但说实话，PHP原生对多线程的支持，嗯，挺有限的。虽然有像pthreads这样的扩展，但它对PHP版本、编译环境要求高，且因为PHP的“写时复制”特性，共享内存的复杂性不小，维护起来也相对麻烦。所以，对于大多数PHP应用，尤其是那些需要稳定、高效并发处理的场景，多进程（pcntl）往往是更实际、更稳妥的选择。

什么时候用多进程呢？我个人觉得，当你的任务符合以下特点时，pcntl的优势就凸显出来了：

1. CPU密集型任务：比如大量的数据计算、图像处理、视频转码等。多进程可以充分利用多核CPU，每个进程独立跑在不同的核心上，互不干扰。
2. I/O密集型任务：虽然多进程在I/O等待时会阻塞，但你可以创建多个子进程同时发起I/O请求（比如同时请求多个API接口、同时处理多个文件），从而提高整体吞吐量。
3. 需要高隔离性：每个子进程都有独立的内存空间。这意味着一个子进程崩溃了，通常不会影响到其他子进程或父进程。这对于构建健壮的后台服务非常有利。
4. 长生命周期服务：比如消息队列消费者、定时任务调度器、守护进程等。这些服务需要长时间运行，多进程模型可以更好地管理它们的生命周期和资源。

相比之下，多线程的优势在于共享内存带来的通信便利和更低的创建销毁开销。但在PHP中，由于Zend引擎的设计，变量的共享和同步是个大挑战，往往需要复杂的锁机制来避免数据竞争，这无形中增加了开发和调试的难度。所以，如果你不是对性能有极致要求，且明确知道如何处理共享内存的复杂性，否则，多进程通常是更“接地气”的选择。

避免PHP多进程编程中的常见陷阱

多进程编程听起来很酷，但实际操作起来，坑也不少。这些坑踩不好，轻则程序异常，重则系统资源耗尽。

一个最常见的坑就是僵尸进程。子进程结束了，但它的父进程没有调用pcntl_waitpid()或pcntl_wait()来回收它的资源，那么这个子进程就会变成一个“僵尸”，它虽然不占CPU，但会一直占用一个进程号，直到父进程退出或被回收。如果你的程序大量创建子进程又不回收，很快就会把系统进程表占满。解决办法很简单：父进程要么周期性地调用pcntl_waitpid()（非阻塞模式WNOHANG），要么注册信号处理器（比如SIGCHLD），在子进程结束时自动回收。

// 僵尸进程处理示例（父进程注册SIGCHLD信号处理器）
pcntl_signal(SIGCHLD, function() {
    // 循环回收所有已结束的子进程，直到没有更多子进程需要回收
    while (($pid = pcntl_waitpid(-1, $status, WNOHANG)) > 0) {
        echo "回收了僵尸子进程: " . $pid . "\n";
    }
});

另一个需要注意的点是资源句柄的继承问题。当你fork一个进程时，子进程会继承父进程打开的文件句柄、数据库连接等。这看起来很方便，但如果父进程和子进程都去操作同一个文件句柄或数据库连接，就可能出现竞争或意外行为。正确的做法是，在子进程中，应该重新建立自己的数据库连接、重新打开文件句柄。尤其对于数据库连接，子进程在fork之后，应该立即关闭继承的连接，然后重新建立新的连接。否则，可能会遇到“MySQL server has gone away”或者连接池耗尽的问题。

还有就是信号处理。在多进程环境中，信号是进程间通信的一种方式，也是管理进程生命周期（比如优雅退出）的重要工具。你需要为SIGTERM、SIGINT等信号注册处理器，让进程在收到这些信号时能平稳地关闭，而不是突然崩溃。

最后，别忘了日志记录。在多进程环境中，每个子进程都可能独立地产生日志。如果你简单地都写入同一个文件，可能会出现日志混乱甚至文件损坏。一个好的实践是，让每个子进程写入自己的日志文件，或者使用支持并发写入的日志系统（如syslog）。

PHP多进程通信（IPC）的几种实现方式

如果你的子进程只是各自干活，互不影响，那还好说。但很多时候，进程之间需要协作，需要交换数据，这就涉及到进程间通信（IPC）。PHP里有几种常见的IPC方式，各有优缺点。

1. 信号（Signals）：最简单，但能传递的信息量极少，通常只能用来通知某个事件发生。比如父进程可以发SIGUSR1给子进程，通知它重新加载配置。pcntl_signal()和posix_kill()是主要函数。

   // 父进程发送信号给子进程
   posix_kill($child_pid, SIGUSR1);
   
   // 子进程注册信号处理器
   pcntl_signal(SIGUSR1, function($signo) {
       echo "子进程收到信号: " . $signo . "，准备重新加载配置。\n";
       // 实际的配置加载逻辑
   });
   // 在循环中需要调用pcntl_signal_dispatch()来处理待处理的信号
   // while(true) { pcntl_signal_dispatch(); sleep(1); }

2. 管道（Pipes）：分为匿名管道和命名管道。匿名管道通常用于父子进程之间，单向通信。命名管道（FIFO）则可以用于不相关的进程之间。管道的特点是数据流式传输，先进先出。在PHP里，你可以通过proc_open()创建的管道进行读写。这在处理子进程的输入输出时非常有用。

3. 共享内存（Shared Memory）：这是效率最高的一种IPC方式，多个进程可以访问同一块物理内存区域。PHP提供了shmop和sysvshm扩展来操作共享内存。使用共享内存时，最关键的是要处理好同步问题，避免数据竞争，通常需要配合信号量（semaphores）或文件锁来确保数据一致性。

   // 共享内存示例（需要sysvshm扩展）
   // $shm_key = ftok(__FILE__, 't'); // 生成一个唯一的key
   // $shm_id = shm_attach($shm_key, 1024, 0666); // 附加到共享内存
   // shm_put_var($shm_id, 1, "Hello from parent"); // 写入数据
   // $data = shm_get_var($shm_id, 1); // 读取数据
   // shm_detach($shm_id); // 分离共享内存

   共享内存虽然快，但复杂性也高，不适合传递复杂的数据结构，通常需要序列化/反序列化。

4. 套接字（Sockets）：包括Unix域套接字（Unix Domain Sockets）和TCP/IP套接字。Unix域套接字适用于同一台机器上的进程间通信，比TCP/IP套接字效率更高。TCP/IP套接字则可以实现跨机器的进程通信。这是最灵活也最常用的一种IPC方式，可以传递任意复杂的数据，但需要自行处理协议和数据包的解析。在PHP中，你可以用socket_create()等函数来创建和操作套接字。

选择哪种IPC方式，取决于你的具体需求：数据量大小、通信频率、是否需要跨机器通信、以及对复杂度的接受程度。对于简单的通知，信号就够了；对于大量结构化数据交换，套接字或共享内存可能更合适。当然，你也可以结合使用，比如用信号通知，用套接字传递数据。