soliphp / process
Simple multi-process manager for PHP, based on pcntl and posix.
Requires
- php: >=5.0
- ext-pcntl: *
- ext-posix: *
Suggests
- signals: Signal handling needs PHP 7.1+.
README
基于 pcntl 和 posix 扩展,简单的 PHP 多进程管理类库。
依赖
- Unix-like
- PHP 5.0+
- ext-pcntl
- ext-posix
注:信号处理部分需要 PHP 7.1+
安装
使用 composer
进行安装:
composer require soliphp/process
快速使用
<?php
use Soli\Process;
include __DIR__ . "/vendor/autoload.php";
$job = function ($worker) {
while (1) {
echo "Hello world, master pid: {$worker->masterPid}, worker pid: {$worker->workerPid}, worker id: {$worker->id}\n";
sleep(1);
}
};
$proc = new Process();
$proc->name = 'soli process test';
$proc->count = 2;
$proc->daemonize = 0;
$proc->logFile = '/tmp/soli_process.log';
$proc->setJob($job);
$proc->start();
进程结构
Soli\Process
使用 Master-Worker 进程模型:
[ master ]
/ | \
/ v \
[Worker1] [Worker2] [WorkerN]
master 进程 fork worker 进程,在 PHP 7.1+ 下 master 进程还会接收终止信号传递给 worker 进程执行退出。
自动补充退出的进程
如程序出现异常或其他情况导致进程退出,默认会自动补充进程,且保持对应的 $worker->id 不变。
如果不想自动补充退出的进程,可以设置 $process->refork = false;
函数列表
setJob
设置 worker 进程需要执行的任务。
Process->setJob(callable $job)
关于 callable 类型参见官方文档。
如这里使用匿名函数定义 job,输出一条信息退出进程:
$proc = new Process();
$proc->setJob(function ($worker) {
echo "Hello world, master pid: {$worker->masterPid}, worker pid: {$worker->workerPid}, worker id: {$worker->id}\n";
});
在 job 回调参数中会返回当前 worker 进程的 $worker 实例
,通过这个 $worker 实例可以获取以下属性列表中的中的属性。
start
启动进程,将根据设置的 count
启动相应个 worker 进程。
Process->start()
属性列表
id
当前 worker 进程的编号,编号范围:[0, $worker->count - 1]。
可在 job 回调中使用
。
masterPid
当前 master 进程 PID。
可在 job 回调中使用
。
workerPid
当前 worker 进程 PID。
可在 job 回调中使用
。
name
当前 master/worker 进程的名称,只支持 Linux。
执行设置进程名称时:
master 进程会自动在其后追加 master 文本,最终的进程名称为 $name master
;
worker 进程会自动在其后追加 worker 文本,最终的进程名称为 $name worker
。
count
设置启动的 worker 进程数,默认为 1
daemonize
是否将程序作为守护进程运行。
启用守护进程后,标准输出和错误会被重定向到 logFile
;
如果未设置 logFile
,将重定向到 /dev/null
,所有打印到屏幕的信息都会被丢弃。
logFile
运行期发生的异常信息、进程的终止信息等会记录到这个文件;
启用守护进程后,所有打印到屏幕的信息也都会写入到这个文件。
refork
worker 进程退出后是否自动补充新的进程,默认为 true,自动补充新的进程
。
如果不想自动补充退出的进程,可以设置 refork
为 false;
信号处理
信号处理部分使用了 pcntl_async_signals 需要 PHP 7.1+
支持。
master 进程支持接收 SIGINT
, SIGTERM
终止信号,master 进程接收到终止信号后向所有 worker
进程发送相应的终止信号,worker 进程接收到终止信号后执行退出操作。
我们可以通过 kill
命令发送信号:
kill -SIGINT <master pid>
kill -SIGTERM <master pid>
也可以直接通过信号所对应的数字参数:
kill -2 <master pid>
kill -15 <master pid>
SIGINT
即为在终端按下的 CTRL + C
。
注:如果使用 kill -9
即 kill -SIGKILL
对 master
进程发送终止信号,master 进程会立即终止,并不会再向 worker
进程发送终止信号,所以如果是要通过 master 进程终止所有 worker 进程,建议使用
kill -15
终止所有 worker 进程。
低于 PHP 7.1 可以使用以下命令终止所有 worker 进程,注意替换为你的 "process name":
ps aux | grep "process name" | grep -v grep | awk '{ print $2 }' | xargs kill -9
License
MIT Public License