php 利用pcntl扩展实现高并发-阿里云开发者社区

开发者社区> 开发与运维> 正文

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]);
        }
    }
}

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

分享:
开发与运维
使用钉钉扫一扫加入圈子
+ 订阅

集结各类场景实战经验,助你开发运维畅行无忧

其他文章