进程间通信之命名管道FIFO通信_设计两个程序,要求用命名管道fifo,实现进程间的文件传输功能,即实现进程a将文件fi-程序员宅基地

技术标签: 数据  通信  内核  Linux应用编程  工作  

概念

何谓命名管道

  • 匿名管道应用的一个限制就是只能在具有共同祖先(具有亲缘关系)的进程间通信。
  • 如果我们想在不相关的进程之间交换数据,可以使用FIFO文件来做这项工作,它经常被称为命名管道。
  • 命名管道是一种特殊类型的文件。
    FIFO是Linux基础文件类型中的一种。但FIFO文件在磁盘上没有数据块,仅仅用来标识内核中一条通道。各进程可以打开这个文件进行read/write,实际上是在读写内核通道,这样就实现了进程间通信。

匿名管道与命名管道的区别

  • 匿名管道由pipe函数创建并打开–一个步骤
  • 命名管道由mkfifo函数创建,打开用open–两个步骤
  • FIFO(命名管道)与pipe(匿名管道)之间唯一的区别在它们创建与打开的方式不同,一但这些工作完成之后,它们具有相同的语义。

创建一个命名管道

  • 命名管道可以从命令行上创建,命令行方法是使用下面这个命令:
    $ mkfifo filename
  • 命名管道也可以从程序里创建,相关函数有:
    int mkfifo(const char *filename,mode_t );
  • 参考手册man 3 mkfifo

命名管道的打开规则

  • 如果当前打开操作是为而打开FIFO时
    • O_NONBLOCK disable:阻塞直到有相应进程为写而打开该FIFO
    • O_NONBLOCK enable:立刻返回成功–意味着非阻塞模式下按读的方式打开永远成功
  • 如果当前打开操作是为写而打开FIFO时

    • O_NONBLOCK disable:阻塞直到有相应进程为读而打开该FIFO
    • O_NONBLOCK enable:立刻返回失败–意味着非阻塞模式下按写的方式打开永远失败,错误码为ENXIO
  • mknod
    管道文件不能使用vi打开–vi不能打开看管道内容

一旦使用mkfifo创建了一个FIFO,就可以使用open打开它,常见的文件I/O函数都可用于fifo。如:close、read、write、unlink等。

命名管道的读写规则

同匿名管道

示例代码

  • 写FIFO
#include <unistd.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <fcntl.h>

#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <signal.h>
#include <sys/time.h>

/*
利用管道,两个进程间进行文件复制。
fifow
读文件1.txt    
    写入管道
fifor   
    读管道
    写入2.txt文件
    */

int main(int argc, char *argv[])
{
  int infd;
  int outfd;
  char buf[1024];
    int n = 0;

    //建立管道文件
    mkfifo("fifop", 0644);


    //按只读方式 打开现有文件--文件作为输入
    infd = open("./1.txt", O_RDONLY);
    if (infd == -1)
    {
        printf("infd open() err..\n");
        exit(0);
    }


    //打开管道文件,准备写数据--FIFO管道作为输出
    //outfd = open("fifop", O_WRONLY | O_NONBLOCK);
    outfd = open("fifop", O_WRONLY ); //默认的阻塞模式下按只写方式打开会阻塞--直到有另一个进程按只读方式打开该FIFO
    if (outfd == -1)
    {
        printf("infd open() err..\n");
        exit(0);
    }


    //从文件中读数据写入管道文件
    while ( (n = read(infd, buf, sizeof(buf))) > 0)
    {
        write(outfd, buf, n);   
    }
    close (infd);
    close (outfd);

    printf("fifow 写管道文件 success\n");
    return 0;
}
  • 读FIFO
#include <unistd.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <fcntl.h>

#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <signal.h>
#include <sys/time.h>



int main(int argc, char *argv[])
{   

  int infd;
    int outfd;
  char buf[1024];
    int n = 0;

  //打开2.txt 准备写数据--文件作为输出
    outfd = open("./2.txt", O_WRONLY | O_CREAT | O_TRUNC, 0644); //O_TRUNC 打开文件清空
    if (outfd == -1)
    {
        printf("open()  2.txt err..\n");
        exit(0);
    }


    //打开管道文件,准备读数据--FIFO管道作为输入
    infd = open("fifop", O_RDONLY);//默认的阻塞模式下按只读方式打开会阻塞--直到有另一个进程按只写方式打开该FIFO
    if (infd == -1)
    {
        printf("open err ... \n");
        exit(0);
    }


    //从文件中读数据写入管道文件
    while ( (n = read(infd, buf, 1024)) > 0)
    {
        write(outfd, buf, n);   
    }

    close (infd);
    close (outfd);
    unlink("fifop");//删除FIFO--直到该进程结束才真正删除FIFO,参考Ulink的用法

    printf("fifor 读管道文件 success\n");
    return 0;
}
  • 测试非阻塞模式下打开FIFO的规则
#include <unistd.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <sys/types.h>
#include <fcntl.h>

#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>
#include <signal.h>
#include <sys/time.h>

//测试再FIFO存在的前提下,非阻塞模式下,按只写方式打开会失败
int main(int argc, char *argv[])
{
    //建立管道文件
    int outfd = 0;

  mkfifo("fifop", 0644);
  outfd = open("fifop", O_RDONLY | O_NONBLOCK);//非阻塞模式下按只读方式打开永远成功--返回描述符

    if (outfd != -1)
    {
    printf("outfd : %d\n",outfd);
        printf("infd open() O_RDONLY | O_NONBLOCK OK!!\n");
    }
    close(outfd);
    //打开管道文件,准备写数据
    outfd = open("fifop", O_WRONLY | O_NONBLOCK);//非阻塞模式下按只写方式打开会永远失败--返回-1
    if (outfd == -1)
    {
        printf("infd open() O_WRONLY | O_NONBLOCK err..\n");
        exit(0);
    }

    return 0;
}
  • 常用来修改文件是否阻塞的函数模板
int fcntl(int fd, int cmd);
int fcntl(int fd, int cmd, long arg);

int flags = 0;
flags = fcntl(infd, F_GETFD);
flags = flags | O_NONBLOCK;

fcntl(infd, F_SETFD, flags);
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/lzjsqn/article/details/53860091

智能推荐

CPU如何跑分_cpu跑分教程-程序员宅基地

文章浏览阅读1k次。烤CPU的时候,占用率满了,CPU频率的槽有一些还是空的…… 有没有能跑分的软件?好像有的【聊电Jing】你的CPU性能如何? 来跑个分测试看看吧! | Cinebench R15 & R20 使用教学_哔哩哔哩_bilibili 好像还是免费的Cinebench - Maxon Cinebench - Microsoft Store Apps 频率为什么就是超不过3Ghz? 多核,100度了? 可能频率最高只能这么高,再高可能就烧掉了…… 多核结果.................._cpu跑分教程

最大流问题的Ford-Fulkerson解法_ford capacity 详解-程序员宅基地

文章浏览阅读498次。这是一种方法,而不是算法,因为它包含具有不同运行时间的几种实现。该方法依赖于三种重要思想:残留网络,增广路径和割我们先简单介绍下Ford-Fulkerson方法的基本思想。首先需要了解的是Ford-Fulkerson是一种迭代的方法。开始时,对所有的u,v属于V,f(u,v)=0(这里f(u,v)代表u到v的边当前流量),即初始状态时流的值为0。在每次迭代中,可以通过寻找一个“增广路径”来增加_ford capacity 详解

Windows10下多版本CUDA的安装与切换 超详细教程_cuda版本-程序员宅基地

文章浏览阅读1.9w次,点赞69次,收藏379次。当我们跑深度学习的代码时,有时会遇到上古的代码,环境比较老,是低版本的 CUDA,此时我们就需要多个 CUDA 版本,并能灵活切换。本文是在已有CUDA11.2的环境下安装CUDA9.2。Windows10下多版本CUDA的安装与切换保姆级教学。_cuda版本

C语言——数组逆置(内含递归实现)-程序员宅基地

文章浏览阅读5k次,点赞5次,收藏25次。一.什么是数组的逆置呢?int a[10]={1,2,3,4,5,6,7,8,9,10};将数组变为 a[10]={10,9,8,7,6,5,4,3,2,1};这就叫做数组的逆置。二.1.循环实现数组的逆置这个是我们在初学C语言时最容易的实现方法!a.通过for循环实现//通过循环完成对数组的逆置#include<stdio.h>#define size 10void Inversion(int[], int);int main(void){ i_数组逆置

esp32-cam Thonny 烧录以及通信-程序员宅基地

文章浏览阅读229次,点赞4次,收藏3次。链接:https://pan.baidu.com/s/1cBsrCJ_TATFsuVhVdr0VmA?IO1和GND不再短接。重新插拔一下,就可以了。

字符,字节和编码-程序员宅基地

文章浏览阅读39次。级别:中级摘要:本文介绍了字符与编码的发展过程,相关概念的正确理解。举例说明了一些实际应用中,编码的实现方法。然后,本文讲述了通常对字符与编码的几种误解,由于这些误解而导致乱码产生的原因,以及消除乱码的办法。本文的内容涵盖了“中文问题”,“乱码问题”。掌握编码问题的关键是正确地理解相关概念,编码所涉及的技术其实是很简单的。因此,阅读本文时需要慢读多想,多思考。引言“字符与编码”...

随便推点

话题的发布与订阅_话题订阅频率和发布频率一样-程序员宅基地

文章浏览阅读2.6k次,点赞3次,收藏11次。Ros话题发布与订阅节点的编写(C++)_话题订阅频率和发布频率一样

Qt Creator 安装 VLD_qtcreater vld-程序员宅基地

文章浏览阅读509次。Qt Creator 安装 VLD2015-04-14 16:52:55你好L阅读数 2325更多分类专栏:qt版权声明:本文为博主原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。本文链接:https://blog.csdn.net/lin_jianbin/article/details/45044459一、环境说明1、VLD内存..._qtcreater vld

Linux 开发环境工具[zt]-程序员宅基地

文章浏览阅读120次。软件集成开发环境(代码编辑、浏览、编译、调试)Emacs http://www.gnu.org/software/emacs/Source-Navigator 5.2b2 http://sourceforge.net/projects/sourcenavAnjuta http://anjuta.sourceforge...._linux上安装flawfinder

java小易——Spring_spring的beanfactory是hashmap吗-程序员宅基地

文章浏览阅读109次。SpringIoC DI AOPspring底层用的是ConcurrentHashMap解耦合:工厂模式:需要一个模板控制反转 IoC将原来有动作发起者(Main)控制创建对象的行为改成由中间的工厂来创建对象的行为的过程叫做IoC一个类与工厂之间如果Ioc以后,这个时候,动作发起者(Main)已经不能明确的知道自己获得到的对象,是不是自己想要的对象了,因为这个对象的创建的权利与交给我这个对象的权利全部转移到了工厂上了所用包:DOM4j解析XML文件lazy-init = _spring的beanfactory是hashmap吗

温故而知新:部分常见的图像数学运算处理算法的用途_图像处理算啊-程序员宅基地

文章浏览阅读1.3k次,点赞29次,收藏24次。本文将图像处理中常用的数学运算算法及其对图像的作用做了个汇总介绍,有助于图像处理时针对对应场景快速选择合适的数学算法。_图像处理算啊

EM Agent Fatal agent error: State Manager failed at Startup_check agent status retcode=1-程序员宅基地

文章浏览阅读1.1k次。EM 不定期异常宕机,问题重复出现,之前几次因为忙于其它事,无力兼顾,等回头处理时,发现EM已恢复正常。这次问题又重现,准备彻底解决,过程如下:1. 重新启动EM失败,报错:/u01/oracle/agent/core/12.1.0.5.0/bin/emctl status agentOracle Enterprise Manager Cloud Control 12c Relea_check agent status retcode=1