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

php進(jìn)行進(jìn)程間通信的方式有好幾種：消息隊(duì)列，管道，共享內(nèi)存，socket，信號(hào)。本文介紹的是通過(guò)有名管道的方式。　　

　　管道PIPE

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

　　通過(guò)管道通信的大概思路是，首先創(chuàng)建一個(gè)管道，然后子進(jìn)程向管道中寫(xiě)入信息，父進(jìn)程從管道中讀取信息，這樣就可以做到父子進(jìn)程直接實(shí)現(xiàn)通信了。<?php<br>/**<br>?*?author:?NickBai<br>?*?createTime:?2016/12/2?0002?上午?11:12<br>?*/<br>//創(chuàng)建管道<br>$pipePath?=?"/tmp/test.pipe";<br>if(?!file_exists(?$pipePath?)?){<br>????if(?!posix_mkfifo(?$pipePath,?0666?)?){<br>????????exit('make?pipe?false!'?.?PHP_EOL);<br>????}<br>}<br><br>//創(chuàng)建進(jìn)程,子進(jìn)程寫(xiě)管道，父進(jìn)程讀管道<br>$pid?=?pcntl_fork();<br><br>if(?$pid?==?0?){<br>????//子進(jìn)程寫(xiě)管道<br>????$file?=?fopen(?$pipePath,?'w'?);<br>????fwrite(?$file,?'hello?world'?);<br>????sleep(1);<br>????exit();<br>}else{<br>????//父進(jìn)程讀管道<br>????$file?=?fopen(?$pipePath,?'r'?);<br>????//stream_set_blocking(?$file,?False?);??//設(shè)置成讀取非阻塞<br>????echo?fread(?$file,?20?)?.?PHP_EOL;<br><br>????pcntl_wait($status);??//回收子進(jìn)程<br>} ? ? ?注意：本代碼只能在linux下運(yùn)行，并且只能在php-cli模式下。
　　第7行：指定一個(gè)管道的路徑，這里跟普通文件沒(méi)什么區(qū)別。

　　第9行：通過(guò) posix_mkfifo 函數(shù)創(chuàng)建 管道 并且設(shè)置讀寫(xiě)權(quán)限為 0666

　　第15行：通過(guò) pcntl_fork函數(shù)創(chuàng)建一個(gè)子進(jìn)程。注意從現(xiàn)在開(kāi)始，程序?qū)?huì)被分成兩個(gè)進(jìn)程來(lái)執(zhí)行。 pcntl_fork 函數(shù) 很特殊，它調(diào)用一次擁有 多個(gè)返回值。在父進(jìn)程中：它返回 子進(jìn)程的ID 這個(gè)值是 大于0 的。在子進(jìn)程中，它返回0。當(dāng)返回 -1 時(shí)表示創(chuàng)建進(jìn)程失敗。

? 第17行：兩個(gè)進(jìn)程根據(jù)當(dāng)前進(jìn)程所獲得的$pid的值不同，而進(jìn)入不同的分支。

　 ?第18~22行：子進(jìn)程打開(kāi)管道，并向其中寫(xiě)入hello world ，然后進(jìn)入休眠，休眠結(jié)束之后，退出。

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

　 ?在linux 下運(yùn)行該代碼：

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

　　當(dāng)我們打開(kāi) 第 26 行代碼,并將 27行改為 var_dump(fread( $file, 20 )) . PHP_EOL; 時(shí)，運(yùn)行程序：

　能看到程序立馬輸出 空串，并等待 1秒 中之后退出。這是因?yàn)椤．?dāng)讀取是非阻塞的情況下，父進(jìn)程進(jìn)行讀取信息的時(shí)候，不會(huì)等待立馬有信息，管道中沒(méi)有信息，也會(huì)立馬返回。然后執(zhí)行到 29行回收子進(jìn)程的時(shí)候，阻塞等待子進(jìn)程退出后結(jié)束。

下面來(lái)看一個(gè)簡(jiǎn)單的實(shí)際小例子。兩個(gè)子進(jìn)程向一個(gè)文件中寫(xiě)信息，父進(jìn)程負(fù)責(zé)監(jiān)聽(tīng)檢測(cè)這個(gè)文件是否寫(xiě)入完成，完成之后，講這個(gè)文件copy一份。這里，父子進(jìn)程之間通過(guò)管道通信，確認(rèn)是否完成寫(xiě)入。<?php<br>/**<br>?*?author:?NickBai<br>?*?createTime:?2016/12/2?0002?下午?2:00<br>?*/<br>//創(chuàng)建管道<br>$pipePath?=?"/tmp/test.pipe";<br>if(?!file_exists(?$pipePath?)?){<br>????if(?!posix_mkfifo(?$pipePath,?0666?)?){<br>????????exit("make?pipe?fail?\n");<br>????}<br>}<br><br>//創(chuàng)建兩個(gè)子進(jìn)程寫(xiě)文件<br>for(?$i?=?0;?$i?<?2;?$i++?){<br><br>????$pid?=?pcntl_fork();<br>????if(?$pid?==?0?){<br>????????file_put_contents(?'./pipe.log',?$i?.?"?write?pipe\n",?FILE_APPEND?);??//寫(xiě)入文件<br>????????$file?=?fopen(?$pipePath,?'w'?);<br>????????fwrite(?$file,?$i?.?"\n"?);??//向管道中寫(xiě)標(biāo)識(shí)，標(biāo)識(shí)寫(xiě)入完畢。<br>????????fclose(?$file?);<br>????????exit();??//退出子進(jìn)程<br>????}<br>}<br><br>//父進(jìn)程要做的是：<br>//1、讀取管道中的寫(xiě)出狀態(tài),判斷是否完全寫(xiě)完<br>//2、拷貝寫(xiě)好的文件<br>//3、刪除管道<br>//4、回收進(jìn)程<br><br>$file?=?fopen(?$pipePath,?'r'?);<br>$line?=?0;<br>while(1){<br>????$end?=?fread(?$file,?1024?);<br>????foreach(?str_split(?$end?)?as?$c)?{<br>????????if?(?"\n"?==?$c?)?{<br>????????????$line++;<br>????????}<br>????}<br><br>????if(?$line?==?2?){<br>????????copy(?'./pipe.log',?'./pipe_copy.log'?);<br>????????fclose(?$file?);<br>????????unlink(?$pipePath?);<br>????????pcntl_wait(?$status?);<br>????????exit("ok?\n");<br>????}<br>}