php管線通訊
本人部落格：http://www.cnblogs.com/nickbai/
本人GitHub：https://github.com/nick-bai

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

　　管道用於承載簡(jiǎn)稱之間的通訊資料。為了方便理解，可以將管道比喻為文件，進(jìn)程A將資料寫(xiě)到管道P中，然後進(jìn)程B從管道P中讀取資料。 php提供的管道操作API與操作文件的API基本上一樣，除了建立管道使用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>//建立管道<br>$pipePath?=?"/tmp/test.pipe";<br>if(?!file_exists(?$pipePath??){<br>?p. ,?0666?)?){<br>????????exit('make?pipe?false!'?.?PHP_EOL);<br>????}＜}<br>}<br>處理程序();<br><br>if( $pid?==?0?){<br>????//子程序?qū)懭牍艿?lt;br>????$file?=?fopen(?$pipePath,?'w'?);<br>??1); <br>????exit() ;<br>}else{<br>????//父程式讀取管道<br>????$file?=?fopen(?$pipePath,?'r'?);<br>???//stream_set_blocking(F1file)<br>?echo?fread(?$ file,?20?)?.?PHP_EOL;<br><br>????pcntl_wait($status);??//回收子程序<br>}<br> ? ? ?<br>在：本程式碼時(shí)只能於<br>　　第7行：指定一個(gè)管道的路徑，這裡跟普通文件沒(méi)什麼區(qū)別。 　　第9行：透過(guò) posix_mkfifo 函數(shù)建立 管道 並且設(shè)定讀寫(xiě)權(quán)限為 0666

　　第15行：透過(guò) pcntl_fork函數(shù)建立一個(gè)子程序。注意從現(xiàn)在開(kāi)始，程式將會(huì)被分成兩個(gè)流程來(lái)執(zhí)行。 pcntl_fork 函數(shù) 很特殊，它呼叫一次擁有 多個(gè)回傳值。在父進(jìn)程中：它回傳 子進(jìn)程的ID 這個(gè)值是 大於0 的。在子進(jìn)程中，它回傳0。當(dāng)傳回 -1 時(shí)表示建立進(jìn)程失敗。

? 第17行：兩個(gè)進(jìn)程依目前進(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è)地方是阻塞的，首先是預(yù)設(shè)讀的地方，要等待子程序發(fā)出exit指令之後，才能回傳資料。還有就是回收進(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)行程式：


　能看到程式立刻輸出中之後退出。這是因?yàn)?。?dāng)讀取是非阻塞的情況下，父進(jìn)程進(jìn)行讀取訊息的時(shí)候，不會(huì)等待立刻有訊息，管道中沒(méi)有訊息，也會(huì)立刻回傳。然後執(zhí)行到 29行回收子程序的時(shí)候，阻塞等待子程序退出後結(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ě)入。
/**
?*?author:?NickBai?*?createTime:?2016/12/2?0002?下午?2:00<br>?*/<br>//建立管道<br>$pipePath?=?"/tmp/test.pipe";<br>if(?!file_exists(?$pipePath?)?){<br>????if(?!posix_mkfifo(?$pipePath,?0666?)?){??); }<br>}<br><br>//建立兩個(gè)子程序?qū)懭霗n案<br>for (?$i?=?0;?$i?<br>????$pid?=?pcntl_fork(); './pipe.log',?$i?.?"?write pipen",?FILE_APPEND?);??//寫(xiě)入檔案<br>????????$file?=?fopen(?$pipePath,?'w'?); /向管道中寫(xiě)標(biāo)識(shí)，標(biāo)識(shí)寫(xiě)入完畢。 <br>????????fclose(?$file?);<br>????????exit();??//退出子程序<br>????exit();??//退出子程序<br>???完<br>//2、拷貝寫(xiě)好的文件<br>//3、刪除管道<br>//4、回收程序<br><br>$file?=?fopen(?$pipePath,?'r'?);<br>$line?=?0 ){<br>????$end?=?fread(?$file,?1024?);<br>????foreach(?str_split(?$end?)?as?==$c)H <br>????????????$line++;<br>????????}<br>????}<br>?(?$line?==?2?){<br>????????copy(?'./pipe.log',?'./pipe_copy.log'?);?????$pipePath?);<br>????????pcntl_wait(?$status?);<br> exit("ok?n");<br>????}<br>}<br><br><br><br><br> <br>