PHP多进程通信-消息队列

进程是一个具有独立功能的程序关于某个数据集合的一次运行活动。换句话说就是，在系统调度多个cpu的时候，一个程序的基本单元。进程对于大多数的语言都不是一个陌生的概念，作为”世界上最好的语言php”当然也例外。
通常linux中的进程通信方式有：消息队列、信号量、共享内存、信号、管道、socket。
向消息队列发送数据和获取数据的测试
<?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); }

怎样申请云邮箱
网站被劫持？-市场咨询
数据库导入用不了-虚拟主机/数据库问题
HTTP详细介绍
开页游私服能用虚拟主机吗
阿里云网站服务器环境配置文件
其他网站如都可以访问为什么昨天关机后今天无法访问
平衡空间性能与部署成本之选：西部数码独享云虚拟主机全新上线！