使用PHP的ftok()函数实现基于linux下系统级进程间消息通信demon(消息队列模式)

php

$key = ftok(__DIR__, ‘p‘);

echo($key . PHP_EOL);

#队列资源句柄
$queue = msg_get_queue($key);
//var_dump($queue);

#队列状态信息
$info = msg_stat_queue($queue);
//var_export($info);

$i = 0;

while($i++ )
{
    msg_send($queue, 1, ‘吃饭了吗? ‘ . $i , false, false);
}

php
$key = ftok(__DIR__, ‘p‘);

$queue = msg_get_queue($key);

echo("queue_key:" . $key . PHP_EOL);

$i = 0;

//这里是阻塞模式，不会因为while(true)而陷入死循环,内存爆满的情况
while(true)
{

    msg_receive($queue, 0, $msg_type, 1024, $message, false, 0);

    echo("i: " . $i . ‘, message: ‘ .$message);

    sleep(2);//增加耗时方便展示演示效果
}

[root@guangzhou msg]# php msg_send.php
1879117732
#为了增加演示效果，开了三个窗口同时运行msg_receive.php，分别传参one, two, three
[root@guangzhou msg]# php msg_receive.php one
queue_key:1879117732
i: 0, index: one, message: 吃饭了吗? 1
i: 0, index: one, message: 吃饭了吗? 2
i: 0, index: one, message: 吃饭了吗? 5
i: 0, index: one, message: 吃饭了吗? 8


[root@guangzhou msg]# php msg_receive.php two
queue_key:1879117732
i: 0, index: two, message: 吃饭了吗? 3
i: 0, index: two, message: 吃饭了吗? 6
i: 0, index: two, message: 吃饭了吗? 9


[root@guangzhou msg]# php msg_receive.php three
queue_key:1879117732
i: 0, index: three, message: 吃饭了吗? 4
i: 0, index: three, message: 吃饭了吗? 7
i: 0, index: three, message: 吃饭了吗? 10

#通过脚本输出可以看到类似redis队列读取的效果
#最后如果不需要可以销毁队列msg_remove_queue($queue)