资讯专栏INFORMATION COLUMN

用PHP玩转进程之二 — 多进程PHPServer

stormjun / 1003人阅读

摘要:代码实现启动启动流程见流程,主要包括守护进程保存注册信号处理器创建多进程这部分。模拟调度实际用实现捕获信号其中,会在每次调度过程中,捕获信号并执行注册的信号处理器。

首发于 樊浩柏科学院

经过 用 PHP 玩转进程之一 — 基础 的回顾复习,我们已经掌握了进程的基础知识,现在可以尝试用 PHP 做一些简单的进程控制和管理,来加深我们对进程的理解。接下来,我将用多进程模型实现一个简单的 PHPServer,基于它你可以做任何事。

PHPServer 完整的源代码,可前往 fan-haobai/php-server 获取。

总流程

该 PHPServer 的 Master 和 Worker 进程主要控制流程,如下图所示:

其中,主要涉及 3 个对象,分别为 入口脚本、Master 进程、Worker 进程。它们扮演的角色如下:

入口脚本:主要实现 PHPServer 的启动、停止、重载功能,即触发 Master 进程startstopreload流程;

Master 进程:负责创建并监控 Worker 进程。在启动阶段,会注册信号处理器,然后创建 Worker;在运行阶段,会持续监控 Worker 进程健康状态,并接受来自入口脚本的控制信号并作出响应;在停止阶段,会停止掉所有 Worker 进程;

Worker 进程:负责执行业务逻辑。在被 Master 进程创建后,就处于持续运行阶段,会监听到来自 Master 进程的信号,以实现自我的停止;

整个过程,又包括 4 个流程

流程 ① :以守护态启动 PHPServer 时的主要流程。入口脚本会进行 daemonize,也就是实现进程的守护态,此时会fork出一个 Master 进程;Master 进程先经过 保存 PID、注册信号处理器 操作,然后 创建 Worker 会fork出多个 Worker 进程;

流程 ② :为 Master 进程持续监控的流程,过程中会捕获入口脚本发送来的信号。主要监控 Worker 进程健康状态,当 Worker 进程异常退出时,会尝试创建新的 Worker 进程以维持 Worker 进程数量;

流程 ③ :为 Worker 进程持续运行的流程,过程中会捕获 Master 进程发送来的信号。流程 ① 中 Worker 进程被创建后,就会持续执行业务逻辑,并阻塞于此;

流程 ④ :停止 PHPServer 的主要流程。入口脚本首先会向 Master 进程发送 SIGINT 信号,Master 进程捕获到该信号后,会向所有的 Worker 进程转发 SIGINT 信号(通知所有的 Worker 进程终止),等待所有 Worker 进程终止退出;

在流程 ② 中,Worker 进程被 Master 进程fork出来后,就会 持续运行 并阻塞于此,只有 Master 进程才会继续后续的流程。
代码实现 启动

启动流程见 流程 ①,主要包括 守护进程、保存 PID、注册信号处理器、创建多进程 Worker 这 4 部分。

守护进程

首先,在入口脚本中fork一个子进程,然后该进程退出,并设置新的子进程为会话组长,此时的这个子进程就会脱离当前终端的控制。如下图所示:

这里使用了 2 次fork,所以最后fork的一个子进程才是 Master 进程,其实一次fork也是可以的。代码如下:

protected static function daemonize()
{
    umask(0);
    $pid = pcntl_fork();
    if (-1 === $pid) {
        exit("process fork fail
");
    } elseif ($pid > 0) {
        exit(0);
    }

    // 将当前进程提升为会话leader
    if (-1 === posix_setsid()) {
        exit("process setsid fail
");
    }

    // 再次fork以避免SVR4这种系统终端再一次获取到进程控制
    $pid = pcntl_fork();
    if (-1 === $pid) {
        exit("process fork fail
");
    } elseif (0 !== $pid) {
        exit(0);
    }
}
通常在启动时增加-d参数,表示进程将运行于守护态模式。

当顺利成为一个守护进程后,Master 进程已经脱离了终端控制,所以有必要关闭标准输出和标准错误输出。如下:

protected static function resetStdFd()
{
    global $STDERR, $STDOUT;
    //重定向标准输出和错误输出
    @fclose(STDOUT);
    fclose(STDERR);
    $STDOUT = fopen(static::$stdoutFile, "a");
    $STDERR = fopen(static::$stdoutFile, "a");
}
保存PID

为了实现 PHPServer 的重载或停止,我们需要将 Master 进程的 PID 保存于 PID 文件中,如php-server.pid文件。代码如下:

protected static function saveMasterPid()
{
    // 保存pid以实现重载和停止
    static::$_masterPid = posix_getpid();
    if (false === file_put_contents(static::$pidFile, static::$_masterPid)) {
        exit("can not save pid to" . static::$pidFile . "
");
    }

    echo "PHPServer start	 33[32m [OK] 33[0m
";
}
注册信号处理器

因为守护进程一旦脱离了终端控制,就犹如一匹脱缰的野马,任由其奔腾可能会为所欲为,所以我们需要去驯服它。

这里使用信号来实现进程间通信并控制进程的行为,注册信号处理器如下:

protected static function installSignal()
{
    pcntl_signal(SIGINT, array("PHPServerWorker", "signalHandler"), false);
    pcntl_signal(SIGTERM, array("PHPServerWorker", "signalHandler"), false);

    pcntl_signal(SIGUSR1, array("PHPServerWorker", "signalHandler"), false);
    pcntl_signal(SIGQUIT, array("PHPServerWorker", "signalHandler"), false);

    // 忽略信号
    pcntl_signal(SIGUSR2, SIG_IGN, false);
    pcntl_signal(SIGHUP,  SIG_IGN, false);
}

protected static function signalHandler($signal)
{
    switch($signal) {
        case SIGINT:
        case SIGTERM:
            static::stop();
            break;
        case SIGQUIT:
        case SIGUSR1:
            static::reload();
            break;
        default: break;
    }
}

其中,SIGINT 和 SIGTERM 信号会触发stop操作,即终止所有进程;SIGQUIT 和 SIGUSR1 信号会触发reload操作,即重新加载所有 Worker 进程;此处忽略了 SIGUSR2 和 SIGHUP 信号,但是并未忽略 SIGKILL 信号,即所有进程都可以被强制kill掉。

创建多进程Worker

Master 进程通过fork系统调用,就能创建多个 Worker 进程。实现代码,如下:

protected static function forkOneWorker()
{
    $pid = pcntl_fork();

    // 父进程
    if ($pid > 0) {
        static::$_workers[] = $pid;
    } else if ($pid === 0) { // 子进程
        static::setProcessTitle("PHPServer: worker");

        // 子进程会阻塞在这里
        static::run();

        // 子进程退出
        exit(0);
    } else {
        throw new Exception("fork one worker fail");
    }
}

protected static function forkWorkers()
{
    while(count(static::$_workers) < static::$workerCount) {
        static::forkOneWorker();
    }
}
Worker进程的持续运行

Worker 进程的持续运行,见 流程 ③ 。其内部调度流程,如下图:

对于 Worker 进程,run()方法主要执行具体业务逻辑,当然 Worker 进程会被阻塞于此。对于 任务 ① 这里简单地使用while来模拟调度,实际中应该使用事件(Select 等)驱动。

public static function run()
{
    // 模拟调度,实际用event实现
    while (1) {
        // 捕获信号
        pcntl_signal_dispatch();

        call_user_func(function() {
            // do something
            usleep(200);
        });
    }
}

其中,pcntl_signal_dispatch()会在每次调度过程中,捕获信号并执行注册的信号处理器。

Master进程的持续监控 调度流程

Master 进程的持续监控,见 流程 ② 。其内部调度流程,如下图:

对于 Master 进程的调度,这里也使用了while,但是引入了wait的系统调用,它会挂起当前进程,直到一个子进程退出或接收到一个信号。

protected static function monitor()
{
    while (1) {
        // 这两处捕获触发信号,很重要
        pcntl_signal_dispatch();
        // 挂起当前进程的执行直到一个子进程退出或接收到一个信号
        $status = 0;
        $pid = pcntl_wait($status, WUNTRACED);
        pcntl_signal_dispatch();

        if ($pid >= 0) {
            // worker健康检查
            static::checkWorkerAlive();
        }
        // 其他你想监控的
    }
}
第两次的pcntl_signal_dispatch()捕获信号,是由于wait挂起时间可能会很长,而这段时间可能恰恰会有信号,所以需要再次进行捕获。

其中,PHPServer 的 停止 和 重载 操作是由信号触发,在信号处理器中完成具体操作;Worker 进程的健康检查 会在每一次的调度过程中触发。

Worker进程的健康检查

由于 Worker 进程执行繁重的业务逻辑,所以可能会异常崩溃。因此 Master 进程需要监控 Worker 进程健康状态,并尝试维持一定数量的 Worker 进程。健康检查流程,如下图:

代码实现,如下:

protected static function checkWorkerAlive()
{
    $allWorkerPid = static::getAllWorkerPid();
    foreach ($allWorkerPid as $index => $pid) {
        if (!static::isAlive($pid)) {
            unset(static::$_workers[$index]);
        }
    }

    static::forkWorkers();
}
停止

Master 进程的持续监控,见 流程 ④ 。其详细流程,如下图:

入口脚本给 Master 进程发送 SIGINT 信号,Master 进程捕获到该信号并执行 信号处理器,调用stop()方法。如下:

protected static function stop()
{
    // 主进程给所有子进程发送退出信号
    if (static::$_masterPid === posix_getpid()) {
        static::stopAllWorkers();

        if (is_file(static::$pidFile)) {
            @unlink(static::$pidFile);
        }
        exit(0);
    } else { // 子进程退出

        // 退出前可以做一些事
        exit(0);
    }
}

若是 Master 进程执行该方法,会先调用stopAllWorkers()方法,向所有的 Worker 进程发送 SIGINT 信号并等待所有 Worker 进程终止退出,再清除 PID 文件并退出。有一种特殊情况,Worker 进程退出超时时,Master 进程则会再次发送 SIGKILL 信号强制杀死所有 Worker 进程;

由于 Master 进程会发送 SIGINT 信号给 Worker 进程,所以 Worker 进程也会执行该方法,并会直接退出。

protected static function stopAllWorkers()
{
    $allWorkerPid = static::getAllWorkerPid();
    foreach ($allWorkerPid as $workerPid) {
        posix_kill($workerPid, SIGINT);
    }

    // 子进程退出异常,强制kill
    usleep(1000);
    if (static::isAlive($allWorkerPid)) {
        foreach ($allWorkerPid as $workerPid) {
            static::forceKill($workerPid);
        }
    }

    // 清空worker实例
    static::$_workers = array();
}
重载

代码发布后,往往都需要进行重新加载。其实,重载过程只需要重启所有 Worker 进程即可。流程如下图:

整个过程共有 2 个流程,流程 ① 终止所有的 Worker 进程,流程 ② 为 Worker 进程的健康检查 。其中流程 ① ,入口脚本给 Master 进程发送 SIGUSR1 信号,Master 进程捕获到该信号,执行信号处理器调用reload()方法,reload()方法调用stopAllWorkers()方法。如下:

protected static function reload()
{
    // 停止所有worker即可,master会自动fork新worker
    static::stopAllWorkers();
}
reload()方法只会在 Master 进程中执行,因为 SIGQUIT 和 SIGUSR1 信号不会发送给 Worker 进程。

你可能会纳闷,为什么我们需要重启所有的 Worker 进程,而这里只是停止了所有的 Worker 进程?这是因为,在 Worker 进程终止退出后,由于 Master 进程对 Worker 进程的健康检查 作用,会自动重新创建所有 Worker 进程。

运行效果

到这里,我们已经完成了一个多进程 PHPServer。我们来体验一下:

$ php server.php 
Usage: Commands [mode] 

Commands:
start        Start worker.
stop        Stop worker.
reload        Reload codes.

Options:
-d        to start in DAEMON mode.

Use "--help" for more information about a command.

首先,我们启动它:

$ php server.php start -d
PHPServer start      [OK]

其次,查看进程树,如下:

$ pstree -p
init(1)-+-init(3)---bash(4)
        |-php(1286)-+-php(1287)
                    `-php(1288)

最后,我们把它停止:

$ php server.php stop
PHPServer stopping ...
PHPServer stop success

现在,你是不是感觉进程控制其实很简单,并没有我们想象的那么复杂。( ̄┰ ̄*)

总结

我们已经实现了一个简易的多进程 PHPServer,模拟了进程的管理与控制。需要说明的是,Master 进程可能偶尔也会异常地崩溃,为了避免这种情况的发生:

首先,我们不应该给 Master 进程分配繁重的任务,它更适合做一些类似于调度和管理性质的工作;
其次,可以使用 Supervisor 等工具来管理我们的程序,当 Master 进程异常崩溃时,可以再次尝试被拉起,避免 Master 进程异常退出的情况发生。

相关文章 »

用PHP玩转进程之一 — 基础(2018-08-28)

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/31099.html

相关文章

  • PHP面试之二:高并发与大数据

    摘要:三态分别是就绪运行阻塞进程的五态模型在三态的基础上发展而来新建态运行态终止态就绪态等待态线程称之为轻量级的进程,程序执行流的最小单元。一个进程下有多个线程来完成不同的工作称之为多线程。 web资源防盗链 盗链是什么? 为什么要防? 在自己页面上显示一些不是自己服务器的资源(图片、音频、视频、css、js等)由于别人盗链你的资源会加重你的服务器负担,所以我们需要防止可能会影响统计 防盗链...

    Ashin 评论0 收藏0
  • nginx 负载服务器优化

    摘要:每个进程打开文件描述符最大数目配置要和系统的单进程打开文件数一致内核下开启文件打开数为,就相应应该填写调度时分配请求到进程并不是那么的均衡,假如超过会返回错误。 user www www; # ginx要开启的进程数 一般等于cpu的总核数,没必要开那么多,1个nginx内存消耗10兆左右 worker_processes 4; # 为每个进程分配cpu,上例中将4 个进程分...

    yunhao 评论0 收藏0
  • nginx 负载服务器优化

    摘要:每个进程打开文件描述符最大数目配置要和系统的单进程打开文件数一致内核下开启文件打开数为,就相应应该填写调度时分配请求到进程并不是那么的均衡,假如超过会返回错误。 user www www; # ginx要开启的进程数 一般等于cpu的总核数,没必要开那么多,1个nginx内存消耗10兆左右 worker_processes 4; # 为每个进程分配cpu,上例中将4 个进程分...

    姘搁『 评论0 收藏0
  • nginx 负载均衡搭建

    摘要:客户请求头缓冲大小默认会用这个来读取值,如果设定通过上传文件的大小磁盘和之间互相拷贝数据或任意两个文件描述符。 环境说明 192.168.1.208 Nginx负载服务器 192.168.1.210 webA服务器 PHP memcache xcache mysql 192.168.1.211 webB服务器 PHP memcache xcache webA/webB...

    endiat 评论0 收藏0
  • Swoole入门到实战(一):PHP7&Swoole源码安装、玩转网络通信引擎、异步非堵塞I

    摘要:服务重点基本概述协议是基于的一种新的网络协议。被调用者通过状态通知机制等来通知调用者,或通过回调函数来处理结果阻塞和非阻塞关注的是调用者等待被调用者返回调用结果时的状态。 一、PHP7源码安装和Swoole源码编译安装 1.1 PHP7源码安装 1.1.1 获取源码与安装     获取PHP7源码:www.php.net tar -xzvf ... # 解压命令 ./configur...

    weakish 评论0 收藏0

发表评论

0条评论

最新活动
阅读需要支付1元查看
<