Linux IPC实践(3) --具名FIFO

FIFO具名/命名管道

(匿名)管道应用的一个限制就是只能在具有共同祖先(具有亲缘关系)的进程间通信。

如果我们想在不相关的进程之间交换数据,可以使用FIFO文件来做这项工作，它经常被称为命名管道;命名管道是一种特殊类型的文件.

创建一个命名管道

1)命名管道可以从命令行上创建:

$ mkfifo <filename>

2)命名管道在程序里创建：

       #include <sys/types.h>#include <sys/stat.h>int mkfifo(const char *pathname, mode_t mode);

//示例
int main()
{if (mkfifo("p2", 0644) == -1)err_exit("mkfifo error");
}

FIFO与PIPE的区别:

1) 匿名管道由pipe函数创建并打开。

命名管道由mkfifo函数创建，打开用open

2) FIFO（命名管道）与pipe（匿名管道）之间唯一的区别在它们创建与打开的方式不同，一但这些工作完成之后，它们具有相同的语义 (The only difference between pipes and FIFOs is the manner in which they are created and opened.

Once these tasks have been accomplished, I/O on pipes and FIFOs has exactly the same semantics.)。

命名管道的打开规则

1)读打开FIFO

O_NONBLOCK disable(阻塞)：阻塞直到有相应进程为写而打开该FIFO

O_NONBLOCK enable(非阻塞)：立刻返回成功

//示例1: 阻塞, 只读打开
int main()
{int fd = open("fifo", O_RDONLY);if (fd == -1)err_exit("FIFO open error");cout << "fifo O_RDONLY open success" << endl;
}

//示例2: 只读, 非阻塞打开
int main()
{int fd = open("fifo", O_RDONLY|O_NONBLOCK);if (fd == -1)err_exit("FIFO open error");cout << "fifo O_RDONLY open success" << endl;
}

2)写打开FIFO

O_NONBLOCK disable(阻塞)：阻塞直到有相应进程为读而打开该FIFO

O_NONBLOCK enable(非阻塞)：立刻返回失败，错误码为ENXIO

//示例1: 阻塞, 只写打开
int main()
{int fd = open("fifo", O_WRONLY);if (fd == -1)err_exit("FIFO open error");cout << "FIFO O_WRONLY open success" << endl;
}

//示例2: 非阻塞, 只写打开
int main()
{int fd = open("fifo", O_WRONLY|O_NONBLOCK);if (fd == -1)err_exit("FIFO open error");cout << "FIFO O_WRONLY open success" << endl;
}

命名管道的读写规则

同匿名管道

/**FIFO示例, 两个进程通过FIFO对拷数据:利用管道,两个进程间进行文件复制。
1.进程writefifo:
(1)读文件(文件名从命令行参数中获取)
(2)写入管道myFifo(管道由该进程创建)
(3)关闭文件及管道2.进程readfifo:
(1)读管道myFifo
(2)写入文件[该文件有进程创建并打开]
(3)关闭文件
(4)删除管道
*/

//1:writefifo
int main(int argc, char *argv[])
{if (argc < 2)err_quit("Usage: ./writefifo <read-file-name>");// 创建管道if (mkfifo("myFifo", 0644) == -1)err_exit("mkfifo error");int outfd = open("myFifo", O_WRONLY);   //打开FIFOint infd = open(argv[1], O_RDONLY);     //打开文件if (outfd == -1 || infd == -1)err_exit("open file/fifo error");char buf[BUFSIZ];int readBytes;while ((readBytes = read(infd, buf, sizeof(buf))) > 0){write(outfd, buf, readBytes);}close(infd);close(outfd);
}

//2:readfifo
int main(int argc, char *argv[])
{if (argc < 2)err_quit("Usage: ./writefifo <write-file-name>");int outfd = open(argv[1], O_WRONLY|O_CREAT|O_TRUNC, 0644);  //创建并打卡文件int infd = open("myFifo", O_RDONLY);    //打开FIFOif (infd == -1 || outfd == -1)err_exit("open file/fifo error");char buf[BUFSIZ];int readBytes;while ((readBytes = read(infd, buf, sizeof(buf))) > 0){write(outfd, buf, readBytes);}close(outfd);unlink("myFifo");   //删除FIFO
}

Linux IPC实践(3) --具名FIFO相关推荐

Linux IPC实践(13) --System V IPC综合实践
实践:实现一个先进先出的共享内存shmfifo 使用消息队列即可实现消息的先进先出(FIFO), 但是使用共享内存实现消息的先进先出则更加快速; 我们首先完成C语言版本的shmfifo(基于过程调用) ...
Linux IPC实践(8) --共享内存/内存映射
概述共享内存区是最快的IPC形式.一旦这样的内存映射到共享它的进程的地址空间,这些进程间数据传递不再涉及到内核,换句话说是进程不再通过执行进入内核的系统调用来传递彼此的数据(如图). 共享内存 VS ...
Linux IPC实践(11) --System V信号量(1)
信号量API #include <sys/types.h> #include <sys/ipc.h> #include <sys/sem.h> int semget ...
Linux IPC实践(9) --System V共享内存
共享内存API #include <sys/ipc.h> #include <sys/shm.h>int shmget(key_t key, size_t size, int ...
Linux IPC实践(7) --Posix消息队列
1. 创建/获取一个消息队列 #include <fcntl.h> /* For O_* constants */ #include <sys/stat.h> /* For m ...
Linux IPC实践(4) --System V消息队列(1)
消息队列概述消息队列提供了一个从一个进程向另外一个进程发送一块数据的方法(仅局限于本机); 每个数据块都被认为是有一个类型,接收者进程接收的数据块可以有不同的类型值. 消息队列也有管道一样的不足: ...
Linux IPC实践(6) --System V消息队列(3)
消息队列综合案例消息队列实现回射客户/服务器 server进程接收时, 指定msgtyp为0, 从队首不断接收消息 server进程发送时, 将mtype指定为接收到的client进程的pid cl ...
Linux IPC实践(12) --System V信号量(2)
实践1:信号量实现进程互斥父子进程执行流程如下: 父进程子进程 P P O(print) X(print) sleep sleep O(print) X(print) V V sleep slee ...
Linux IPC实践(10) --Posix共享内存
1. 创建/获取一个共享内存 #include <sys/mman.h> #include <sys/stat.h> /* For mode constants */ #inc ...

Linux IPC实践(3) --具名FIFO

FIFO具名/命名管道

Linux IPC实践(3) --具名FIFO相关推荐

最新文章

热门文章