php管道通信
本人博客：http://www.cnblogs.com/nickbai/
本人GitHub：https://github.com/nick-bai

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

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

　　通過管道通信的大概思路是，首先創(chuàng)建一個管道，然后子進程向管道中寫入信息，父進程從管道中讀取信息，這樣就可以做到父子進程直接實現通信了。/**
?*?author:?NickBai
?*?createTime:?2016/12/2?0002?上午?11:12
?*/
//創(chuàng)建管道
$pipePath?=?"/tmp/test.pipe";
if(?!file_exists(?$pipePath?)?){
????if(?!posix_mkfifo(?$pipePath,?0666?)?){
????????exit('make?pipe?false!'?.?PHP_EOL);
????}
}

//創(chuàng)建進程,子進程寫管道，父進程讀管道
$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行：指定一個管道的路徑，這里跟普通文件沒什么區(qū)別。

　　第9行：通過 posix_mkfifo 函數創(chuàng)建 管道 并且設置讀寫權限為 0666

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

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

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

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

　 ?在linux 下運行該代碼：

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

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

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

下面來看一個簡單的實際小例子。兩個子進程向一個文件中寫信息，父進程負責監(jiān)聽檢測這個文件是否寫入完成，完成之后，講這個文件copy一份。這里，父子進程之間通過管道通信，確認是否完成寫入。/**
?*?author:?NickBai
?*?createTime:?2016/12/2?0002?下午?2:00
?*/
//創(chuàng)建管道
$pipePath?=?"/tmp/test.pipe";
if(?!file_exists(?$pipePath?)?){
????if(?!posix_mkfifo(?$pipePath,?0666?)?){
????????exit("make?pipe?fail?\n");
????}
}

//創(chuàng)建兩個子進程寫文件
for(?$i?=?0;?$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、讀取管道中的寫出狀態(tài),判斷是否完全寫完
//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");
????}
}