$message_queue_key= ftok(__FILE__, 'a');

if(msg_queue_exists($message_queue_key)){//如果有该消息队列,则删除,用于清空之前队列的无用数据

    msg_remove_queue(msg_get_queue($message_queue_key, 0666));

}

$message_queue= msg_get_queue($message_queue_key, 0666);

$msg_queue= newMsgQueue($message_queue);

<?php

/**

 * Created by PhpStorm.

 * User: tioncico

 * Date: 18-5-29

 * Time: 下午11:00

 */

classMsgQueue

{

    public$queue;

    publicfunction__construct($queue)

    {

        $this->queue = $queue;

    }

    publicfunctionpush($data, $type= 1)

    {

        $result= msg_send($this->queue, $type, $data);

        return$result;

    }

    publicfunctionpop($type= 0,$flags= MSG_IPC_NOWAIT)

    {

        msg_receive($this->queue, $type, $message_type, 1024, $message,true,$flags);

//        var_dump($message_type);

//        msg_receive($this->queue,$type,$message_type,1024,$message);

        return$message;

    }

    publicfunctionclose()

    {

        returnmsg_remove_queue($this->queue);

    }

    /**

     * 创建一个队列（TODO:疑问待解决）

     * @param string $path_name

     * @param string $prop

     * @param string $perms

     * @return array

     */

    publicstaticfunctiongetQueue($path_name= __FILE__, $prop= '1', $perms= '0666')

    {

        $data              = array();

        $data['queue＿key'] = ftok($path_name, $prop);

        $data['queue']     = msg_get_queue($data['queue＿key'], $perms);

        return$data;

    }

}

<?php

include_once'new/MsgQueue.php';

$message_queue_key= ftok(__FILE__, 'a');

$message_queue= msg_get_queue($message_queue_key, 0666);

$queue_obj= newMsgQueue($message_queue);

$pid= pcntl_fork();

if($pid>0){//主进程入列

    while(1){

        $msg= $queue_obj->push((array('a'=>321312,'v'=>'casd')),12456);

        sleep(2);

    }

}else{//子进程出列

    while(1){

        $message= $queue_obj->pop();

        var_dump($message);

        sleep(1);

    }

}