【Linux的那些事】關於FIFO

最近在處理多進程間進行數據通信(基本上屬於1伺服器多客戶端類型的),而且通信的數據屬於視頻數據,量比較大,權衡再三,決定使用FIFO來處理.

伺服器與每個客戶端之間用一個專屬的FIFO有名管道,這就存在一個阻塞的問題,不過可以通過添加O_NONBLOCK來設置為非阻塞狀態.

下面是我寫的一個測試程序,包含客戶端和伺服器端,伺服器與每個客戶端之間單獨的fifo有名管道

客戶端：

#include <sys/types.h> 
#include <sys/stat.h> 
#include <unistd.h> 
#include <errno.h> 
#include <stdio.h> 
#include <stdlib.h> 
#include <fcntl.h> 
#include <limits.h> 
#include <time.h> 
 
int main(int argc,char** argv){ 
    int fd; 
    int len; 
    char buf[PIPE_BUF];         
                 
    time_t tp; 
    if(argc!=2){ 
        printf("Usage:client [Name]"); 
    } 
    if((fd = open(argv[1],O_WRONLY))<0){ 
        perror("open"); 
        exit(EXIT_FAILURE); 
    } 
    while(1){ 
        time(&tp); 
        len = sprintf(buf,"wrfifo: %d sends %s",getpid(),ctime(&tp)); 
        if((write(fd,buf,len 1))<0){ 
            perror("write"); 
            close(fd); 
            exit(EXIT_FAILURE); 
        } 
    } 
    close(fd); 
    exit(EXIT_SUCCESS); 
} 

伺服器端：

#include <sys/types.h> 
#include <sys/stat.h> 
#include <unistd.h> 
#include <errno.h> 
        
                 #include <stdio.h> 
#include <stdlib.h> 
#include <fcntl.h> 
#include <limits.h> 
//#define PIPE_BUF 8192 
int main(void){ 
    int fd1,fd2; 
    int dumy1,dumy2; 
    int len1,len2; 
    char buf1[PIPE_BUF],buf2[PIPE_BUF]; 
    mode_t mode = 0666; 
    unlink("fifo1"); 
    unlink("fifo2"); 
    if((mkfifo("fifo1",mode))<0){ 
        perror("mkfifo1"); 
        exit(EXIT_FAILURE); 
    } 
    if((mkfifo("fifo2",mode))<0){ 
        perror("mkfifo2"); 
        exit(EXIT_FAILURE); 
    }         
                 
    printf("open fifo1n"); 
    if((fd1=open("fifo1",O_RDONLY|O_NONBLOCK))<0){ 
//  if((fd1=open("fifo1",O_RDONLY,0))<0){ 
        perror("open1"); 
        exit(EXIT_FAILURE); 
    } 
    printf("open fifo2n"); 
    if((fd2=open("fifo2",O_RDONLY|O_NONBLOCK))<0){ 
//  if((fd2=open("fifo2",O_RDONLY,0))<0){ 
        perror("open2"); 
        exit(EXIT_FAILURE); 
    } 
    printf("loopn"); 
    while(1){ 
        len1 = read(fd1,buf1,PIPE_BUF-1); 
        if(len1>0) 
            printf("rdfifo1 read: %s",buf1); 
        len2 = read(fd2,buf2,PIPE_BUF-1); 
        if(len2>0) 
            printf("rdfifo2 read: %s"        
                 ,buf2);     
    } 
    close(fd1); 
    close(fd2); 
    printf("exitn"); 
    exit(EXIT_SUCCESS); 
} 

將上述程序編譯

分別在三個超級終端中運行 ./server ./client fifo1 ./client fifo2

如果把server.c裡面的open的參數中的O_NONBLOCK參數去掉,server的程序就會阻塞在第一個open操作中！

FIFO有一個缺點就是,管道名必須是伺服器端和客戶端協商好的.