• [放鞭炮][福]玉竹斑斑节日快乐![福][放鞭炮] 2019-05-23
  • 三狮军团首秀 只有两千多球迷观战 2019-05-19
  • 人民网2017呼和浩特徒步迎新活动--内蒙古频道--人民网 2019-05-19
  • 【品牌资讯】环球网斩获“全国行业新闻网站传播力2017年6月榜”多项冠军 2019-05-15
  • 深化对经济工作主线的认识 从供需关系看供给侧结构性改革 2019-05-15
  • 格拉斯哥艺术学院起火 4年前曾遭火灾仍在整修 2019-05-14
  • 回复@地瓜干17世:猪临死才会嚎叫呢~ 2019-05-14
  • 婺源古村溪中发现鹰嘴龟 2019-05-08
  • 编辑评测:高夫净源控油平衡露 极速补水长效控油 2019-05-08
  • 四部门发文规范特色小镇建设防止“新瓶装旧酒” 2019-05-02
  • 【地球的盛会文明的聚会艺术的盛宴四海一家足球为人类和平幸福而荣耀!!!普京是当今人类世界最优秀的一代伟人俄罗斯赢啦!!!】 2019-04-29
  • 学习新思想,千万师生同上一堂课 2019-04-28
  • 你这种个体户都干不了的老蚕也配谈计划?真是笑死人不偿命哦? 2019-04-23
  • 感人!的哥带着患病父亲出车 孝心感动乘客 2019-04-23
  • 图解:习近平在纪念马克思诞辰200周年大会上讲话的16个金句 2019-04-16
  • 十一选五奖金对照表:PHP多进程通信-消息队列使用

    山西体彩11选5直选遗漏 www.caxru.com  更新时间:2019年03月08日 15:37:26   作者:陶士涵的菜地   我要评论

    这篇文章主要介绍了PHP通信-消息队列使用详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

    向消息队列发送数据和获取数据的测试

    <?php
    $key=ftok(__FILE__,'a');
    
    //获取消息队列
    $queue=msg_get_queue($key,0666);
    //发送消息
    //msg_send($queue, 1, "Hello, 1");
    //接收消息,如果接收不到会阻塞
    msg_receive($queue, 1, $message_type, 1024, $message1);
    //移除消息
    //msg_remove_queue($queue);
    //var_dump($message1);

    <?php
    /**
     * 这段代码模拟了一个日常的任务。
     * 第一个父进程产生了一个子进程。子进程又作为父进程,产生10个子进程。
     * 可以简化为A -> B -> c,d,e... 等进程。
     * 作为A来说,只需要生产任务,然后交给B 来处理。B 则会将任务分配给10个子进程来进行处理。
     * 
     */
    
    //设定脚本永不超时
    set_time_limit(0);
    $ftok = ftok(__FILE__, 'a');
    $msg_queue = msg_get_queue($ftok);
    $pidarr = []; 
    
    //产生子进程
    $pid = pcntl_fork();
    if ($pid) {
     //父进程模拟生成一个特大的数组。
     $arr = range(1,100000);
     //将任务放进队里,让多个子进程并行处理
     foreach ($arr as $val) {
      $status = msg_send($msg_queue,1, $val);
      usleep(1000);
     } 
     $pidarr[] = $pid;
     msg_remove_queue($msg_queue);
    } else {
     //子进程收到任务后,fork10个子进程来处理任务。
     for ($i =0; $i<10; $i++) {
      $childpid = pcntl_fork();
      if ($childpid) {
       $pidarr[] = $childpid; //收集子进程processid
      } else {
       while (true) {
        msg_receive($msg_queue, 0, $msg_type, 1024, $message);
        if (!$message) exit(0);
        echo $message.PHP_EOL;
        usleep(1000);
       } 
      } 
     } 
    }
    
    //防止主进程先于子进程退出,形成僵尸进程
    while (count($pidarr) > 0) {
     foreach ($pidarr as $key => $pid) {
      $status = pcntl_waitpid($pid, $status);
      if ($status == -1 || $status > 0) {
       unset($pidarr[$key]);
      } 
     } 
     sleep(1);
    }

    以上所述是小编给大家介绍的PHP通信-消息队列使用详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持!

    相关文章

    最新评论

  • [放鞭炮][福]玉竹斑斑节日快乐![福][放鞭炮] 2019-05-23
  • 三狮军团首秀 只有两千多球迷观战 2019-05-19
  • 人民网2017呼和浩特徒步迎新活动--内蒙古频道--人民网 2019-05-19
  • 【品牌资讯】环球网斩获“全国行业新闻网站传播力2017年6月榜”多项冠军 2019-05-15
  • 深化对经济工作主线的认识 从供需关系看供给侧结构性改革 2019-05-15
  • 格拉斯哥艺术学院起火 4年前曾遭火灾仍在整修 2019-05-14
  • 回复@地瓜干17世:猪临死才会嚎叫呢~ 2019-05-14
  • 婺源古村溪中发现鹰嘴龟 2019-05-08
  • 编辑评测:高夫净源控油平衡露 极速补水长效控油 2019-05-08
  • 四部门发文规范特色小镇建设防止“新瓶装旧酒” 2019-05-02
  • 【地球的盛会文明的聚会艺术的盛宴四海一家足球为人类和平幸福而荣耀!!!普京是当今人类世界最优秀的一代伟人俄罗斯赢啦!!!】 2019-04-29
  • 学习新思想,千万师生同上一堂课 2019-04-28
  • 你这种个体户都干不了的老蚕也配谈计划?真是笑死人不偿命哦? 2019-04-23
  • 感人!的哥带着患病父亲出车 孝心感动乘客 2019-04-23
  • 图解:习近平在纪念马克思诞辰200周年大会上讲话的16个金句 2019-04-16
  • 澳洲幸运10是哪里的 体彩排列五走势图 彩票玩法 全天北京pk10计划网页 13171必发指数爱彩网 福利彩票中奖税务处理 抽奖刮刮乐 福彩幸运农场技巧 重庆幸运农场直三遗漏 河北福利彩票开奖结果 江苏时时彩开奖网 3d和尾走势图福彩3d和质表3d和质 喜乐彩券行台北市 四川时时彩网 体育运动刮刮乐图片 上海时时乐杀两码组合