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

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

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

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

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

<?php
$key = ftok('demo5.php',"x");//將文件與ID轉換為一個key
$msqid = msg_get_queue($key);
// fork 一個子進程
$pid = pcntl_fork();
if($pid == 0){
    while(1){
    // MSG_IPC_NOWAIT【啟用非阻塞】 msg_receive 函數(shù)其實是封裝 linux c msgrcv 系統(tǒng)調用函數(shù)，如果設置為非阻塞，函數(shù)調用次數(shù)非常高，會非常消耗cpu資源
    //阻塞模式調用函數(shù)次數(shù)低，有數(shù)據(jù)才返回，對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轉換為一個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){
    	// 殺死子進程
        posix_kill($pid,SIGILL);
        break;
    }
}
//子進程退出回收子進程，防止孤兒進程
$pid = pcntl_wait($status);
if($pid > 0)
{
    echo "exit pid=".$pid."\n";
}

<?php
$key = ftok('demo5.php',"x");//將文件與ID轉換為一個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){
    	// 殺死子進程
        posix_kill($pid,SIGILL);
        break;
    }
}
//子進程退出回收子進程，防止孤兒進程
$pid = pcntl_wait($status);
if($pid > 0)
{
    echo "exit pid=".$pid."\n";
}
//msg_remove_queue 函數(shù)移除消息隊列
if(msg_remove_queue($msqid)){
    echo "remove ok\n";
}