命名管道是一種用于進程間通信的機制,能夠在沒有親緣關系的進程之間進行數據交換。它們被稱為命名管道,因為它們通過文件系統中的一個特殊文件來實現通信,盡管這個文件實際上并不存儲數據,而是維護一個內存中的緩沖區,執行先進先出的數據傳輸。
要在文件系統中創建一個命名管道,可以使用mkfifo()或mknod()函數。創建后,一個進程可以以寫入模式打開該管道并向其中寫入數據,而另一個進程則可以以讀取模式打開該管道并從中讀取數據。數據在命名管道中的流動是單向的。
從命令行創建命名管道可以使用以下命令:
mkfifo filename
以p開頭的文件表示它是一個管道文件。
命名管道的讀寫操作是阻塞的,且管道文件的大小始終為0,因為數據存儲在內存中。
命名管道也可以通過編程方式創建,使用以下函數:
為了管理命名管道的生命周期,可以創建一個namedPipe.hpp文件,提供管道創建和關閉的函數:
#pragma once #include<iostream> #include <sys> #include <sys> #include<String> #include<cerrno> #include<cstdio> #include<unistd.h> using namespace std; <p>const string comm_path ="./myfifo";</p><p>int CreateNamedPipe(const string & path) { int res =mkfifo(path.c_str(),0666); if(res!=0) { perror("mkfifo"); } return res; }</p><p>int RemoveNamedPipe(const string & path) { int res =unlink(path.c_str()); if(res!=0) { perror("unlink"); } return res; } </unistd.h></cstdio></cerrno></string></sys></sys></iostream>
在server.cc中,可以使用這些函數來創建和刪除命名管道:
#include"namedPipe.hpp"</p><p>int main() { CreateNamedPipe(comm_path); RemoveNamedPipe(comm_path); return 0; }
為了簡化操作,可以將這些功能封裝在一個類中:
class NamedPipe { public: NamedPipe(const string &path) : _fifo_path(path) { int res = mkfifo(path.c_str(), 0666); if (res != 0) { perror("mkfifo"); } } ~NamedPipe() { int res = unlink(_fifo_path.c_str()); if (res != 0) { perror("unlink"); } } private: const string _fifo_path; };
這樣,主函數中只需創建一個NamedPipe對象即可:
NamedPipe myfifo(comm_path);
管道會在對象銷毀時自動釋放。
進一步地,可以在類中添加其他功能,如打開管道、讀取和寫入數據:
const string comm_path = "./myfifo";</p><h1>define DefaultFd -1</h1><h1>define Creater 1</h1><h1>define User 2</h1><h1>define Read O_RDONLY</h1><h1>define Write O_WRONLY</h1><p>class NamedPipe { private: bool OpenNamedPipe(int mode) { _fd = open(_fifo_path.c_str(), mode); if (_fd
隱藏打開文件的函數操作,并定義宏常量Read和Write來指定打開文件的方式。初始化時傳遞執行者身份(創建者還是使用者),以決定是否需要再次創建管道文件。
int ReadNamedPipe(string <em> out)//輸出型參數,輸入型const& 輸入輸出型& { char buffer[BaseSize]; int n = read(_fd,buffer,sizeof(buffer)); if(n>0) { buffer[n]=0; </em>out = buffer; }</p><pre class="brush:php;toolbar:false">return n;
} int WriteNamedPipe(const string & in) { write(_fd,in.c_str(),in.size()); }