Linux中進(jìn)程的通信方式有信號(hào),管道,共享內(nèi)存,消息隊(duì)列socket等。其中管道是*nix系統(tǒng)進(jìn)程間通信的最古老形式,所有*nix都提供這種通信方式。管道是一種半雙工的通信機(jī)制,也就是說(shuō),它只能一端用來(lái)讀,另外一端用來(lái)寫(xiě);另外,管道只能用來(lái)在具有公共祖先的兩個(gè)進(jìn)程之間通信。管道通信遵循先進(jìn)先出的原理,并且數(shù)據(jù)只能被讀取一次,當(dāng)此段數(shù)據(jù)被讀取后,馬上會(huì)從數(shù)據(jù)中消失,這一點(diǎn)很重要。
Linux上,創(chuàng)建管道使用pipe函數(shù),當(dāng)它執(zhí)行后,會(huì)產(chǎn)生兩個(gè)文件描述符,分別為讀端和寫(xiě)端。單個(gè)進(jìn)程中的管道幾乎沒(méi)有任何作用,通常會(huì)先調(diào)用pipe,然后調(diào)用fork,從而創(chuàng)建從父進(jìn)程到子進(jìn)程的IPC通道。
Linux中,我們經(jīng)常會(huì)使用到管道,例如用cat命令查看一個(gè)大文件時(shí),一頁(yè)不能全部顯示,我們可以通過(guò)cat xxx | more來(lái)分頁(yè)顯示,又比如搜索文件里的內(nèi)容可以用 cat xxx | grep search來(lái)進(jìn)行,這里我們都用到了管道。接下來(lái)我會(huì)用python編寫(xiě)一段自動(dòng)分頁(yè)顯示的程序,而不用手動(dòng)來(lái)使用管道。
#!/usr/bin/env python import os,sys if not sys.argv[1:]: print "No filename input" sys.exit(1) try: fp = open(sys.argv[1],"r") except IOError,msg: sys.exit(msg) pi=os.pipe() pid=os.fork() if pid: #parent os.close(pi[0]) #close read pipe #write to pipe line=fp.readline() while line: os.write(pi[1],line) line=fp.readline() #close write pipe os.close(pi[1]) #wait for chile os.waitpid(pid,0) else: os.close(pi[1]) #close write pipe #put pipe read to stdin os.dup2(pi[0],sys.stdin.fileno()) os.close(pi[0]) os.execl("/bin/more","more")
把這段代碼存為scat.py,增加執(zhí)行權(quán)限之后,運(yùn)行 scat.py 文件名,系統(tǒng)就會(huì)自動(dòng)讀取文件的內(nèi)容并分頁(yè),與使用 cat 文件名 | more 的效果是一模一樣的。在上面的代碼中,用到了前幾篇博客中說(shuō)的fork,dup2和exec系列函數(shù)。
首先是程序創(chuàng)建了一個(gè)管道,系統(tǒng)fork之后,父進(jìn)程關(guān)閉其讀端,子進(jìn)程關(guān)閉其寫(xiě)端,接下來(lái)父進(jìn)程讀取傳遞過(guò)來(lái)的文件名,并把內(nèi)容通過(guò)管道的寫(xiě)入端口寫(xiě)入管道里,然后關(guān)閉寫(xiě)入端口,并等待子進(jìn)程的結(jié)束。子進(jìn)程在關(guān)閉寫(xiě)入端口后,把讀取端口重定向到進(jìn)程的標(biāo)準(zhǔn)輸入,子進(jìn)程就能自動(dòng)接收到管道傳遞過(guò)來(lái)的數(shù)據(jù),最后用execl函數(shù)調(diào)用系統(tǒng)的more程序用來(lái)處理傳遞過(guò)來(lái)的數(shù)據(jù),這樣,就輕松實(shí)現(xiàn)的分頁(yè)的效果。
pipe是半雙工的通信機(jī)制,如果進(jìn)程間要使用全雙工的通信,可以創(chuàng)建兩條管道來(lái)達(dá)到全雙工的效果。另外,pipe匿名管道只能用來(lái)在擁有同一個(gè)父進(jìn)程的進(jìn)程間通信,*nix提供另外一個(gè)fifo(命名管道)可以讓任意的進(jìn)程之間實(shí)現(xiàn)通信,會(huì)在接下來(lái)的博客中來(lái)講。
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號(hào)聯(lián)系: 360901061
您的支持是博主寫(xiě)作最大的動(dòng)力,如果您喜歡我的文章,感覺(jué)我的文章對(duì)您有幫助,請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點(diǎn)擊下面給點(diǎn)支持吧,站長(zhǎng)非常感激您!手機(jī)微信長(zhǎng)按不能支付解決辦法:請(qǐng)將微信支付二維碼保存到相冊(cè),切換到微信,然后點(diǎn)擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
