Linux中進程的通信方式有信號,管道,共享內存,消息隊列socket等。其中管道是*nix系統進程間通信的最古老形式,所有*nix都提供這種通信方式。管道是一種半雙工的通信機制,也就是說,它只能一端用來讀,另外一端用來寫;另外,管道只能用來在具有公共祖先的兩個進程之間通信。管道通信遵循先進先出的原理,并且數據只能被讀取一次,當此段數據被讀取后,馬上會從數據中消失,這一點很重要。
Linux上,創建管道使用pipe函數,當它執行后,會產生兩個文件描述符,分別為讀端和寫端。單個進程中的管道幾乎沒有任何作用,通常會先調用pipe,然后調用fork,從而創建從父進程到子進程的IPC通道。
Linux中,我們經常會使用到管道,例如用cat命令查看一個大文件時,一頁不能全部顯示,我們可以通過cat xxx | more來分頁顯示,又比如搜索文件里的內容可以用 cat xxx | grep search來進行,這里我們都用到了管道。接下來我會用python編寫一段自動分頁顯示的程序,而不用手動來使用管道。
#!/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,增加執行權限之后,運行 scat.py 文件名,系統就會自動讀取文件的內容并分頁,與使用 cat 文件名 | more 的效果是一模一樣的。在上面的代碼中,用到了前幾篇博客中說的fork,dup2和exec系列函數。
首先是程序創建了一個管道,系統fork之后,父進程關閉其讀端,子進程關閉其寫端,接下來父進程讀取傳遞過來的文件名,并把內容通過管道的寫入端口寫入管道里,然后關閉寫入端口,并等待子進程的結束。子進程在關閉寫入端口后,把讀取端口重定向到進程的標準輸入,子進程就能自動接收到管道傳遞過來的數據,最后用execl函數調用系統的more程序用來處理傳遞過來的數據,這樣,就輕松實現的分頁的效果。
pipe是半雙工的通信機制,如果進程間要使用全雙工的通信,可以創建兩條管道來達到全雙工的效果。另外,pipe匿名管道只能用來在擁有同一個父進程的進程間通信,*nix提供另外一個fifo(命名管道)可以讓任意的進程之間實現通信,會在接下來的博客中來講。
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

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