管道PIPE

　　管道用於承載簡稱之間的通訊資料。為了方便理解，可以將管道比作檔案，程序A將資料寫到管道P中，然後程序B從管道P中讀取資料。php提供的管道操作API與操作檔案的API基本一樣，除了建立管道使用posix_mkfifo函式，讀寫等操作均與檔案操作函式相同。當然，你可以直接使用檔案模擬管道，但是那樣無法使用管道的特性了。

　　通過管道通訊的大概思路是，首先建立一個管道，然後子程序向管道中寫入資訊，父程序從管道中讀取資訊，這樣就可以做到父子程序直接實現通訊了。

程式碼如下：

<?php
//建立管道
$pipePath = "/tmp/test.pipe";
if( !file_exists( $pipePath ) ){
    if( !posix_mkfifo( $pipePath, 0666 ) ){
        exit('make pipe false!' . PHP_EOL);
    }
}

//建立程序,子程序寫管道，父程序讀管道
$pid = pcntl_fork();

if( $pid == 0 ){
    //子程序寫管道
    $file = fopen( $pipePath, 'w' );
    fwrite( $file, 'hello world' );
    sleep(1);
    exit();
}else{
    //父程序讀管道
    $file = fopen( $pipePath, 'r' );
    //stream_set_blocking( $file, False );  //設定成讀取非阻塞
    echo fread( $file, 20 ) . PHP_EOL;

    pcntl_wait($status);  //回收子程序
}
 

下面來看一個簡單的實際小例子。兩個子程序向一個檔案中寫資訊，父程序負責監聽檢測這個檔案是否寫入完成，完成之後，講這個檔案copy一份。這裡，父子程序之間通過管道通訊，確認是否完成寫入。

<?php
//建立管道
$pipePath = "/tmp/test.pipe";
if( !file_exists( $pipePath ) ){
    if( !posix_mkfifo( $pipePath, 0666 ) ){
        exit("make pipe fail \n");
    }
}

//建立兩個子程序寫檔案
for( $i = 0; $i < 2; $i++ ){

    $pid = pcntl_fork();
    if( $pid == 0 ){
        file_put_contents( './pipe.log', $i . " write pipe\n", FILE_APPEND );  //寫入檔案
        $file = fopen( $pipePath, 'w' );
        fwrite( $file, $i . "\n" );  //向管道中寫標識，標識寫入完畢。
        fclose( $file );
        exit();  //退出子程序
    }
}


//父程序要做的是：
//1、讀取管道中的寫出狀態,判斷是否完全寫完
//2、拷貝寫好的檔案
//3、刪除管道
//4、回收程序

$file = fopen( $pipePath, 'r' );
$line = 0;
while(1){
    $end = fread( $file, 1024 );
    foreach( str_split( $end ) as $c) {
        if ( "\n" == $c ) {
            $line++;
        }
    }

    if( $line == 2 ){
        copy( './pipe.log', './pipe_copy.log' );
        fclose( $file );
        unlink( $pipePath );
        pcntl_wait( $status );
        exit("ok \n");
    }
}
?>