时间:2021-05-26
向消息队列发送数据和获取数据的测试
<?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通信-消息队列使用详解整合,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
本文实例讲述了PHP消息队列用法。分享给大家供大家参考,具体如下:该消息队列用于linux下,进程通信#根据路径和后缀创建一个id$key=ftok(__DIR
思路: 队列使用说明: multiprocessing.Queue()#用于进程间通信,单主进程与子进程无法通信(使用进程池时尽量不要使用这个) mu
Linux消息队列实现进程间通信实例详解一、什么是消息队列消息队列提供了一种从一个进程向另一个进程发送一个数据块的方法。每个数据块都被认为含有一个类型,接收进程
本文实例讲述了PHP多进程。分享给大家供大家参考,具体如下:PHP创建多进程需要使用到pcntl模块在编译时加上--enable-pcntl打开进程控制支持,不
本文实例讲述了Python进程间通信Queue消息队列用法。分享给大家供大家参考,具体如下:进程间通信-QueueProcess之间有时需要通信,操作系统提供了