进程间通信之命名管道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

智能推荐

“码农”一词是怎么来的?为什么中国程序员会被码农?程序员和农民有什么关联?-程序员宅基地

文章浏览阅读1.7w次。原创: 思齐大神 来源:蚁开源社区很多同学会问,IT行业在中国并不是特别差的行业,而程序员的工资也并不低,但为什么中国的程序员总被称作码农或者说是苦逼的程序员?中国的程序员生活和欧美的有什么不一样?​先说两个小段子街边,一对情侣在吵架。女孩对男孩说,“我们分手吧!”男孩沉默半天,开口问道,“我能再说最后一句话吗?”“说吧,婆婆妈妈的。”“我会编程……”“会编程有个屁用啊,现在到处都是会编程的人!”男孩涨红了脸,接着说道,“我会编程……我会变成…童话里,你爱的那个天使……”【程序._码农

Java初学者也能看的懂的AQS_aqs对接-程序员宅基地

文章浏览阅读259次。Java初学者也能看的懂的AQS学习AQS之前,你需要了解以下内容,如果不是很清楚,那么理解本文会有点吃力。(Java初学者得会一下内容)synchronizedCASLock前言synchronized首先我们知道synchronized是Java关键字,上锁释放锁等一切操作都是由JVM控制的。我们只能通过虚拟机的C++才能去研究其底层实现。我们除了判断synchronized是作为方法的修饰符,还是当做同步代码块使用以外,没什么需要我们程序员操作的。cas一种自旋的原子操作,也是J_aqs对接

【JZOJ5262】【GDOI2018模拟8.12】树(DP,性质题)_gdoi2018省选模拟树-程序员宅基地

文章浏览阅读460次。DescriptionSolution首先我们可以知道两个性质:1、路径u-v和路径v-w可以合并为路径u-w;2、路径u1-v1加路径u2-v2和路径u1-v2加路径u2-v1是等价的(就是起始点和终点可以互换) 那么知道这些性质之后就很好做了。我们只用知道每个点多少次做起点和多少次做终点。 我们设f[i]表示满足i子树的需求i上的值要是多少。 那么枚举i的所有儿子,判断a[i]-f[i],_gdoi2018省选模拟树

[PTA]7-65 字符串替换 (15 分)含思路_字符串替换pta-程序员宅基地

文章浏览阅读2.8k次,点赞4次,收藏28次。我们进行简单的运算即可实现倒序。_字符串替换pta

linux网络设置_linux如何开启网络连接-程序员宅基地

文章浏览阅读4k次,点赞5次,收藏22次。traceroute 180.101.50.188————————测试到180.101.50.188有多少个网关。vim /etc/sysconfig/static-routes——————————修改。netstat -antp | grep 22———————查看端口号22的相关信息。systemctl restart network————————————重启。systemctl restart network————————重新启动。_linux如何开启网络连接

pr中,视频导入后,视频画面大小显示不完整应该如何解决?_avi视频到pr里会放大-程序员宅基地

文章浏览阅读4w次,点赞23次,收藏6次。本人pr小白,今天编辑视频时候遇到了问题,也解决了,所以分享记录一下。问题一视频下面原来有字幕的,可是导入的视频变大了,现在看不到了怎么办?还有就是,频导入之后画质好像变糊了又是为什么?解决:将箭头放到要编辑的视频那里,右击,然后点击设为帧大小这样完整的视频就出来了。问题二如果视频模糊,就是序列设置的不对 要先新建序列一般的都是1920×1080本人博客:https://blog.csdn.net/weixin_46654114本人b站求关注:https://space.bi_avi视频到pr里会放大

随便推点

SeetaFace2 Android 平台编译_seetafacerecognizer2.0.ats-程序员宅基地

文章浏览阅读4.1k次。SeetaFace2 Android 平台编译项目地址:https://github.com/seetafaceengine/SeetaFace2SeetaFace2 人脸识别引擎包括了搭建一套全自动人脸识别系统所需的三个核心模块,即:人脸检测模块 FaceDetector、面部关键点定位模块 FaceLandmarker 以及人脸特征提取与比对模块 FaceRecognizer。面部关键点定位支持 5 点 和 81 点定位,两个辅助模块 FaceTracker 和 QualityAssessor 用_seetafacerecognizer2.0.ats

Oracle删除约束和主键的语句_oracle删除主键的sql语句-程序员宅基地

文章浏览阅读3.2w次,点赞4次,收藏34次。1.删除约束语句:alter table 表名 drop constraint 约束名;alter table mz_sf4 drop constraint pk_id1;2.删除主键语句:alter table 表名 drop primary key;alter table mz_sf3 drop primary key;如果出错:ORA-02273:此唯一主键已_oracle删除主键的sql语句

MySQL~InnoDB的备份和主从复制-程序员宅基地

文章浏览阅读989次,点赞9次,收藏13次。这份面试题几乎包含了他在一年内遇到的所有面试题以及答案,甚至包括面试中的细节对话以及语录,可谓是细节到极致,甚至简历优化和怎么投简历更容易得到面试机会也包括在内!也包括教你怎么去获得一些大厂,比如阿里,腾讯的内推名额!某位名人说过成功是靠99%的汗水和1%的机遇得到的,而你想获得那1%的机遇你首先就得付出99%的汗水!你只有朝着你的目标一步一步坚持不懈的走下去你才能有机会获得成功!成功只会留给那些有准备的人!《一线大厂Java面试题解析+核心总结学习笔记+最新讲解视频+实战项目源码》点击传送门即可获取。

大数据平台核心技术 学堂在线 雨课堂 第八讲作业答案 人文交流月_vertectorization-程序员宅基地

文章浏览阅读2k次。关于Vertectorization哪些是正确的( )相对于其他编程模型,sql在大数据领域有哪些好处( )哪些部分适合做codegen( )关于内存计算描述不正确的有( )_vertectorization

java汉字拼音简码_java生成首字母拼音简码的总结-程序员宅基地

文章浏览阅读306次。百度找到了某论坛高人写的java(具体论坛记不清了),直接用来调用,再次非常感谢,基本上实现了我的需求package MD5;import java.util.Scanner;public class ChineseToPinYin {/*** 汉字转拼音缩写** @param str* 要转换的汉字字符串* @return String 拼音缩写*/public Strin..._java生成拼音码

C++ 数据结构——堆排序_数据结构堆排序c++-程序员宅基地

文章浏览阅读93次。/* 堆排序 */#include <iostream>using namespace std;int *data;void Sift(int k,int last){ int i,j,temp; i=k;j=2*i+1; while (j<=last) { if(j<last&&data[j]<data[j+1]) j++; if(data[i]>data[j]) _数据结构堆排序c++

推荐文章

热门文章

相关标签