php消息队列发送数据和获取数据的代码示例

内容导读

收集整理的这篇技术教程文章主要介绍了php消息队列发送数据和获取数据的代码示例，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1678字，纯文字阅读大概需要3分钟。

内容图文

本篇文章给大家带来的内容是关于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消息队列发送数据和获取数据的代码示例的详细内容，更多请关注Gxl网其它相关文章！

内容总结

以上是为您收集整理的php消息队列发送数据和获取数据的代码示例全部内容，希望文章能够帮你解决php消息队列发送数据和获取数据的代码示例所遇到的程序开发问题。 如果觉得技术教程内容还不错，欢迎将网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

希望以上内容对你有所帮助！如果还有其他问题，请随时提问。 各类知识收集 拥有多年CMS企业建站经验，对 lecms， classcms， fastadmin， pbootcms， phpcms， eyoucms， yzmcms， PHP， xunruicms， jizhicms， dedecms， wordpress， hkcms， yzncms， 等各类cms的相互转化，程序开发，网站制作，bug修复，程序杀毒，插件定制都可以提供最佳解决方案。