php進程間通信--有名管道

　　php進行進程間通信的方式有好幾種：消息隊列，管道，共享內存，socket，信號。本文介紹的是通過有名管道的方式。　　

　　管道PIPE

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

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

　　代碼如下：

<?php
/**
 * author: NickBai
 * createTime: 2016/12/2 0002 上午 11:12
 */
//創建管道
$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);  //回收子進程
}

　　注意：本代碼只能在linux下運行，並且只能在php-cli模式下。

　　第7行：指定一個管道的路徑，這里跟普通文件沒什么區別。

　　第9行：通過 posix_mkfifo 函數創建 管道 並且設置讀寫權限為 0666

　　第15行：通過 pcntl_fork函數創建一個子進程。注意從現在開始，程序將會被分成兩個進程來執行。 pcntl_fork 函數 很特殊，它調用一次擁有 多個返回值。在父進程中：它返回 子進程的ID 這個值是 大於0 的。在子進程中，它返回0。當返回 -1 時表示

創建進程失敗。

     第17行：兩個進程根據當前進程所獲得的$pid的值不同，而進入不同的分支。

　  第18~22行：子進程打開管道，並向其中寫入hello world ，然后進入休眠，休眠結束之后，退出。

　  第25~29行：父進程打開管道，並進行讀取，最后執行 29行的代碼回收掉子進程。這里面兩個地方是阻塞的，首先是默認讀的地方，要等待子進程發出exit命令之后，才能返回數據。還有就是回收進程的 pcntl_wait方法。要等到進程退出。

　  在linux 下運行該代碼：

　　會看到程序阻塞 1秒 之后，輸出 hello world。

　　當我們打開 第 26 行代碼,並將 27行改為 var_dump(fread( $file, 20 )) . PHP_EOL; 時，運行程序：

　　能看到程序立馬輸出 空串，並等待 1秒 中之后退出。這是因為。當讀取是非阻塞的情況下，父進程進行讀取信息的時候，不會等待立馬有信息，管道中沒有信息，也會立馬返回。然后執行到 29行回收子進程的時候，阻塞等待子進程退出后結束。

　　

　　下面來看一個簡單的實際小例子。兩個子進程向一個文件中寫信息，父進程負責監聽檢測這個文件是否寫入完成，完成之后，講這個文件copy一份。這里，父子進程之間通過管道通信，確認是否完成寫入。

<?php
/**
 * author: NickBai
 * createTime: 2016/12/2 0002 下午 2:00
 */
//創建管道
$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");
    }
}