侯体宗的博客
  • 首页
  • Hyperf版
  • beego仿版
  • 人生(杂谈)
  • 技术
  • 关于我
  • 更多分类
    • 文件下载
    • 文字修仙
    • 中国象棋ai
    • 群聊
    • 九宫格抽奖
    • 拼图
    • 消消乐
    • 相册

PHP 多进程与信号中断实现多任务常驻内存管理实例方法

php  /  管理员 发布于 7年前   173

本文章基于 pcntl 扩展做的多进程测试。

进程调度策略

父子进程的调度由操作系统来负责,具体先调度子进程还是父进程由系统的调度算法决定,当然可以在父进程加上延时或是调用进程回收函数 pcntl_wait 可以先让子进程先运行,进程回收的目的是释放进程创建时占用的内存空间,防止变成僵尸进程。

信号:

信号称为软中断系统或是叫软中断,功能是向进程发送异步事件通知。

信号编号: 【源码基于 SIGINT,SIGTERM,SIGUSR1 信号,含义请自行查看 kill 命令手册,不在描述】

linux 支持 64 个,有一半为实时信号,一半为非时实信号,这些信号都有自己的编号和对应的整数值。每个信号的编号含义读者可以参阅 linux 相关手册【man 手册看看就知道了】

信号处理函数:

信号一般会绑定相应的功能,有的是默认动作如 SIGKILL,SIGTERM,SIGINT 操作默认操作就是干掉进程,当然我们可以重写覆盖掉,就是通过 pcntl_signal 来覆盖掉。

信号的概念:与硬件中断一个道理,请读者自行参考本人前面撸过的文章或是查看芯片硬件中断原理。

信号的发送:

kill 信号编号 进程 或是按键产品的中断信号或是在源码里可以使用 posix_kill 等函数。

进程是相互隔离的,拥有自己的堆栈空间,除了一些公用的正文【代码区】,同时也有自己的可执行代码,进程运行时,将占用 cpu 的资源,其它进程将无权运行,此时其它进程将为阻塞状态【比如前面撸过的 tcp 服务】,当进程运行结束后【运行到代码的最后一句或是遇到 return 或是遇到 exit 退出进程函数或是遇到信号事件时将会退出】让出权限并释放掉内存,其它进程就有机会运行了。

进程拥有的自己进程描述符,其中比较常用的是进程号 PID,进程运行时会在系统 /proc/PID 下生成相应的进程文件,用户可以自行查看。

每个进程都拥有所属的进程组【进程的集合】,多个进程组集合则是一个会话,创建一个会话是通过一个进程进行创建的,并且此进程不可以为组长进程,此进程将成为会话期的会话首进程,也会成为进程组的进程组长,同时将会脱离控制终端,即使之前的进程绑定了控制终端也会脱离【守护进程的创建】。

文件描述权限掩码【权限屏蔽字】:

umask () 你可以在 linux 运行这个命令,然后创建文件,并查看它的权限【如果你跑完啥也没有发现,说明你还是训练不够 ^_^】

daemon();  $this->worker();  $this->setMasterPid();  $this->installSignal();  $this->showState();  $this->wait(); } function wait() {  while (1){   pcntl_signal_dispatch();   $pid = pcntl_wait($status);   if ($pid>0){    unset($this->workerPids[$pid]);   }else{    if (count($this->workerPids)==0){     exit();    }   }   usleep(100000);  } } function showState() {  $state = "\nMaster 信息\n";  $state.=str_pad("master pid",25);  $state.=str_pad("worker num",25);  $state.=str_pad("job pid list",10)."\n";  $state.=str_pad($this->getMasterPid(),25);  $state.=str_pad(count($this->workerPids),25);  $state.=str_pad(implode(",",array_keys($this->workerPids)),10);  echo $state.PHP_EOL; } function getMasterPid() {  if (file_exists($this->master_pid_file)){   return file_get_contents($this->master_pid_file);  }else{   exit("服务未运行\n");  } } function setMasterPid() {  $fp = fopen($this->master_pid_file,"w");  @fwrite($fp,posix_getpid());  @fclose($fp); } function daemon() {  $pid = pcntl_fork();  if ($pid<0){   exit("fork进程失败\n");  }else if ($pid >0){   exit(0);  }else{   umask(0);   $sid = posix_setsid();   if ($sid<0){    exit("创建会话失败\n");   }   $pid = pcntl_fork();   if ($pid<0){    exit("进程创建失败\n");   }else if ($pid >0){    exit(0);   }   //可以关闭标准输入输出错误文件描述符【守护进程不需要】  } } function worker() {  if (count($this->workerJob)==0)exit("没有工作任务\n");  foreach($this->workerJob as $job){   $pid = pcntl_fork();   if ($pid<0){    exit("工作进程创建失败\n");   }else if ($pid==0){    /***************子进程工作范围**********************/    //给子进程安装信号处理程序    $this->workerInstallSignal();    $start_time = time();    while (1){     pcntl_signal_dispatch();     if ((time()-$start_time)>=$job->job_run_time){      break;     }     $job->run(posix_getpid());    }    exit(0);//子进程运行完成后退出    /***************子进程工作范围**********************/   }else{    $this->workerPids[$pid] = $job;   }  } } function workerInstallSignal() {  pcntl_signal(SIGUSR1,[__CLASS__,'workerHandleSignal'],false); } function workerHandleSignal($signal) {  switch ($signal){   case SIGUSR1:    $state = "worker pid=".posix_getpid()."接受了父进程发来的自定义信号\n";    file_put_contents($this->state_file,$state,FILE_APPEND);    break;  } } function installSignal() {  pcntl_signal(SIGINT,[__CLASS__,'handleMasterSignal'],false);  pcntl_signal(SIGTERM,[__CLASS__,'handleMasterSignal'],false);  pcntl_signal(SIGUSR1,[__CLASS__,'handleMasterSignal'],false); } function handleMasterSignal($signal) {  switch ($signal){   case SIGINT:    //主进程接受到中断信号ctrl+c    foreach ($this->workerPids as $pid=>$worker){     posix_kill($pid,SIGINT);//向所有的子进程发出    }    exit("服务平滑停止\n");    break;   case SIGTERM://ctrl+z    foreach ($this->workerPids as $pid=>$worker){     posix_kill($pid,SIGKILL);//向所有的子进程发出    }    exit("服务停止\n");    break;   case SIGUSR1://用户自定义信号    if (file_exists($this->state_file)){     unlink($this->state_file);    }    foreach ($this->workerPids as $pid=>$worker){     posix_kill($pid,SIGUSR1);    }    $state = "master pid\n".$this->getMasterPid()."\n";    while(!file_exists($this->state_file)){     sleep(1);    }    $state.= file_get_contents($this->state_file);    echo $state.PHP_EOL;    break;  } }} workerJob = [new \Chen\Worker\Talk(),new \Chen\Worker\Job()];$process->run();

以上就是PHP 多进程与信号中断实现多任务常驻内存管理【Master/Worker 模型】的详细内容,感谢大家的学习和对AIDI的支持。

您可能感兴趣的文章:

  • PHP多进程通信-消息队列使用
  • 浅析PHP7的多进程及实例源码
  • php多进程模拟并发事务产生的问题小结
  • PHP多进程编程之僵尸进程问题的理解
  • PHP多进程编程总结(推荐)
  • PHP的Socket通信之UDP通信实例
  • PHP与Go语言之间的通信详解
  • php中socket通信机制实例详解
  • php实现的简单多进程服务器类完整示例


  • 上一条:
    php输出文字乱码的解决方法
    下一条:
    php实现映射操作实例详解
  • 昵称:

    邮箱:

    0条评论 (评论内容有缓存机制,请悉知!)
    最新最热
    • 分类目录
    • 人生(杂谈)
    • 技术
    • linux
    • Java
    • php
    • 框架(架构)
    • 前端
    • ThinkPHP
    • 数据库
    • 微信(小程序)
    • Laravel
    • Redis
    • Docker
    • Go
    • swoole
    • Windows
    • Python
    • 苹果(mac/ios)
    • 相关文章
    • Laravel从Accel获得5700万美元A轮融资(0个评论)
    • PHP 8.4 Alpha 1现已发布!(0个评论)
    • 用Time Warden监控PHP中的代码处理时间(0个评论)
    • 在PHP中使用array_pop + yield实现读取超大型目录功能示例(0个评论)
    • Property Hooks RFC在PHP 8.4中越来越接近现实(0个评论)
    • 近期文章
    • 智能合约Solidity学习CryptoZombie第三课:组建僵尸军队(高级Solidity理论)(0个评论)
    • 智能合约Solidity学习CryptoZombie第二课:让你的僵尸猎食(0个评论)
    • 智能合约Solidity学习CryptoZombie第一课:生成一只你的僵尸(0个评论)
    • 在go中实现一个常用的先进先出的缓存淘汰算法示例代码(0个评论)
    • 在go+gin中使用"github.com/skip2/go-qrcode"实现url转二维码功能(0个评论)
    • 在go语言中使用api.geonames.org接口实现根据国际邮政编码获取地址信息功能(1个评论)
    • 在go语言中使用github.com/signintech/gopdf实现生成pdf分页文件功能(0个评论)
    • gmail发邮件报错:534 5.7.9 Application-specific password required...解决方案(0个评论)
    • 欧盟关于强迫劳动的规定的官方举报渠道及官方举报网站(0个评论)
    • 在go语言中使用github.com/signintech/gopdf实现生成pdf文件功能(0个评论)
    • 近期评论
    • 122 在

      学历:一种延缓就业设计,生活需求下的权衡之选中评论 工作几年后,报名考研了,到现在还没认真学习备考,迷茫中。作为一名北漂互联网打工人..
    • 123 在

      Clash for Windows作者删库跑路了,github已404中评论 按理说只要你在国内,所有的流量进出都在监控范围内,不管你怎么隐藏也没用,想搞你分..
    • 原梓番博客 在

      在Laravel框架中使用模型Model分表最简单的方法中评论 好久好久都没看友情链接申请了,今天刚看,已经添加。..
    • 博主 在

      佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 @1111老铁这个不行了,可以看看近期评论的其他文章..
    • 1111 在

      佛跳墙vpn软件不会用?上不了网?佛跳墙vpn常见问题以及解决办法中评论 网站不能打开,博主百忙中能否发个APP下载链接,佛跳墙或极光..
    • 2016-10
    • 2016-11
    • 2017-06
    • 2017-07
    • 2017-08
    • 2017-09
    • 2017-11
    • 2017-12
    • 2018-01
    • 2018-02
    • 2018-03
    • 2020-03
    • 2020-04
    • 2020-05
    • 2020-06
    • 2020-07
    • 2020-09
    • 2021-02
    • 2021-03
    • 2021-04
    • 2021-05
    • 2021-06
    • 2021-07
    • 2021-08
    • 2021-09
    • 2021-10
    • 2021-11
    • 2021-12
    • 2022-01
    • 2022-02
    • 2022-05
    • 2022-06
    • 2022-07
    • 2022-08
    • 2022-09
    • 2022-10
    • 2022-11
    • 2022-12
    • 2023-01
    • 2023-02
    • 2023-03
    • 2023-04
    • 2023-05
    • 2023-06
    • 2023-07
    • 2023-08
    • 2023-09
    • 2023-10
    • 2023-11
    • 2023-12
    • 2024-01
    • 2024-02
    • 2024-03
    • 2024-04
    • 2024-05
    • 2024-06
    • 2024-07
    • 2024-09
    Top

    Copyright·© 2019 侯体宗版权所有· 粤ICP备20027696号 PHP交流群

    侯体宗的博客