无名管道与有名管道通讯编程

2024-05-27 17:38

本文主要是介绍无名管道与有名管道通讯编程,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

管道通讯:一个进程在管道的尾部写入数据,另一个进程从管道的头部读出数据。管道包括无名管道和有名管道两种,前者只能用于父进程和子进程间的通信,后者可用于运行于同一系统中的任意两个进程间的通信。
管道通讯的特点:
1. 管道通讯是单向的,有固定的读端和写端。
2. 数据被进程从管道读出后,在管道中该数据就不存在了。
3. 当进程去读取空管道的时候,进程会阻塞。
4. 当进程往满管道写入数据时,进程会阻塞。
5. 管道容量为64KB(#define PIPE_BUFFERS 16,include/linux/pipe_fs_i.h)

无名管道

在Linux系统中,无名管道一旦创建完成后,操作无名管道等同于操作文件。当读端和写端被创建后,相当于创建了两个文件。无名管道的读端被视作一个文件;无名管道的写端也被视作一个文件。要写入数据,只需往写端文件写数据,要读取数据,只需往读端文件读数据。因为操作无名管道相当与操作文件,因此可用write函数,read函数,close函数来访问无名管道。创建无名管道使用的函数是pipe,并且该函数需要在创建子进程前使用

int pipe(int pipefd[2])
头文件:<unistd.h>
功能:创建无名管道,成功则返回0,失败则返回-1
参数:pipefd[2]用于存储创建的读写端文件的文件描述符,pipefd[0]为读端文件描述符,pipefd[1]为写端文件描述符
#include<stdio.h>
#include<unistd.h>
#include<stdlib.h>
void main()
{int pipefd[2];pipe(pipefd);pid_t pid;pid=fork();if(pid>0){/*父进程*/write(pipefd[1],"hello",6);write(pipefd[1],"world",6);wait(NULL);close(pipefd[1]);}if(pid==0){/*子进程*/char c_buf[10];read(pipefd[0],c_buf,6);printf("%s\n",c_buf);read(pipefd[0],c_buf,6);printf("%s\n",c_buf);close(pipefd[0]);}exit(0);
}

有名管道

有名管道又称为FIFO文件,因此我们对有名管道的操作可以采用操作文件的方法,如使用open,close,read,write等。创建有名管道用mkfifo函数,删除用unlink函数。
FIFO文件在使用上和普通文件有相似之处,但是也有不同之处:
1.读取Fifo文件的进程只能以”O_RDONLY”方式打开fifo文件。
2.写Fifo文件的进程只能以”O_WRONLY”方式打开fifo文件。
3.Fifo文件里面的内容被读取后,就消失了。但是普通文件里面的内容读取后还存在。

mkfifo
原型:int mkfifo(const char* pathname,mode_t mode)
头文件:<sys/types.h><sys/stat.h>
功能:创建fifo文件,成功返回0,失败返回-1
参数:pathname:要创建的fifo文件的名字(含路径)mode:创建的文件的访问权限
unlink
原型:int unlink(const char* pathname)
头文件:<unistd.h>
功能:删除文件,成功返回0,失败返回-1
参数:pathname:待删除的文件名字

写进程:

#include<stdio.h>
#include<fcntl.h>
#include<sys/types.h>
#include<sys/stat.h>
void main()
{int fd;mkfifo("/home/jx/myfifo",666);fd=open("/home/jx/myfifo",O_WRONLY);write(fd,"hello world",12);close(fd);
}

当创建有名管道且有向fifo文件写入数据,则程序运行后会处于阻塞状态,直到有程序去读取有名管道内容。
读进程:

#include<stdio.h>
#include<fcntl.h>#include<unistd.h>
#include<sys/types.h>
#include<sys/stat.h>
void main()
{char c_buf[20];int fd;fd=open("/home/jx/myfifo",O_RDONLY);read(fd,c_buf,12);close(fd);printf("%s\n",c_buf);unlink("/home/jx/myfifo");
}

这篇关于无名管道与有名管道通讯编程的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1008155

相关文章

Linux基础命令@grep、wc、管道符的使用详解

《Linux基础命令@grep、wc、管道符的使用详解》:本文主要介绍Linux基础命令@grep、wc、管道符的使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录grep概念语法作用演示一演示二演示三,带选项 -nwc概念语法作用wc,不带选项-c,统计字节数-

C#使用MQTTnet实现服务端与客户端的通讯的示例

《C#使用MQTTnet实现服务端与客户端的通讯的示例》本文主要介绍了C#使用MQTTnet实现服务端与客户端的通讯的示例,包括协议特性、连接管理、QoS机制和安全策略,具有一定的参考价值,感兴趣的可... 目录一、MQTT 协议简介二、MQTT 协议核心特性三、MQTTNET 库的核心功能四、服务端(BR

Python 异步编程 asyncio简介及基本用法

《Python异步编程asyncio简介及基本用法》asyncio是Python的一个库,用于编写并发代码,使用协程、任务和Futures来处理I/O密集型和高延迟操作,本文给大家介绍Python... 目录1、asyncio是什么IO密集型任务特征2、怎么用1、基本用法2、关键字 async1、async

Java并发编程之如何优雅关闭钩子Shutdown Hook

《Java并发编程之如何优雅关闭钩子ShutdownHook》这篇文章主要为大家详细介绍了Java如何实现优雅关闭钩子ShutdownHook,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起... 目录关闭钩子简介关闭钩子应用场景数据库连接实战演示使用关闭钩子的注意事项开源框架中的关闭钩子机制1.

Redis Pipeline(管道) 详解

《RedisPipeline(管道)详解》Pipeline管道是Redis提供的一种批量执行命令的机制,通过将多个命令一次性发送到服务器并统一接收响应,减少网络往返次数(RTT),显著提升执行效率... 目录Redis Pipeline 详解1. Pipeline 的核心概念2. 工作原理与性能提升3. 核

shell编程之函数与数组的使用详解

《shell编程之函数与数组的使用详解》:本文主要介绍shell编程之函数与数组的使用,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录shell函数函数的用法俩个数求和系统资源监控并报警函数函数变量的作用范围函数的参数递归函数shell数组获取数组的长度读取某下的

揭秘Python Socket网络编程的7种硬核用法

《揭秘PythonSocket网络编程的7种硬核用法》Socket不仅能做聊天室,还能干一大堆硬核操作,这篇文章就带大家看看Python网络编程的7种超实用玩法,感兴趣的小伙伴可以跟随小编一起... 目录1.端口扫描器:探测开放端口2.简易 HTTP 服务器:10 秒搭个网页3.局域网游戏:多人联机对战4.

Java并发编程必备之Synchronized关键字深入解析

《Java并发编程必备之Synchronized关键字深入解析》本文我们深入探索了Java中的Synchronized关键字,包括其互斥性和可重入性的特性,文章详细介绍了Synchronized的三种... 目录一、前言二、Synchronized关键字2.1 Synchronized的特性1. 互斥2.

Python异步编程中asyncio.gather的并发控制详解

《Python异步编程中asyncio.gather的并发控制详解》在Python异步编程生态中,asyncio.gather是并发任务调度的核心工具,本文将通过实际场景和代码示例,展示如何结合信号量... 目录一、asyncio.gather的原始行为解析二、信号量控制法:给并发装上"节流阀"三、进阶控制

Redis中管道操作pipeline的实现

《Redis中管道操作pipeline的实现》RedisPipeline是一种优化客户端与服务器通信的技术,通过批量发送和接收命令减少网络往返次数,提高命令执行效率,本文就来介绍一下Redis中管道操... 目录什么是pipeline场景一:我要向Redis新增大批量的数据分批处理事务( MULTI/EXE