在前一篇文章—— Linux进程间通信——使用匿名管道中,我们看到了如何使用匿名管道来在进程之间传递数据,同时也看到了这个方式的一个缺陷,就是这些进程都由一个共同的祖先进程启动,这给我们在不相关的的进程之间交换数据带来了不方便。这里将会介绍进程的另一种通信方式——命名管道,来解决不相关进程间的通信问题。
一、什么是命名管道
命名管道也被称为FIFO文件,它是一种特殊类型的文件,它在文件系统中以文件名的形式存在,但是它的行为却和之前所讲的没有名字的管道(匿名管道)类似。
由于Linux中所有的事物都可被视为文件,所以对命名管道的使用也就变得与文件操作非常的统一,也使它的使用非常方便,同时我们也可以像平常的文件名一样在命令中使用。
二、创建命名管道
我们可以使用两下函数之一来创建一个命名管道,他们的原型如下:
#include <sys/types.h>
#include <sys/stat.h>
int mkfifo(const char *filename, mode_t mode);
int mknod(const char *filename, mode_t mode | S_IFIFO, (dev_t)0);
这两个函数都能创建一个FIFO文件,注意是创建一个真实存在于文件系统中的文件,filename指定了文件名,而mode则指定了文件的读写权限。
mknod是比较老的函数,而使用mkfifo函数更加简单和规范,所以建议在可能的情况下,尽量使用mkfifo而不是mknod。
三、访问命名管道
1、打开FIFO文件
与打开其他文件一样,FIFO文件也可以使用open调用来打开。注意,mkfifo函数只是创建一个FIFO文件,要使用命名管道还是将其打开。
但是有两点要 注意,1、就是程序不能以O_RDWR模式打开FIFO文件进行读写操作,而其行为也未明确定义,因为如一个管道以读/写方式打开,进程就会读回自己的输出,同时我们通常使用FIFO只是为了单向的数据传递。2、就是传递给open调用的是FIFO的路径名,而不是正常的文件。
打开FIFO文件通常有四种方式,
open(const char *path, O_RDONLY);//1
open(const char *path, O_RDONLY | O_NONBLOCK);//2
open(const char *path, O_WRONLY);//3
open(const char *path, O_WRONLY | O_NONBLOCK);//4
在open函数的调用的第二个参数中,你看到一个陌生的选项O_NONBLOCK,选项O_NONBLOCK表示非阻塞,加上这个选项后,表示open调用是非阻塞的,如果没有这个选项,则表示open调用是阻塞的。
open调用的阻塞是什么一回事呢?很简单,对于以只读方式(O_RDONLY)打开的FIFO文件,如果open调用是阻塞的(即第二个参数为O_RDONLY),除非有一个进程以写方式打开同一个FIFO,否则它不会返回;如果open调用是非阻塞的的(即第二个参数为O_RDONLY | O_NONBLOCK),则即使没有其他进程以写方式打开同一个FIFO文件,open调用将成功并立即返回。
对于以只写方式(O_WRONLY)打开的FIFO文件,如果open调用是阻塞的(即第二个参数为O_WRONLY),open调用将被阻塞,直到有一个进程以只读方式打开同一个FIFO文件为止;如果open调用是非阻塞的(即第二个参数为O_WRONLY | O_NONBLOCK),open总会立即返回,但如果没有其他进程以只读方式打开同一个FIFO文件,open调用将返回-1,并且FIFO也不会被打开。
四、使用FIFO实现进程间的通信
说了这么多,下面就用一个例子程序来说明一下,两个进程如何通过FIFO实现通信吧。这里有两个源文件,一个fifowrite.c,它在需要时创建管道,然后向管道写入数据,数据由文件Data.txt提供,大小为10M,内容全是字符‘0’。另一个源文件为fiforead.c,它从FIFO中读取数据,并把读到的数据保存到另一个文件DataFormFIFO.txt中。为了让程序更加简洁,忽略了有些函数调用是否成功的检查。
fifowrite.c的源代码如下:
#include <unistd.h>
#include <stdlib.h>
#include <fcntl.h>
#include <limits.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h>
#include <string.h>int main()
{const char *fifo_name = "/tmp/my_fifo";int pipe_fd = -1;int data_fd = -1;int res = 0;const int open_mode = O_WRONLY;int bytes_sent = 0;char buffer[PIPE_BUF + 1];if(access(fifo_name, F_OK) == -1){//管道文件不存在//创建命名管道res = mkfifo(fifo_name, 0777);if(res != 0){fprintf(stderr, "Could not create fifo %s\n", fifo_name);exit(EXIT_FAILURE);}}printf("Process %d opening FIFO O_WRONLY\n", getpid());//以只写阻塞方式打开FIFO文件,以只读方式打开数据文件pipe_fd = open(fifo_name, open_mode);data_fd = open("Data.txt", O_RDONLY);printf("Process %d result %d\n", getpid(), pipe_fd);if(pipe_fd != -1){int bytes_read = 0;//向数据文件读取数据bytes_read = read(data_fd, buffer, PIPE_BUF);buffer[bytes_read] = '\0';while(bytes_read > 0){//向FIFO文件写数据res = write(pipe_fd, buffer, bytes_read);if(res == -1){fprintf(stderr, "Write error on pipe\n");exit(EXIT_FAILURE);}//累加写的字节数,并继续读取数据bytes_sent += res;bytes_read = read(data_fd, buffer, PIPE_BUF);buffer[bytes_read] = '\0';}close(pipe_fd);close(data_fd);}elseexit(EXIT_FAILURE);printf("Process %d finished\n", getpid());exit(EXIT_SUCCESS);
}

源文件fiforead.c的代码如下:
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <limits.h>
#include <string.h>int main()
{const char *fifo_name = "/tmp/my_fifo";int pipe_fd = -1;int data_fd = -1;int res = 0;int open_mode = O_RDONLY;char buffer[PIPE_BUF + 1];int bytes_read = 0;int bytes_write = 0;//清空缓冲数组memset(buffer, '\0', sizeof(buffer));printf("Process %d opening FIFO O_RDONLY\n", getpid());//以只读阻塞方式打开管道文件,注意与fifowrite.c文件中的FIFO同名pipe_fd = open(fifo_name, open_mode);//以只写方式创建保存数据的文件data_fd = open("DataFormFIFO.txt", O_WRONLY|O_CREAT, 0644);printf("Process %d result %d\n",getpid(), pipe_fd);if(pipe_fd != -1){do{//读取FIFO中的数据,并把它保存在文件DataFormFIFO.txt文件中res = read(pipe_fd, buffer, PIPE_BUF);bytes_write = write(data_fd, buffer, res);bytes_read += res;}while(res > 0);close(pipe_fd);close(data_fd);}elseexit(EXIT_FAILURE);printf("Process %d finished, %d bytes read\n", getpid(), bytes_read);exit(EXIT_SUCCESS);
}

运行结果如下:
分析:两个程序都使用阻塞模式的FIFO,为了让大家更清楚地看清楚阻塞究竟是怎么一回事,首先我们运行fifowrite.exe,并把它放到后台去运行。这时调用jobs命令,可以看到它确实在后台运行着,过了5秒后,再调用jobs命令,可以看到进程fifowrite.exe还没有结束,它还在继续运行。因为fifowrite.exe进程的open调用是阻塞的,在fiforead.exe还没有运行时,也就没有其他的进程以读方式打开同一个FIFO,所以它就一直在等待,open被阻塞,没有返回。然后,当我们进程fiforead.exe运行时(为了查看性能,在time命令中运行),fifowrite.exe中的open调用返回,进程开始继续工作,然后结束进程。而fiforead.exe的open调用虽然也是阻塞模式,但是fifowrite.exe早已运行,即早有另一个进程以写方式打开同一个FIFO,所以open调用立即返回。
从time中的输出来看,管道的传递效率是非常高的,因为fiforead.exe既要读取数据,还要写数据到文件DataFormFIFO.txt中,10M的数据只用了0.1秒多一点。
此外,如果此时,你在shell中输入如下命令,ls -l /tmp/my_fifo,可以看到如下结果:
证明FIFO文件确实是存在于文件系统中的文件,文件属性的第一个字符为‘p',表示该文件是一个管道。
五、命名管道的安全问题
前面的例子是两个进程之间的通信问题,也就是说,一个进程向FIFO文件写数据,而另一个进程则在FIFO文件中读取数据。试想这样一个问题,只使用一个FIFO文件,如果有多个进程同时向同一个FIFO文件写数据,而只有一个读FIFO进程在同一个FIFO文件中读取数据时,会发生怎么样的情况呢,会发生数据块的相互交错是很正常的?而且个人认为多个不同进程向一个FIFO读进程发送数据是很普通的情况。
为了解决这一问题,就是让写操作的原子化。怎样才能使写操作原子化呢?答案很简单,系统规定:在一个以O_WRONLY(即阻塞方式)打开的FIFO中, 如果写入的数据长度小于等待PIPE_BUF,那么或者写入全部字节,或者一个字节都不写入。如果所有的写请求都是发往一个阻塞的FIFO的,并且每个写记请求的数据长度小于等于PIPE_BUF字节,系统就可以确保数据决不会交错在一起。
六、命名管道与匿名管道的对比
使用匿名管道,则通信的进程之间需要一个父子关系,通信的两个进程一定是由一个共同的祖先进程启动。但是匿名管道没有上面说到的数据交叉的问题。
与使用匿名管道相比,我们可以看到fifowrite.exe和fiforead.exe这两个进程是没有什么必然的联系的,如果硬要说他们具有某种联系,就只能说是它们都访问同一个FIFO文件。它解决了之前在匿名管道中出现的通信的两个进程一定是由一个共同的祖先进程启动的问题。但是为了数据的安全,我们很多时候要采用阻塞的FIFO,让写操作变成原子操作。

Linux进程间通信——使用命名管道相关推荐

  1. linux命名管道进程间通信,《Linux 进程间通信》命名管道:FIFO

    命名管道的主要用途:不相关的进程之间交换数据. 命令行上创建命名管道: $ mkfifo filename 程序中创建命名管道: #include #include int mkfifo(const ...

  2. linux 命名管道通信速度,《Linux 进程间通信》命名管道:FIFO

    命名管道的主要用途:不相关的进程之间交换数据. 命令行上创建命名管道: $ mkfifo filename 程序中创建命名管道: #include #include int mkfifo(const ...

  3. linux进程间通信:命名管道FIFO

    文章目录 FIFO 通信特点 系统调用接口 应用 拥有亲缘关系之间的进程通信 非亲缘关系进程之间的通信 总结 FIFO 通信特点 FIFO文件有文件名 可以像普通文件一样存储在文件系统之中 可以像普通 ...

  4. c语言系统编程六:Linux进程间通信之无名管道

    Linux进程间通信之无名管道 一 文件描述符复制 1.1 dup函数(复制文件描述符) 1.2 dup2函数(复制文件描述符) 二 无名管道的概述 三 无名管道的特点 四 无名管道的创建和使用 4. ...

  5. python命名管道通讯_Python进程间通信的命名管道详解(Windows)

    本文和大家分享的主要是windows系统下,python进程间通信的命名管道相关内容 ,一起来看看吧,希望对大家学习python有所帮助. 在 Windows 上的命名管道主要是通过调用win32 a ...

  6. 【Linux】进程间通信 - 匿名/命名管道与System V共享内存

    目录 前言 一.管道 0.什么是管道 1).管道的概念 2).管道的本质 3).管道指令: "|" 1.匿名管道 1).如何创建匿名管道 2).如何使用匿名管道进行通信 3).匿名 ...

  7. 【Linux系统编程】进程间通信之命名管道

    00. 目录 文章目录 00. 目录 01. 命名管道概述 02. 命名管道创建 03. 命名管道特性 04. 命名管道非阻塞 05. 附录 01. 命名管道概述 无名管道,由于没有名字,只能用于亲缘 ...

  8. Linux系统编程——进程间通信:命名管道(FIFO)

    命名管道的概述 无名管道,由于没有名字,只能用于亲缘关系的进程间通信(更多详情,请看<无名管道>).为了克服这个缺点,提出了命名管道(FIFO),也叫有名管道.FIFO 文件. 命名管道( ...

  9. linux c之命名管道简单使用

    1.介绍FIFO(命名管道) 管道有局限性,只能在具有亲缘关系的进程间通信,但是命名管道克服了这个问题,可以实现无亲缘关系的进程之间的通信 API介绍: /* FIFO 命名管道 */ /* * 函数 ...

最新文章

  1. UE4风格化场景设计入门指南 Stylized Station – The Environment Artist’s Survival Kit
  2. Decoders对于语义分割的重要性 | CVPR 2019
  3. angular之表单
  4. 关于raid5 5e 5ee的性能 对比及其数据恢复原理
  5. 【CodeForces - 1096D】Easy Problem(dp,思维)
  6. 动态ram依靠什么存储信息_处理器内存系统1(ROM,RAM,数据存储顺序)
  7. 简单的企业网站后台的实现之流程
  8. Vmware之锁定文件失败
  9. java分布式缓存memcached_分布式缓存系统Memcached学习心得
  10. 创建 VSTO 工作簿的 ClickOnce 安装包
  11. lol服务器维护2021,英雄联盟客户端清理:2021进度与后续计划
  12. 江苏省发布我国首个公路行业BIM省地方标准
  13. 什么是测试用例?什么是测试脚本?两者有什么关系?为什么要编写测试用例?测试用例的作用是什么?
  14. linux驱动开发:mma7660 sensor的配置
  15. css设置十六进制背景色和透明度
  16. 项目审查图片报404找不到
  17. 用ssh方法scp,从本地传输文件到服务器
  18. coreldraw带圈字符_coreldraw中如何使字体围绕一个圆形排列?
  19. 天津室内设计培训班:3分钟带你了解室内设计的6大原则
  20. BEA CEO庄思浩清华大学演讲(2002/12)

热门文章

  1. CAT - 监控平台之装配篇
  2. web.xml 配置 contextConfigLocation
  3. Java-Collections的sort方法对 list 进行排序
  4. 上海卓道医疗完成千万级Pre-A轮融资,幂方资本领投...
  5. p1198bzoj1012 最大数
  6. Spring都用到了那些设计模式(3)
  7. [转载]java中try 与catch的使用
  8. 2011年8月5日星期五
  9. C++11 用户自定义字面量
  10. C++ 临时变量的常量性