Linux进程通信之管道通信2

<?php

/**
 * Created by PhpStorm
 * User: 北溟有鱼QAQ
 * Date: 2021-09-01
 * Time: 15:26
 * Email: 1769360227@qq.com
 */

$file = 'pipe_file';
//检测是否存在管道文件
if(!posix_access($file,POSIX_F_OK))
{
    //创建管道文件
    if(posix_mkfifo($file,0666))
    {
        fprintf(STDOUT,"create ok\r\n");
    }
}
//以读方式打开文件
$fd = fopen($file,'r');

//设置非阻塞方式
stream_set_blocking($fd,0);
while (1)
{
    $data = fread($fd,64);
    if($data){
        fprintf(STDOUT,"pid=%d recv data=%s",getmypid(),$data);
    }
}

fclose($fd);

<?php

/**
 * Created by PhpStorm
 * User: 北溟有鱼QAQ
 * Date: 2021-09-01
 * Time: 15:06
 * Email: 1769360227@qq.com
 */


$file = 'pipe_file';
//检测是否存在管道文件
if(!posix_access($file,POSIX_F_OK))
{
    //创建管道文件
    if(posix_mkfifo($file,0666))
    {
        fprintf(STDOUT,"create ok\r\n");
    }
}

$fd = fopen($file,'w');

while (1)
{

    $data = fgets(STDIN,64);
    if($data){
        $len = fwrite($fd,$data);

        fprintf(STDOUT,"pid=%d write len = %d \n",getmypid(),$len);

    }


}

fclose($fd);