PHP 多进程

2021-07-25 本文已影响0人 JJNile

简单的父子进程

<?php
  
/**
 * 简单的父子进程
 * pcntl_fork 创建了一个子进程，父进程和子进程都从 fork 位置开始向下继续执行，不同的是父进程执行过程中，得到的 fork 返回值为子进程号，而子进程得到的是 0。
 * posix_getpid 获取当前进程
 * posix_getppid 获取父亲进程
 */
// fork 父进程中返回的是子进程号、子进程中返回的是 0
$pid = pcntl_fork();
if (0 === $pid) {
    echo "子进程：" . posix_getpid() . " - 父进程：". posix_getppid() . PHP_EOL;
} elseif ($pid > 0) {
    echo "父进程：" . posix_getpid() . " - 子进程：". $pid . PHP_EOL;
} else {
    throw \Exception("进程 fork 错误");
}

// 输出：
// 父进程：292 - 子进程：293
// 子进程：293 - 父进程：292

循环内父子进程

<?php

/**
 * fork 一次调用，两次返回
 * 如果子进程不加 exit 退出的话，子进程也会参与到循环，然后子进程 fork 新的子进程
 */
for ($i = 1; $i <= 3; $i++) {
    $pid = pcntl_fork();
    if (0 === $pid) {
        echo "子进程：" . $pid . PHP_EOL;
        // for 循环里使用 pcntl_fork() 需要 exit，否则会造成进程分裂
        // exit;
    }
}

// 输出：
// 子进程：0
// 子进程：0
// 子进程：0
// 子进程：0
// 子进程：0
// 子进程：0
// 子进程：0

image-20210706080335902

多个进程复用一个链接

<?php
  
/**
 * 多个进程共享一个链接问题
 * - 多个进程复用一个连接会造成结果无法保证被哪个进程处理
 * - 正确做法应该是给每一个进程分别创建一个连接
 */
$redis = new Redis();
// 此处只创建一个连接，在后续给多个进程复用数据会发生错乱了，此处应被注释
$redis->connect('docker-lnmp_redis_1', 6379);
for ($i = 1; $i <= 4; $i++) {
    $pid = pcntl_fork();
    if (0 === $pid) {
        // 正确做法：注释上面共享的连接，给每一个进程分别创建一个 Redis 连接
        // $redis->connect('docker-lnmp_redis_1', 6379);
        // uid 只有 [1,2,3,5],没有 4
        $res = $redis->sIsMember('uid', $i);
        echo $i . ":" . json_encode($res) . PHP_EOL;
        while (true) {
            sleep(1);
        }
    }
}
while (true) {
    sleep(1);
}