首页 > 系统相关 >进程间通信----管道篇

进程间通信----管道篇

时间:2024-08-31 09:26:10浏览次数:16  
标签:---- 阻塞 间通信 管道 fd 进程 include buf

目录

一丶  无名管道

1.  特点

2.  读写特性

3.  函数接口

二丶有名管道

1.特点:

2.函数接口

3. 读写特性


一丶  无名管道

1.  特点

        1.  只能用于具有亲缘关系的进程之间的通信
        2.  半双工的通信模式,具有固定的读端和写端
        3.  管道可以看成是一种特殊的文件,对于它的读写可以使用文件IO如read、write函数.
        4.  管道是基于文件描述符的通信方式。当一个管道建立时,它会创建两个文件描述符fd[0]和fd[1]。其中fd[0]固定用于读管道,而fd[1]固定用于写管道。

2.  读写特性

1.  当管道中无数据时,读操作会阻塞;
        管道中无数据时,将写端关闭,读操作会立即返回

2.  管道中装满(管道大小64K)数据写阻塞,一旦有4k空间,写继续

3.  只有在管道的读端存在时,向管道中写入数据才有意义。否则,会导致管道破裂,向管道中写入数据的进程将收到内核传来的SIGPIPE信号 (通常Broken pipe错误)。Broken pipe:管道破裂

3.  函数接口

int pipe(int fd[2])
功能:创建无名管道
参数:文件描述符 fd[0]:读端  fd[1]:写端 
返回值:成功 0
      失败 -1
#include <stdio.h>
#include <unistd.h>

int main(int argc, char const *argv[])
{
    char buf[65536] = "";
    int fd[2] = {0}; //fd[0]代表读端,fd[1]代表写端
    if (pipe(fd) < 0)
    {
        perror("pipe err");
        return -1;
    }
    printf("%d %d\n", fd[0], fd[1]);

    //结构类似队列,先进先出
    //1. 当管道中无数据时,读阻塞。
    // read(fd[0], buf, 32);
    // printf("%s\n", buf);

    //但是关闭写端就不一样了
    //当管道中有数据关闭写端可以读出数据,无数据时关闭写端读操作会立即返回。
    // write(fd[1], "hello", 5);
    // close(fd[1]);
    // read(fd[0], buf, 32);
    // printf("%s\n", buf);

    //2. 当管道中写满数据时,写阻塞,管道空间大小为64K
    // write(fd[1], buf, 65536);
    // printf("full!\n");
    //write(fd[1], "a", 1);  //当管道写满时不能再继续写了会阻塞

    //写满一次之后,当管道中至少有4K空间时(也就是读出4K),才可以继续写,否则阻塞。
    // read(fd[0], buf, 4096); //换成4095后面再写就阻塞了,因为不到4K空间
    // write(fd[1], "a", 1);

    //3. 当读端关闭,往管道中写入数据无意义,会造成管道破裂,进程收到内核发送的SIGPIPE信号。
    close(fd[0]);
    write(fd[1], "a", 1);
    printf("read close\n");

    return 0;
}
练习:父子进程实现通信,父进程循环从终端输入数据,子进程循环打印数据,当输入quit结束。

提示:不需要加同步机制, 因为pipe无数据时读会阻塞。
先创建管道再fork,这样父子进程可以使用同一个无名管道。

#include <stdio.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/wait.h>

int main(int argc, char const *argv[])
{
    pid_t pid;
    char buf[32] = "";
    int fd[2];
    if (pipe(fd) < 0)
    {
        perror("pipe err");
        return -1;
    }
    printf("%d %d\n", fd[0], fd[1]);

    pid = fork();
    if (pid < 0)
    {
        perror("fork err");
        return -1;
    }
    else if (pid == 0) //循环打印, quit结束
    {
        while (1)
        {
            read(fd[0], buf, 32); //读出管道中内容存入buf
            if (strcmp(buf, "quit") == 0)
                break;
            printf("%s\n", buf);//将buf内容打印到终端
        }
    }
    else //循环输入,quit结束
    {
        while (1)
        {
            scanf("%s", buf);
            write(fd[1], buf, 32); //把输入buf内容写入管道
            if (strcmp(buf, "quit") == 0)
                break;
        }
        wait(NULL);
    }

    return 0;
}

二丶有名管道

1.特点:

        1.  有名管道可以使互不相关的两个进程互相通信
        2.  有名管道可以通过路径名来指出,并且在文件系统中可见,但内容存放在内存中
        3.  进程通过文件IO操作有名管道
        4.  有名管道遵循先进先出规则
        5.  不支持如lseek() 操作

2.函数接口

#include <sys/types.h>
#include <sys/stat.h>

int mkfifo(const char *filename,mode_t mode);
功能:创健有名管道
参数:filename:有名管道文件名
       mode:权限
返回值:成功:0        爱no
       失败:-1,并设置errno号

示例:

对于这种情况我并不希望它直接return输出,而是我们存在这个文件,我直接就继续向下执行就可以了

解决方案:

补充:

1.  当管道文件存在(报错提示file exists)时的处理方式:
        判断errno的值为EEXIST时,只是打印提示语句,if(errno == EEXIST)
2.  注意代码中出现errno,需要添加头文件#include <errno.h>

3. 读写特性

1.  只写方式,写阻塞(阻塞在打开文件的位置),一直到另一个进程把读打开
2.  只读方式,读阻塞(阻塞在打开文件的位置),一直到另一个进程把写打开
3.  可读可写,如果管道中没有数据,读阻塞

练习:两个进程实现通信,一个进程输入字符串,另一个进程打印数据,当输入quit时结束

gcc input.c -o in 输入字符串
gcc output.c -o out 打印数据
./in ./out

有名管道和无名管道的区别:

无名管道

有名管道

使用场景

只能在亲缘关系进程

不相关的任意进程

特点

有固定的读端和写端

文件IO进行操作

先入先出原则

不支持lseek操作

存放在存储的内核空间

在文件系统中存在管道文件

文件IO进行操作

先入先出原则

不支持lseek操作

存放在存储的内核空间

操作方式

直接进行读写操作

先打开管道文件,再读写操作

函数

pipe

mkfifo

标签:----,阻塞,间通信,管道,fd,进程,include,buf
From: https://blog.csdn.net/qq_64136247/article/details/141726277

相关文章

  • 载波监听多址接入碰撞检测 CSMA/CD(carrier sense multiple access collision detecti
    载波监听多址接入/碰撞检测CSMA/CD(carriersensemultipleaccess/collisiondetection)概念解析在总线局域网使用的协议多址接入MA:多个站连接在同一条线上,竞争使用总线。载波监听CS:每一个站在发送帧之前都要检测一下总线上是否有其他站点在发送帧(”先听后说“)......
  • linux下基本指令(持续更新)
    目录1.adduser 2.passwd3.userdel4.su-5.ls 6.pwd​编辑7.cd8.touch9.mkdir ......
  • 数据中心安全建设解决方案(Word完整版)
    第一章解决方案1.1建设需求1.2建设思路1.3总体方案信息安全系统整体部署架构图1.3.1IP准入控制系统1.3.2防泄密技术的选择1.3.3主机账号生命周期管理系统1.3.4数据库账号生命周期管理系统1.3.5双因素认证系统1.3.6数据库审计系统1.3.7数据脱敏系统1.3.......
  • 数位 dp
    \(\texttt{0x00}\)简介数位dp解决的是与数字有关的一类计数问题,在求解过程中常把一个数字的每一位都拆开来看,比如十进制下就是把千位、百位、十位、个位上的数字都拆开来看,其他进制类比十进制。数位dp的问题一般比较显眼,有几个常见形式:要求统计满足一定条件的数的数量(即......
  • CSS 高级区块效果——WEB开发系列25
    CSS提供了多种工具和属性,使我们能够创建视觉上引人注目的效果。今天我们继续将深入了解几种高级CSS效果:盒子阴影、滤镜、混合模式和文本背景裁剪,提升网页设计的质感和深度。一、盒子阴影(BoxShadow)对于盒子元素,存在一个类似的属性——​​box-shadow​​​,用于在实际的元......
  • 调试AVR单片机,运行过程中出现异常复位
    调试AVR单片机时,运行过程中出现异常复位是一个常见的问题。这种情况可能由多种原因引起,理解这些原因并采取适当的解决措施是确保系统稳定性的重要步骤。下面将详细分析可能导致AVR单片机异常复位的原因:1.看门狗复位:  看门狗定时器是一个用于监测系统运行状态的内置功能,如......
  • 信息学奥赛一本通1058:求一元二次方程
    【题目描述】利用公式x1=−b+b2−4ac√2a,x2=−b−b2−4ac√2a�1=−�+�2−4��2�,�2=−�−�2−4��2�,求一元二次方程ax2+bx+c=0��2+��+�=0的根,其中a�不等于00。结果要求精确到小数点后55位。【输入】输入一行,包含三个浮点数a,b,c�,�,�(它们之间以一个空格分开),分别表示方程ax2+bx+c=0��2+��+�=0的系数。......
  • 信息学奥赛一本通1056:点和正方形的关系
    【题目描述】有一个正方形,四个角的坐标(x,y)分别是(1,-1),(1,1),(-1,-1),(-1,1),x是横轴,y是纵轴。写一个程序,判断一个给定的点是否在这个正方形内(包括正方形边界)。如果点在正方形内,则输出yes,否则输出no。【输入】输入一行,包括两个整数x、y,以一个空格分开,表示坐标(x,y)。【输出......
  • 数据映射:铸就企业数据互通之桥
    在先前的文章中,我们已经对勤研低代码开发平台的字典功能进行了详细介绍。那么,当面对海量数据时,该平台究竟如何促使不同数据之间实现有效的数据交互与协同工作呢?让我们一同来深入了解勤研低代码开发平台的数据映射功能。数据映射作为低代码平台的核心功能之一,为不同数据源之......
  • 信息学奥赛一本通1055:判断闰年
    【题目描述】#include<iostream>usingnamespacestd;intmain(){ inta; cin>>a; if(a%4==0&&a%100!=0||a%400==0){ cout<<"Y"; } else{ cout<<"N"; } return0;}判断某年是否是闰年。如果公元a年是闰年输出Y,否则输出N......