从0到1优雅的实现PHP多进程管理

_        
                      | |       
_ __   __ _ _ __ _   _| |_ ___  
| '_ \ / _` | '__| | | | __/ _ \ 
| | | | (_| | |  | |_| | || (_) |
|_| |_|\__,_|_|   \__,_|\__\___/ .TIGERB.cn
			
An object-oriented multi process manager for PHP

复制代码

业务场景

在咱们实际的业务场景中(PHP技术栈)，咱们可能须要定时或者近乎实时的执行一些业务逻辑，简单的咱们可使用unix系统自带的crontab实现定时任务，可是对于一些实时性要求比较高的业务就不适用了，因此咱们就须要一个常驻内存的任务管理工具，为了保证明时性，一方面咱们让它一直执行任务(适当的睡眠，保证cpu不被100%占用)，另外一方面咱们实现多进程保证并发的执行任务。

目的

综上所述，个人目标就是：实现基于php-cli模式实现的master-worker多进程管理工具。其次，“我有这样一个目标，我是怎样一步步去分析、规划和实现的”，这是本文的宗旨。

备注：下文中，父进程统称为master,子进程统称为worker。

分析

咱们把这一个大目标拆成多个小目标去逐个实现，以下：

• 多进程
  • 目的：一个master fork多个worker
  • 现象：全部worker的ppid父进程ID为当前master的pid
• master控制worker
  • 目的：master通知worker，worker接收来自master的消息
• master接收信号
  • 目的：master接收并自定义处理来自终端的信号

多进程

PHP fork进程的方法 pcntl_fork, 这个你们应该有所了解，若是不知道的简单google/bing一下应该很容易找到这个函数。接着FTM, 咱们看看pcntl_fork这个函数的使用方式大体以下：

$pid = pcntl_fork(); // pcntl_fork 的返回值是一个int值
                     // 若是$pid=-1 fork进程失败
                     // 若是$pid=0 当前的上下文环境为worker
                     // 若是$pid>0 当前的上下文环境为master，这个pid就是fork的worker的pid
复制代码

接着看代码：

$pid = pcntl_fork();	
switch ($pid) {
  case -1:
    // fatal error 致命错误 全部进程crash掉
    break;

  case 0:
    // worker context
    exit; // 这里exit掉，避免worker继续执行下面的代码而形成一些问题
    break;

  default:
    // master context
    pcntl_wait($status); // pcntl_wait会阻塞，例如直到一个子进程exit
    // 或者 pcntl_waitpid($pid, $status, WNOHANG); // WNOHANG:即便没有子进程exit，也会当即返回
    break;
}
复制代码

咱们看到master有调用pcntl_wait或者pcntl_waitpid函数，为何呢？首先咱们在这里得提到两个概念，以下：

• 孤儿进程：父进程挂了，子进程被pid=1的init进程接管(wait/waitpid)，直到子进程自身生命周期结束被系统回收资源和父进程采起相关的回收操做
• 僵尸进程：子进程exit退出,父进程没有经过wait/waitpid获取子进程状态，子进程占用的进程号等描述资源符还存在，产生危害：例如进程号是有限的，没法释放进程号致使将来可能无进程号可用

因此，pcntl_wait或者pcntl_waitpid的目的就是防止worker成为僵尸进程(zombie process)。

除此以外咱们还须要把咱们的master挂起和worker挂起，我使用的的是while循环，而后usleep(200000)防止CPU被100%占用。

最后咱们经过下图(1-1)来简单的总结和描述这个多进程实现的过程：

master控制worker

上面实现了多进程和多进程的常驻内存，那master如何去管理worker呢？答案：多进程通讯。话很少说google/bing一下，如下我列举几种方式：

• 命名管道: 感兴趣
• 队列: 我的感受和业务中使用redis作消息队列思路应该一致
• 共享内存: 违背“不要经过共享内存来通讯，要经过通讯来实现共享”原则
• 信号: 承载信息量少
• 套接字: 不熟悉

因此我选择了“命名管道”的方式。我设计的通讯流程大体以下：

• step 1: 建立worker管道
• step 2: master写消息到worker管道
• step 3: worker读消息从worker管道

接着仍是逐个击破，固然话很少说仍是google/bing一下。posix_mkfifo建立命名管道、fopen打开文件(管道以文件形式存在)、fread读取管道、fclose关闭管道就呼啸而出，哈哈，这样咱们就能很容易的实现咱们上面的思路的了。接着说说我在这里遇到的问题：fopen阻塞了，致使业务代码没法循环执行，一想不对啊，日常fopen普通文件不存在阻塞行为,这时候二话不说FTM搜fopen,crtl+f页面搜“block”，重点来了：

fopen() will block if the file to be opened is a fifo. This is true whether it's opened in "r" or "w" mode. (See man 7 fifo: this is the correct, default behaviour; although Linux supports non-blocking fopen() of a fifo, PHP doesn't).

翻译下，大概意思就是“当使用fopen的r或者w模式打开一个fifo的文件，就会一直阻塞;尽管linux支持非阻塞的打开fifo，可是php不支持。”，得不到解决方案，不支持，感受要放弃，一想这种场景应该不会不支持吧，再去看看posix_mkfifo,结果喜出望外：

<?php
  $fh=fopen($fifo, "r+"); // ensures at least one writer (us) so will be non-blocking
  stream_set_blocking($fh, false); // prevent fread / fwrite blocking
?>

The "r+" allows fopen to return immediately regardless of external  writer channel.
复制代码

结论使用“r+”,同时咱们又知道了使用stream_set_blocking防止紧接着的fread阻塞。接着咱们用下图(1-2)来简单的总结和描述这个master-worker通讯的方式。

master接收信号

最后咱们须要解决的问题就是master怎么接受来自client的信号，google/bing结论：

master接收信号 -> pcntl_signal注册对应信号的handler方法 -> pcntl_signal_dispatch() 派发信号到handler
复制代码

以下图(1-3)所示，

其余

接着咱们只要实现不一样信号下master&worker的策略，例如worker的重启等。这里须要注意的就是，当master接受到重启的信号后，worker不要当即exit，而是等到worker的业务逻辑执行完成了以后exit。具体的方式就是：

master接收reload信号 -> master把reload信号写worker管道 -> worker读取到reload信号 -> worker添加剧启标志位 -> worker执行完业务逻辑后且检测到重启的标志位后exit
复制代码

建模

上面梳理完咱们的实现方式后，接着咱们就开始码代码了。码代码以前进行简单的建模，以下：

进程管理类Manager

- attributes
  + master: master对象
  + workers: worker进程对象池
  + waitSignalProcessPool: 等待信号的worker池
  + startNum: 启动进程数量
  + userPasswd: linux用户密码
  + pipeDir: 管道存放路径
  + signalSupport: 支持的信号
  + hangupLoopMicrotime: 挂起间隔睡眠时间
- method
  + welcome: 欢迎于
  + configure: 初始化配置
  + fork: forkworker方法
  + execFork: 执行forkworker方法
  + defineSigHandler: 定义信号handler
  + registerSigHandler: 注册信号handler
  + hangup: 挂起主进程
复制代码

进程抽象类Process

- attributes
  + type: 进程类型 master/worker
  + pid: 进程ID
  + pipeName: 管道名称 
  + pipeMode: 管道模式
  + pipeDir: 管道存放路径
  + pipeNamePrefix: 管道名称前缀
  + pipePath: 管道生成路径
  + readPipeType: 读取管道数据的字节数
  + workerExitFlag: 进程退出标志位
  + signal: 当前接受到的信号
  + hangupLoopMicrotime: 挂起间隔睡眠时间
- method
  + hangup: 挂起进程(抽象方法)
  + pipeMake: 建立管道
  + pipeWrite: 写管道
  + pipeRead: 读管道
  + clearPipe: 清理管道文件
  + stop: 进程exit
复制代码

master实体类MasterProcess

- attributes
  + 
- method
  + hangup: 挂起进程
复制代码

worker实体类MasterProcess

- attributes
  + 
- method
  + dispatchSig: 定义worker信号处理方式
复制代码

最后咱们须要作的就是优雅的填充咱们的代码了。

最后

项目地址 github.com/TIGERB/naru…

我的知识还有不少不足，若是有写的不对的地方，但愿你们及时指正。

THX~