php 利用pcntl扩展实现高并发

pcntl_fork官方描述：
pcntl_fork — 在当前进程当前位置产生分支（子进程）。译注：fork是创建了一个子进程，父进程和子进程 都从fork的位置开始向下继续执行，不同的是父进程执行过程中，得到的fork返回值为子进程 号，而子进程得到的是0。

通过一段代码来理解pcntl_fork如何进行多进程并发执行的

$i = 2;
while($i >= 0){
$pid = pcntl_fork();
if($pid > 0){
//当前处于父进程中
}elseif($pid == 0){
//这里是子进程逻辑
exit();//子进程跑完了必须退出。否则子进程会继续执行循环创建新的进程
}else{
//进程创建失败
}

当前进程通过pcntl_fork创建了一个子进程，创建完成后当前进程继续执行，此时$pid为创建子进程的进程id所以会进入pid > 0 的判断区块。同时，当父进程执行pcntl_fork时，php又会重新开启一个进程。该进程会拷贝父进程的变量，并且从pcntl_fork之后开始执行，因为进程为子进程，所以pid为0，会执行pid＝＝0里面的逻辑。子进程逻辑跑完了建议退出，否则会继续执行while循环。

100个号码批量分成10个进程发送示例

//随机取100条数据
$mobileList = ['135***','139***',...,'152*****'];

insert($data);

function insert(array $phoneList){
    $cnt = count($phoneList);  //测试数组大小
    $slice = 10;  //需要调用的进程数量
    $master = array_chunk($phoneList,floor($cnt/(10)));
    $childList = [];
    echo "进程开始\r\n";
    while($slice > 0)
    {
        $pid = pcntl_fork();
        if($pid > 0){
            $childList[$pid] = 1;
            echo $pid."\r\n";
            //$pid>0表示当前还在执行父进程的代码
            //这里最好啥都不做，每次执行pcntl_fork都会执行这里的代码。
            //这里的代码执行完之后 会将$pid设置为0，然后jump到pcntl_fork代码之后，重新做判断；
        }elseif($pid == 0){
            //这里写我们的逻辑
            foreach($master[$slice-1] as $val)
            {
                sendMessage();//发送短信
            }
            //子进程执行完之后务必需要关闭;
            exit();
        }else
        {
            //程序发生错误也需要关闭程序
            exit();
        }
        $slice--;
    }

    // 等待所有子进程结束后回收资源
    while(!empty($childList)){
        $childPid = pcntl_wait($status);
        if ($childPid > 0){
            unset($childList[$childPid]);
        }
    }
}