<?php
$key = ftok('demo1.php',"x");//將文件與ID轉(zhuǎn)換為一個(gè)key，這個(gè)文件只要真實(shí)存在就行，沒有特殊限制，一般都指定當(dāng)前文件名
$msqid = msg_get_queue($key);// 創(chuàng)建一個(gè)消息隊(duì)列，返回一個(gè)資源id
echo msg_send($msqid,1,"hello"); //往消息隊(duì)列寫入一條數(shù)據(jù) hello 到隊(duì)列中
echo $msqid; // 輸出資源id

<?php
$a = serialize("hello");
echo 'hello 序列化長(zhǎng)度：'.strlen($a)."\n";
echo 'hello 序列化內(nèi)容：'.$a."\n";
echo "hello 未序列化長(zhǎng)度：".strlen("hello")."\n";

<?php
$key = ftok('demo1.php',"x");//將文件與ID轉(zhuǎn)換為一個(gè)key
$msqid = msg_get_queue($key);//消息隊(duì)列如果已創(chuàng)建，直接返回同一個(gè)資源描述符
//第一個(gè)參數(shù)資源描述符，第二個(gè)參數(shù)一般為0，表示從隊(duì)列第一條讀取，或者設(shè)置與msg_send函數(shù)第二個(gè)參數(shù)一致，第三個(gè)參數(shù)設(shè)置緩沖區(qū)長(zhǎng)度，注意msg_send 函數(shù)默認(rèn)會(huì)序列化數(shù)據(jù)，msg_receive函數(shù)默認(rèn)會(huì)將讀取數(shù)據(jù)反序列化，如果緩沖區(qū)設(shè)置過小會(huì)反序列化失敗
msg_receive($msqid,1,$received_message_type,1024,$message);//讀取消息隊(duì)列數(shù)據(jù)，逐條讀取，
echo $message.PHP_EOL;

<?php
$key = ftok('demo3.php',"x");//將文件與ID轉(zhuǎn)換為一個(gè)key，這個(gè)文件只要真實(shí)存在就行，沒有特殊限制，一般都指定當(dāng)前文件名
$msqid = msg_get_queue($key);// 創(chuàng)建一個(gè)消息隊(duì)列，返回一個(gè)資源id
// 第一個(gè)參數(shù)資源id,第二個(gè)參數(shù)消息類型，必須大于0，第三個(gè)參數(shù)寫入隊(duì)列內(nèi)容，取消序列化操作
echo msg_send($msqid,1,"hello",false); //往消息隊(duì)列寫入一條數(shù)據(jù) hello 到隊(duì)列中

<?php
$key = ftok('demo3.php',"x");//將文件與ID轉(zhuǎn)換為一個(gè)key
$msqid = msg_get_queue($key);
//第一個(gè)參數(shù)資源描述符
//第二個(gè)參數(shù)一般為0，表示從隊(duì)列第一條讀取，或者設(shè)置與msg_send函數(shù)第二個(gè)參數(shù)一致
// 第三個(gè)參數(shù)是msg_send函數(shù)的第二個(gè)參數(shù)的值，也就是發(fā)送消息的消息類型
//第四個(gè)參數(shù)設(shè)置接收緩沖區(qū)長(zhǎng)度，如果設(shè)置過小會(huì)反序列化失敗【如果使用序列化功能時(shí)候】
//當(dāng)接收緩沖區(qū)大小設(shè)置過小并且關(guān)閉了反序列化【發(fā)送端發(fā)送數(shù)據(jù)也關(guān)閉了】，但是發(fā)送的數(shù)據(jù)超過了設(shè)置的長(zhǎng)度，就會(huì)被截?cái)?，并且額外的數(shù)據(jù)會(huì)被丟棄，必須設(shè)置第五個(gè)參數(shù)才有效
// 第五個(gè)參數(shù) flags 標(biāo)志符
msg_receive($msqid,0,$received_message_type,1,$message,false,MSG_NOERROR);
echo $message.PHP_EOL;

<?php
$key = ftok('demo5.php',"x");//將文件與ID轉(zhuǎn)換為一個(gè)key
$msqid = msg_get_queue($key);
// fork 一個(gè)子進(jìn)程
$pid = pcntl_fork();
if($pid == 0){
    while(1){
    // MSG_IPC_NOWAIT【啟用非阻塞】 msg_receive 函數(shù)其實(shí)是封裝 linux c msgrcv 系統(tǒng)調(diào)用函數(shù)，如果設(shè)置為非阻塞，函數(shù)調(diào)用次數(shù)非常高，會(huì)非常消耗cpu資源
    //阻塞模式調(diào)用函數(shù)次數(shù)低，有數(shù)據(jù)才返回，對(duì)cpu友好
        $ret = msg_receive($msqid,0,$msgType,1024,$msg,true,MSG_IPC_NOWAIT,$error_code);
        if($error_code != MSG_ENOMSG){
            echo $msg."\n";
        }
        sleep(2);
        echo "go"."\n";
    }
    exit(0);
}

<?php
$key = ftok('demo5.php',"x");//將文件與ID轉(zhuǎn)換為一個(gè)key
$msqid = msg_get_queue($key);
$pid = pcntl_fork();
if($pid == 0){
    while(1){
        $ret = msg_receive($msqid,0,$msgType,1024,$msg,true,MSG_IPC_NOWAIT,$error_code);
        if($error_code != MSG_ENOMSG){
            echo $msg."\n";
        }
    }
    exit(0);
}
$i = 1;
while(1){
    msg_send($msqid,2,"hello world",true);
    sleep(2);
    if($i++ == 3){
    	// 殺死子進(jìn)程
        posix_kill($pid,SIGILL);
        break;
    }
}
//子進(jìn)程退出回收子進(jìn)程，防止孤兒進(jìn)程
$pid = pcntl_wait($status);
if($pid > 0)
{
    echo "exit pid=".$pid."\n";
}

<?php
$key = ftok('demo5.php',"x");//將文件與ID轉(zhuǎn)換為一個(gè)key
$msqid = msg_get_queue($key);
$pid = pcntl_fork();
if($pid == 0){
    while(1){
        $ret = msg_receive($msqid,0,$msgType,1024,$msg,true,MSG_IPC_NOWAIT,$error_code);
        if($error_code != MSG_ENOMSG){
            echo $msg."\n";
        }

    }
    exit(0);
}
$i = 1;
while(1){
    msg_send($msqid,2,"hello world",true);
    sleep(2);
    if($i++ == 3){
    	// 殺死子進(jìn)程
        posix_kill($pid,SIGILL);
        break;
    }
}
//子進(jìn)程退出回收子進(jìn)程，防止孤兒進(jìn)程
$pid = pcntl_wait($status);
if($pid > 0)
{
    echo "exit pid=".$pid."\n";
}
//msg_remove_queue 函數(shù)移除消息隊(duì)列
if(msg_remove_queue($msqid)){
    echo "remove ok\n";
}