PHP进程通信之管道与消息队列（二十三节）

<?php
// 管道文件绝对路径
$pipe_file = __DIR__.DIRECTORY_SEPARATOR.'test.pipe';
// 如果这个文件存在，那么使用posix_mkfifo()的时候是返回false，否则，成功返回true
if( !file_exists( $pipe_file ) ){
    if( !posix_mkfifo( $pipe_file, 0666 ) ){
        exit( 'create pipe error.'.PHP_EOL );
    }
}
// fork出一个子进程
$pid = pcntl_fork();
if( $pid < 0 ){
    exit( 'fork error'.PHP_EOL );
} else if( 0 == $pid ) {
    // 在子进程中，打开命名管道，并写入一段文本
    $file = fopen( $pipe_file, "w" );
    fwrite( $file, "I am children." );
    fclose( $file );
    // 然后以读方式再次打开管道文件，并从中读取数据
    $file = fopen( $pipe_file, "r" );
    // ⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️
    // fread 管道上
    $content = fread( $file, 1024 );
    echo $content.PHP_EOL;
    exit;
} else if( $pid > 0 ) {
    // 在父进程中，打开命名管道，然后读取文本
    $file = fopen( $pipe_file, "r" );
    $content = fread( $file, 1024 );
    echo $content.PHP_EOL;
    fclose( $file );
    // 以写方式打开管道，向其中写数据
    $file = fopen( $pipe_file, "w" );
    fwrite( $file, "I am father." );
    fclose( $file );
    // 注意此处再次阻塞，等待回收子进程，避免僵尸进程
    pcntl_wait( $status );
}

<?php
// 管道文件绝对路径
$pipe_file = __DIR__.DIRECTORY_SEPARATOR.'test.pipe';
// 如果这个文件存在，那么使用posix_mkfifo()的时候是返回false，否则，成功返回true
if( !file_exists( $pipe_file ) ){
    if( !posix_mkfifo( $pipe_file, 0666 ) ){
        exit( 'create pipe error.'.PHP_EOL );
    }
}
// fork出一个子进程
$pid = pcntl_fork();
if( $pid < 0 ){
    exit( 'fork error'.PHP_EOL );
} else if( 0 == $pid ) {
    $pid = posix_getpid();
    // 在子进程中，以读方式打开命名管道
    echo "{$pid} child before fopen FIFO".PHP_EOL;
    $file = fopen( $pipe_file, "r" );
    echo "{$pid} child after fopen FIFO".PHP_EOL;
} else if( $pid > 0 ) {
    // 在父进程中，打开命名管道，然后读取文本
    echo "父进程等待读取数据".PHP_EOL;
}

<?php
// 管道文件绝对路径
$pipe_file = __DIR__.DIRECTORY_SEPARATOR.'test.pipe';
// 如果这个文件存在，那么使用posix_mkfifo()的时候是返回false，否则，成功返回true
if( !file_exists( $pipe_file ) ){
    if( !posix_mkfifo( $pipe_file, 0666 ) ){
        exit( 'create pipe error.'.PHP_EOL );
    }
}
// fork出一个子进程
$pid = pcntl_fork();
if( $pid < 0 ){
    exit( 'fork error'.PHP_EOL );
} else if( 0 == $pid ) {
    $pid = posix_getpid();
    // 在子进程中，打开命名管道，并写入一段文本
    echo "{$pid} child before fopen FIFO".PHP_EOL;
    $file = fopen( $pipe_file, "r" );
    echo "{$pid} child after fopen FIFO".PHP_EOL;
} else if( $pid > 0 ) {
    // 在父进程中，打开命名管道，然后读取文本
    // ⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️⚠️
    // 这里也是以 r 方式打开的管道，而不是 w
    echo "父进程等待读取数据".PHP_EOL;
    $file = fopen( $pipe_file, "r" );
}

<?php
$handle = popen('ls -l', 'r');
$read = fread($handle, 2096);
echo $read;
pclose($handle);

<?php
// 这个数组是描述选项，它的构成是这样的
// 它的索引是文件描述符
// 它的索引对应的值是一个数组，数组的第一个元素有两个可选值pipe或文件
// 数组的第二个元素就是r w 或者a mode
// 下面的case里，众所周知
// 0表示标准输入
// 1表示标准输出
// 2表示标准错误
// 任何一个进程打开后，默认都会打开0 1 2三个文件描述符
// 这里通过a_pipe_desc将新进程默认打开的0 1 2文件描述
// 指向自己配置的pipe管道和file文件
// 你还可以自己手动往数组里添加新的文件描述符
$a_pipe_desc = array(
    0 => array("pipe", "r"),
    1 => array("pipe", "w"),
    2 => array("file", "./debug.log", "a"),
    // 比如，你还有有一个文件描述符5
    // 你想让5为一个file
    //5 => array("file", "./test.log", "a"),
);
// 这个测试PHP程序的工作目录，我设置为当前了
$s_cwd = './';

// 这个管道就是在「PHP程序」与「bash程序」之间
// 这个管道是双向的，管道就在$a_pipes中
$r_process = proc_open('bash', $a_pipe_desc, $a_pipes, $s_cwd, NULL);

// 可以打印一下看看
print_r( $a_pipes );

// 而通过proc_get_status可以获取「PHP程序」
// 打开的子进程「bash」的相关信息
$a_process_info = proc_get_status($r_process);
print_r( $a_process_info );

// 啥意思呢？就是说：
// PHP程序向$a_pipes[0]中写内容，而bash从$a_pipes[0]中读内容
// PHP程序从$a_pipes[0]中读内容，而bash向$a_pipes[1]中写内容
// 而错误将会被记录到
fwrite($a_pipes[0], 'ls -l');
fclose($a_pipes[0]);
echo stream_get_contents($a_pipes[1]);
fclose($a_pipes[1]);
// 一定要及时关闭不用的管道，正如前面posix_mkfifo()演示的那样
// 管道如果处理不好，很容易让程序陷入无限等待中，出现异常
proc_close($r_process);

<?php
// 使用ftok创建一个键名，注意这个函数的第二个参数“需要一个字符的字符串”
$key = ftok( __DIR__, 'a' );
// 然后使用msg_get_queue创建一个消息队列
$queue = msg_get_queue( $key, 0666 );
// 使用msg_stat_queue函数可以查看这个消息队列的信息，而使用msg_set_queue函数则可以修改这些信息
//var_dump( msg_stat_queue( $queue ) );
// fork进程
$pid = pcntl_fork();
if( $pid < 0 ){
    exit( 'fork error'.PHP_EOL );
} else if( $pid > 0 ) {
    // 在父进程中
    // 使用msg_receive()函数获取消息
    msg_receive( $queue, 0, $msgtype, 1024, $message );
    echo $message.PHP_EOL;
    // 用完了记得清理删除消息队列
    msg_remove_queue( $queue );
    pcntl_wait( $status );
} else if( 0 == $pid ) {
    // 在子进程中
    // 向消息队列中写入消息
    // 使用msg_send()向消息队列中写入消息，具体可以参考文档内容
    msg_send( $queue, 1, "helloword" );
    exit;
}

<?php
// 使用ftok创建一个键名，注意这个函数的第二个参数“需要一个字符的字符串”
$key = ftok( "/Users/didi/python", "a" );
// 然后使用msg_get_queue创建一个消息队列
$queue = msg_get_queue( $key, 0666 );
// 使用msg_stat_queue函数可以查看这个消息队列的信息，而使用msg_set_queue函数则可以修改这些信息
//var_dump( msg_stat_queue( $queue ) );
// 向消息队列中写入消息
// 使用msg_send()向消息队列中写入消息，具体可以参考文档内容
msg_send( $queue, 1, "helloword" );

#coding:utf-8
import sysv_ipc

# Main
msg_queue_key = sysv_ipc.ftok( "/Users/didi/python", 97 )
msg_queue     = sysv_ipc.MessageQueue( msg_queue_key, sysv_ipc.IPC_CREAT, 0666 )
content = msg_queue.receive()
print( content )