• 贵州省社科规划办与贵州日报社合作推出“文化贵州”专栏 2019-03-20
  • 就算不为了世界杯,俄罗斯也有那么多时髦好去处值得你飞去 2019-03-20
  • 近3000期走势图: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通信-消息队列使用详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对脚本之家网站的支持!

    相关文章

    • PHP实现微信小程序用户授权的工具类示例

      PHP实现微信小程序用户授权的工具类示例

      这篇文章主要介绍了PHP实现微信小程序用户授权的工具类示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
      2019-03-03
    • Codeigniter通过SimpleXML将xml转换成对象的方法

      Codeigniter通过SimpleXML将xml转换成对象的方法

      这篇文章主要介绍了Codeigniter通过SimpleXML将xml转换成对象的方法,涉及Codeigniter操作XML文件的技巧,非常具有实用价值,需要的朋友可以参考下
      2015-03-03
    • php获取访问者IP地址汇总

      php获取访问者IP地址汇总

      在很我的时候我们需要得到用户的真实IP地址,例如,日志记录,地理定位,将用户信息,网站数据分析等,其实获取IP地址很简单$_SERVER[\'REMOTE_ADDR\']就可以了。下面我们就来给大家汇总一下常用的几种获取IP地址的方法。
      2015-04-04
    • 修改ThinkPHP缓存为Memcache的方法

      修改ThinkPHP缓存为Memcache的方法

      这篇文章主要介绍了修改ThinkPHP缓存为Memcache的方法,需要的朋友可以参考下
      2014-06-06
    • 如何使用php实现评委评分器

      如何使用php实现评委评分器

      本文主要介绍了如何使用php实现评委评分器,从输入的数组中去掉最高分和最低分,算出平均分,需要的朋友可以参考下
      2015-07-07
    • 详解ThinkPHP3.2.3验证码显示、刷新、校验

      详解ThinkPHP3.2.3验证码显示、刷新、校验

      本篇文章主要介绍了ThinkPHP3.2.3验证码显示、刷新、校验 ,具有一定的参考价值,感兴趣的小伙伴们可以参考一下。
      2016-12-12
    • Thinkphp模板中截取字符串函数简介

      Thinkphp模板中截取字符串函数简介

      在php中截取字符串的函数有很多,而在thinkphp中也可以直接使用php的函数,本文给大家简单的介绍thinkPHP模板中截取字符串的具体用法,希望能对各位有所帮助
      2014-06-06
    • 提交表单后 PHP获取提交内容的实现方法

      提交表单后 PHP获取提交内容的实现方法

      下面小编就为大家带来一篇提交表单后 PHP获取提交内容的实现方法。小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
      2016-05-05
    • thinkPHP使用post方式查询时分页失效的解决方法

      thinkPHP使用post方式查询时分页失效的解决方法

      这篇文章主要介绍了thinkPHP使用post方式查询时分页失效的解决方法,通过使用JavaScript动态修改页面元素结合thinkPHP查询语句解决分页失效的问题,需要的朋友可以参考下
      2015-12-12
    • PHP实现一个多功能购物网站的案例

      PHP实现一个多功能购物网站的案例

      下面小编就为大家带来一篇PHP实现一个多功能购物网站的案例。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
      2017-09-09

    最新评论

  • 贵州省社科规划办与贵州日报社合作推出“文化贵州”专栏 2019-03-20
  • 就算不为了世界杯,俄罗斯也有那么多时髦好去处值得你飞去 2019-03-20