php消息队列的介绍

515

说明

1、消息队列是存放在内存中的一个队列。

2、由于消息队列去数据是，只有一个进程能去到，所以不需要额外的锁或信号量。

实例

echo"parentprogresspid:{$parentPid\n";$childList=array();
//创建消息队列,以及定义消息类型(类似于数据库中的库)
$id=ftok(__FILE__,'m');
$msgQueue=msg_get_queue($id);
constMSG_TYPE=1;
//生产者
functionproducer(){
global$msgQueue;
$pid=posix_getpid();
$repeatNum=5;
for($i=1;$i<=$repeatNum;$i++){
$str="({$pid)progresscreate!{$i";
msg_send($msgQueue,MSG_TYPE,$str);
$rand=rand(1,3);
sleep($rand);


//消费者
functionconsumer(){
global$msgQueue;
$pid=posix_getpid();
$repeatNum=6;
for($i=1;$i<=$repeatNum;$i++){
$rel=msg_receive($msgQueue,MSG_TYPE,$msgType,1024,$message);
echo"{$message|consumer({$pid)destroy\n";
$rand=rand(1,3);
sleep($rand);


functioncreateProgress($callback){
$pid=pcntl_fork();
if($pid==-1){
//创建失败
exit("forkprogresserror!\n");
elseif($pid==0){
//子进程执行程序
$pid=posix_getpid();
$callback();
exit("({$pid)childprogressend!\n");
else{
//父进程执行程序
return$pid;


//3个写进程
for($i=0;$i<3;$i++){
$pid=createProgress('producer');
$childList[$pid]=1;
echo"createproducerchildprogress:{$pid\n";

//2个写进程
for($i=0;$i<2;$i++){
$pid=createProgress('consumer');
$childList[$pid]=1;
echo"createconsumerchildprogress:{$pid\n";

//等待所有子进程结束
while(!empty($childList)){
$childPid=pcntl_wait($status);
if($childPid>0){
unset($childList[$childPid]);


echo"({$parentPid)mainprogressend!\n";