【Linux操作系统】详解Linux系统编程中的管道进程通信

在Linux系统编程中,管道是一种常用的进程间通信方式。它可以实现父子进程之间或者兄弟进程之间的数据传输。本文将介绍如何使用管道在Linux系统中进行进程通信,并给出相应的代码示例。

在这里插入图片描述

文章目录

    • 1. 管道的概念
    • 2. 管道的创建和使用
      • 2.1 原型
      • 2.2 示例
    • 3. 父子进程通信
    • 4. 兄弟进程间通信
    • 5. fifo函数
    • 6. fifo实现血缘关系进程间通信
    • 7. 管道的特性和限制
    • 8. 总结

1. 管道的概念

管道是一种特殊的文件,它提供了一个缓冲区用于进程间的数据传输。管道可以分为两种类型:匿名管道和命名管道。

  • 匿名管道:匿名管道是一种临时的管道,只能在有亲缘关系的进程之间使用,通常用于父子进程之间的通信。匿名管道只能在创建它的进程及其子进程之间使用,其他进程无法访问。
  • 命名管道:命名管道是一种有名字的管道,可以在不同的进程之间进行通信。命名管道通过在文件系统中创建一个文件来实现,进程可以通过该文件来读写数据。

在本文中,我们将重点介绍匿名管道的使用。

2. 管道的创建和使用

2.1 原型

在Linux系统中,可以使用pipe函数来创建一个管道。pipe函数的原型如下:

int pipe(int pipefd[2]);

pipefd是一个整型数组,用于存储管道的读写文件描述符。pipefd[0]用于读取管道中的数据,pipefd[1]用于写入管道中的数据。

2.2 示例

下面是一个简单的示例代码,演示了如何使用管道进行父子进程之间的通信:

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>int main() {int pipefd[2];pid_t pid;char buf[1024];// 创建管道if (pipe(pipefd) == -1) {perror("pipe");exit(EXIT_FAILURE);}// 创建子进程pid = fork();if (pid == -1) {perror("fork");exit(EXIT_FAILURE);}if (pid == 0) {// 子进程写入数据到管道close(pipefd[0]); // 关闭读取端char* msg = "Hello, parent!";write(pipefd[1], msg, strlen(msg) + 1);close(pipefd[1]); // 关闭写入端exit(EXIT_SUCCESS);} else {// 父进程读取管道中的数据close(pipefd[1]); // 关闭写入端read(pipefd[0], buf, sizeof(buf));printf("Received message from child: %s\n", buf);close(pipefd[0]); // 关闭读取端exit(EXIT_SUCCESS);}
}

在上述代码中,首先使用pipe函数创建了一个管道。然后使用fork函数创建了一个子进程。子进程使用write函数将数据写入管道,父进程使用read函数从管道中读取数据。

3. 父子进程通信

父进程创建管道,并创建子进程后,父进程通过管道向子进程发送数据,子进程通过管道接收父进程发送的数据。

下面是一个示例代码,演示了父子进程之间使用管道进行通信的过程:

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>int main() {int pipefd[2];pid_t pid;char buf[1024];// 创建管道if (pipe(pipefd) == -1) {perror("pipe");exit(EXIT_FAILURE);}// 创建子进程pid = fork();if (pid == -1) {perror("fork");exit(EXIT_FAILURE);}if (pid == 0) {// 子进程读取管道中的数据close(pipefd[1]); // 关闭写入端read(pipefd[0], buf, sizeof(buf));printf("Received message from parent: %s\n", buf);close(pipefd[0]); // 关闭读取端exit(EXIT_SUCCESS);} else {// 父进程写入数据到管道close(pipefd[0]); // 关闭读取端char* msg = "Hello, child!";write(pipefd[1], msg, strlen(msg) + 1);close(pipefd[1]); // 关闭写入端exit(EXIT_SUCCESS);}
}

在上述代码中,首先使用pipe函数创建了一个管道。然后使用fork函数创建了一个子进程。子进程使用read函数从管道中读取数据,父进程使用write函数将数据写入管道。

4. 兄弟进程间通信

要实现兄弟进程之间的通信,可以使用命名管道(named pipe)或者共享内存(shared memory)来实现。

  1. 使用命名管道(named pipe):

    • 兄弟进程可以通过创建一个命名管道来进行通信。
    • 一个兄弟进程将数据写入命名管道,另一个兄弟进程从命名管道中读取数据。
    • 兄弟进程需要使用相同的命名管道名称来进行通信。
    • 可以使用mkfifo函数创建命名管道,使用open函数打开管道进行读写操作。
  2. 使用共享内存(shared memory):

    • 兄弟进程可以通过创建一个共享内存区域来进行通信。
    • 一个兄弟进程将数据写入共享内存,另一个兄弟进程从共享内存中读取数据。
    • 兄弟进程需要使用相同的共享内存标识符来进行通信。
    • 可以使用shmget函数创建共享内存,使用shmat函数将共享内存附加到进程的地址空间中进行读写操作。

下面是一个使用命名管道的示例代码,演示了兄弟进程之间的通信过程:

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <fcntl.h>
#include <sys/stat.h>int main() {pid_t pid;char buf[1024];const char* fifoName = "/tmp/myfifo";// 创建命名管道mkfifo(fifoName, 0666);// 创建子进程pid = fork();if (pid == -1) {perror("fork");exit(EXIT_FAILURE);}if (pid == 0) {// 子进程从命名管道中读取数据int fd = open(fifoName, O_RDONLY);read(fd, buf, sizeof(buf));printf("Received message from sibling: %s\n", buf);close(fd);exit(EXIT_SUCCESS);} else {// 父进程向命名管道中写入数据int fd = open(fifoName, O_WRONLY);char* msg = "Hello, sibling!";write(fd, msg, strlen(msg) + 1);close(fd);exit(EXIT_SUCCESS);}
}

在上述代码中,首先使用mkfifo函数创建了一个命名管道。然后使用fork函数创建了一个子进程。子进程使用open函数打开命名管道并从中读取数据,父进程使用open函数打开命名管道并向其中写入数据。

5. fifo函数

下面是一个使用mkfifoopen函数的示例代码,演示了兄弟进程之间的通信过程:

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <fcntl.h>
#include <sys/stat.h>int main() {pid_t pid;char buf[1024];const char* fifoName = "/tmp/myfifo";// 创建命名管道mkfifo(fifoName, 0666);// 创建子进程pid = fork();if (pid == -1) {perror("fork");exit(EXIT_FAILURE);}if (pid == 0) {// 子进程从命名管道中读取数据int fd = open(fifoName, O_RDONLY);read(fd, buf, sizeof(buf));printf("Received message from sibling: %s\n", buf);close(fd);exit(EXIT_SUCCESS);} else {// 父进程向命名管道中写入数据int fd = open(fifoName, O_WRONLY);char* msg = "Hello, sibling!";write(fd, msg, strlen(msg) + 1);close(fd);exit(EXIT_SUCCESS);}
}

在上述代码中,首先使用mkfifo函数创建了一个命名管道。然后使用fork函数创建了一个子进程。子进程使用open函数打开命名管道并从中读取数据,父进程使用open函数打开命名管道并向其中写入数据。

6. fifo实现血缘关系进程间通信

下面是一个使用命名管道实现非血缘关系进程间通信的示例代码:

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <fcntl.h>
#include <sys/stat.h>int main() {pid_t pid;char buf[1024];const char* fifoName = "/tmp/myfifo";// 创建命名管道mkfifo(fifoName, 0666);// 创建子进程pid = fork();if (pid == -1) {perror("fork");exit(EXIT_FAILURE);}if (pid == 0) {// 子进程向命名管道中写入数据int fd = open(fifoName, O_WRONLY);char* msg = "Hello, sibling!";write(fd, msg, strlen(msg) + 1);close(fd);exit(EXIT_SUCCESS);} else {// 父进程从命名管道中读取数据int fd = open(fifoName, O_RDONLY);read(fd, buf, sizeof(buf));printf("Received message from sibling: %s\n", buf);close(fd);exit(EXIT_SUCCESS);}
}

在上述代码中,首先使用mkfifo函数创建了一个命名管道。然后使用fork函数创建了一个子进程。子进程使用open函数打开命名管道并向其中写入数据,父进程使用open函数打开命名管道并从中读取数据。

7. 管道的特性和限制

管道作为一种进程间通信方式,具有以下特性和限制:

  • 管道是半双工的,即数据只能在一个方向上流动。
  • 管道是有限长度的,一旦写满了数据,继续写入会被阻塞,直到有进程读取数据后才能继续写入。
  • 管道只能在有亲缘关系的进程之间使用,即父子进程或者兄弟进程之间。

8. 总结

  1. fifo函数:在C标准库中没有名为fifo的函数。

  2. 命名管道(FIFO):命名管道是一种特殊的文件,可以在文件系统中创建,并且可以被不同的进程打开和读写。使用mkfifo函数可以创建命名管道。

  3. 兄弟进程间通信:兄弟进程是指由同一个父进程创建的多个子进程。兄弟进程间通信可以使用命名管道实现,其中一个进程向命名管道写入数据,另一个进程从命名管道读取数据。

  4. 非血缘关系进程间通信:非血缘关系的进程是指没有共同的父进程的进程。非血缘关系进程间通信同样可以使用命名管道实现,其中一个进程向命名管道写入数据,另一个进程从命名管道读取数据。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/95889.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

keepalived集群

keepalived概述 keepalived软件就是通过vrrp协议来实现高可用功能。 VRRP通信原理 VRRP就是虚拟路由冗余协议&#xff0c;它的出现就是为了解决静态路由的单点故障。 VRRP是通过一种竞选一种协议机制来将路由交个某台VRRP路由器。 VRRP 用IP多播的方式&#xff08;多播地…

HTTP与HTTPS的区别

面试常见问题&#xff0c;HTTPS优化总结易记版&#xff1a; 1、HSTS重定向技术&#xff1a;将http自动转换为https&#xff0c;减少301重定向 2、TLS握手优化&#xff1a;在TLS握手完成前客户端就提前向服务器发送数据 3、会话标识符&#xff1a;服务器记录下与某客户端的会…

学习笔记|按键原理|消抖|按键点灯的4种模式|STC32G单片机视频开发教程(冲哥)|第七集:按键点灯

文章目录 第六集&#xff08;下&#xff09;课后练习解答&#xff1a;SOS求救灯光编写求救信号原理冲哥代码及解析分模块设计&#xff1a;math.h&#xff1a;math.c:while主程序部分 按键点灯&#xff08;下&#xff09;1.按键的原理Tips&#xff1a;按键消抖 2.按键的代码实现…

创建一个简单的HTML Viewer应用程序

使用wxPython和内嵌浏览器来创建一个简单的HTML Viewer应用程序。 在本篇文章中&#xff0c;我们将使用Python和wxPython模块来创建一个简单的HTML Viewer应用程序。这个应用程序可以让用户输入HTML内容&#xff0c;并在内嵌浏览器中显示该内容的效果。 准备工作 在开始之前…

PCL 三维点云边界提取(C++详细过程版)

边界提取 一、概述二、代码实现三、结果展示本文由CSDN点云侠原创,爬虫自重。如果你不是在点云侠的博客中看到该文章,那么此处便是不要脸的爬虫。 一、概述 点云边界提取在PCL里有现成的调用函数,具体算法原理和实现代码见:PCL 点云边界提取。为充分了解pcl::BoundaryEsti…

Centos7 配置Docker镜像加速器

docker实战(一):centos7 yum安装docker docker实战(二):基础命令篇 docker实战(三):docker网络模式(超详细) docker实战(四):docker架构原理 docker实战(五):docker镜像及仓库配置 docker实战(六):docker 网络及数据卷设置 docker实战(七):docker 性质及版本选择 认知升…

redis 发布和订阅

目录 一、简介 二、常用命令 三、示例 一、简介 Redis 发布订阅 (pub/sub) 是一种消息通信模式&#xff1a;发送者 (pub) 发送消息&#xff0c;订阅者 (sub) 接收消息。Redis 客户端可以订阅任意数量的频道。下图展示了频道 channel1 &#xff0c;以及订阅这个频道的三个客户…

【Redis从头学-4】Redis中的String数据类型实战应用场景之验证码、浏览量、点赞量、Json格式存储

&#x1f9d1;‍&#x1f4bb;作者名称&#xff1a;DaenCode &#x1f3a4;作者简介&#xff1a;啥技术都喜欢捣鼓捣鼓&#xff0c;喜欢分享技术、经验、生活。 &#x1f60e;人生感悟&#xff1a;尝尽人生百味&#xff0c;方知世间冷暖。 &#x1f4d6;所属专栏&#xff1a;Re…

爬虫逆向实战(六)--猿人学第四题

一、数据接口分析 主页地址&#xff1a;猿人学第四题 1、抓包 通过抓包可以发现数据接口是api/match/4 2、判断是否有加密参数 请求参数是否加密&#xff1f; 无请求头是否加密&#xff1f; 无响应是否加密&#xff1f; 响应数据无加密&#xff0c;但是返回的却是html代码…

Linux常用命令——dircolors命令

在线Linux命令查询工具 dircolors 置ls命令在显示目录或文件时所用的色彩 补充说明 dircolors命令设置ls命令在显示目录或文件时所用的色彩。dircolors可根据[色彩配置文件]来设置LS_COLORS环境变量或是显示设置LS_COLORS环境变量的命令。 语法 dircolors(选项)(参数)选项…

通讯协议044——全网独有的OPC HDA知识一之聚合(十二)持续坏值时间

本文简单介绍OPC HDA规范的基本概念&#xff0c;更多通信资源请登录网信智汇(wangxinzhihui.com)。 本节旨在详细说明HDA聚合的要求和性能。其目的是使HDA聚合标准化&#xff0c;以便HDA客户端能够可靠地预测聚合计算的结果并理解其含义。如果用户需要聚合中的自定义功能&…

Jenkins 监控dist.zip文件内容发生变化 触发自动部署

为Jenkins添加plugin http://xx:xx/manage 创建一个任务 构建触发器 每3分钟扫描一次&#xff0c;发现指定文件build.zip文件的MD5发生变化后 触发任务

PostgreSql 备份恢复

一、概述 数据库备份一般可分为物理备份和逻辑备份&#xff0c;其中物理备份又可分为物理冷备和物理热备&#xff0c;下面就各种备份方式进行详细说明&#xff08;一般情况下&#xff0c;生产环境采取的定时物理热备逻辑备份的方式&#xff0c;均是以下述方式为基础进一步研发编…

Kepware 读取16位或32位数据时,结果不是真实数据的问题解决

kepware采集PLC的数据“IW260” IW260的值为61696&#xff0c;与PLC中显示的数值不一致。 61696二进制表示“11110001 00000000”,低8位“00000000”变为十进制为0&#xff1b;高8位“11110001”变为十进制为241&#xff0c;而241是IW260在PLC中显示的数值。由此可看出&#x…

SpringBoot创建和使用

spring core的方式来写代码还是比较繁琐的&#xff0c;而spring boot就是帮助程序员使用spring开发的一个脚手架&#xff08;boot&#xff09;&#xff0c;它是一个用于构建Java应用程序的开源框架&#xff0c;旨在简化开发流程并提高生产效率。它的主要优点有&#xff1a; 快速…

web连接桌面打开gptmap

一&#xff1a;环境配置 需要的材料&#xff1a; python-3.10.4 我使用的是这个版本的&#xff0c;3.8.10 该版本和以下版本组件组合&#xff0c;验证过能正常运行&#xff08;python 3.6.8测试异常&#xff09; websockify 该项目有python版本和node js版本 noVNC 形式的app…

ElasticSearch的客户端操作

ElasticSearch的客户端操作 1、客户端介绍 官方文档地址&#xff1a; https://www.elastic.co/guide/en/elasticsearch/reference/current/index.html 实际开发中&#xff0c;有多种方式操作Elasticsearch&#xff1a; 客户端工具&#xff1a;发送http请求(RESTful风格)操作…

Nginx虚拟主机(server块)部署Vue项目

需求 配置虚拟主机&#xff0c;实现一个Nginx运行多个服务。 实现 使用Server块。不同的端口号&#xff0c;表示不同的服务&#xff1b;同时在配置中指定&#xff0c;Vue安装包所在的位置。 配置 Vue项目&#xff0c;放在 html/test 目录下。 config中的配置如下&#xf…

Docker 网络之 ipvlan 和 macvlan

Docker ipvlan 和 macvlan 引言 本文讲解了Docker 网络模式中的 ipvlan 和 macvlan 的区别,目前自己在生产环境中使用的 ipvlan 模式非常问题.也解决了实际业务问题. IPvlan L2 mode example ipvlan 无需网卡混杂模式 , 运行如下命令后可以生成一个 vlan 子接口 , 会和主网卡…

智慧园区,打造宜居未来之城

近年来&#xff0c;随着数字化和智能化的不断发展&#xff0c;智慧园区的概念正愈发受到关注。 智慧园区的定义十分广泛&#xff0c;它涵盖了城市规划、交通管理、环境保护、能源利用等多个领域。智慧园区以数字化、网络化、智能化为核心&#xff0c;旨在提升生活和工作的质量&…