『Linux从入门到精通』第 ㉔ 期 - 命名管道(named pipe)

2024-03-04 20:12

本文主要是介绍『Linux从入门到精通』第 ㉔ 期 - 命名管道(named pipe),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

在这里插入图片描述

文章目录

  • 💐专栏导读
  • 💐文章导读
  • 🐧什么是命名管道
  • 🐧命名管道与匿名管道(无名)的区别
  • 🐧如何在代码中创建命名管道
    • 🐧代码实例——实现 server 与 client 通信
  • 🐧代码优化

💐专栏导读

🌸作者简介:花想云 ,在读本科生一枚,C/C++领域新星创作者,新星计划导师,阿里云专家博主,CSDN内容合伙人…致力于 C/C++、Linux 学习。

🌸专栏简介:本文收录于 Linux从入门到精通,本专栏主要内容为本专栏主要内容为Linux的系统性学习,专为小白打造的文章专栏。

🌸相关专栏推荐:C语言初阶系列C语言进阶系列C++系列数据结构与算法

💐文章导读

本章我们将深入学习如何通过命名管道进行进程间通信。

🐧什么是命名管道

命名管道(Named Pipe)是一种在Unix和类Unix系统中用于进程间通信的特殊文件类型。它是一种命名的、无连接的、双向通信管道,允许两个进程通过在文件系统中的一个特殊文件进行通信。与无名管道(Anonymous Pipe)不同,命名管道在文件系统中有一个可见的路径名,因此可以被多个进程引用。

命名管道通过文件系统提供一种进程间通信的机制,允许不相关的进程之间进行数据交换。进程通过打开命名管道的文件路径来访问管道,就像访问普通文件一样。

在Linux系统中,使用mkfifo命令可以创建一个命名管道。例如:

$ mkfifo filename

使用命名管道涉及创建、打开、读取和写入管道。以下是一个简单的示例,说明如何在两个Shell进程中使用命名管道进行通信。

示例

  1. 创建命名管道:
    在一个终端中执行以下命令:
 mkfifo mypipe
  1. 写入数据到命名管道:
    在另一个终端中,可以使用命令向管道写入数据。例如:
 echo "Hello, named pipe" > mypipe
  1. 读取数据从命名管道:
    在第一个终端中,可以使用命令从管道读取数据。例如:
 cat mypipe

此时,你将在第一个终端中看到输出: “Hello, named pipe!”

在这里插入图片描述

请注意,命名管道的写入和读取是阻塞的,这意味着如果没有另一个进程准备好读取数据,写入的进程会被阻塞,反之亦然。因此,在实际使用中,你可能需要考虑使用多线程或其他机制来处理阻塞和同步的问题。

这只是一个简单的示例,具体的应用场景可能会更加复杂,根据实际需要,我们需要在编程中使用更高级的语言和库来处理命名管道。

🐧命名管道与匿名管道(无名)的区别

命名管道和匿名管道是两种不同类型的管道,它们在使用和特性上有一些关键的区别。

  1. 命名管道(Named Pipe):

    • 名称可见: 命名管道在文件系统中有一个可见的路径名,因此可以被多个进程引用。
    • 持久性: 命名管道是持久的,它们在文件系统中存在直到被显式删除。
    • 进程间通信: 适用于不相关的进程之间的通信,可以在不同的进程之间传递数据。
  2. 匿名管道(Anonymous Pipe):

    • 无文件系统可见性: 匿名管道没有在文件系统中可见的路径名,只能通过在创建它的进程内部使用。
    • 临时性: 匿名管道是临时的,只在创建它们的进程生存期内存在。
    • 主要用于父子进程通信: 通常用于父进程与其衍生的子进程之间的通信,因为它们在共享同一个进程的上下文中存在。

总的来说,命名管道适用于在不同进程之间传递数据,而匿名管道适用于在父子进程之间建立通信通道。选择使用哪一种取决于特定的应用场景和通信需求。

🐧如何在代码中创建命名管道

mkfifo是一个系统调用,它的作用是创建一个命名管道文件,并设置它的权限。

#include <unistd.h>int mkfifo(const char *pathname, mode_t mode);
  • pathname 参数是要创建的命名管道文件的路径名。
  • mode 参数是要为该文件设置的权限模式,通常使用八进制表示(例如 0666)。

mkfifo 函数会在文件系统中创建一个新的命名管道文件。如果成功,它将返回0;否则,返回-1,并设置适当的错误码来指示失败的原因。

命名管道在创建后,可以像普通文件一样被多个进程打开、读取和写入,从而实现进程间的通信。需要注意的是,管道的读取和写入是阻塞的,即当没有数据可读时,读取进程会被阻塞;当管道写满时,写入进程会被阻塞。

接下来,我们就通过一个小程序简单使用一个这个接口。

🐧代码实例——实现 server 与 client 通信

这里我们将实现一个简单的代码案例,创建服务端程序 server 与客户端程序 client ,并让双方进行通信(client 向管道里写入数据,server 从管道中读取数据)。

Server

/* commucate.hpp */#pragma once#include <iostream>
#include <string>
#include <cstdio>
#include <cassert>
#include <cerrno>
#include <cstring>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>using namespace std;#define NUM 1024const std::string fifoname = "./fifo";
int mode = 0666;
/* server.cc */
#include "communicate.hpp"
using namespace std;int main()
{// 1.创建管道文件umask(0); // 指挥影响当前进程,并不会影响系统默认配置int n = mkfifo(fifoname.c_str(), mode);if (n != 0) // 创建失败{cout << errno << strerror(errno) << endl;return 1;}cout << "creat fifo file sucess" << endl;// 2.服务端开启管道文件int rfd = open(fifoname.c_str(), O_RDONLY);if (rfd < 0) // 打开失败{cout << errno << strerror(errno) << endl;return 2;}cout << "open fifo sucess" << endl;// 3.开始通信char buffer[NUM];while (true){buffer[0] = 0; // 清空bufferssize_t n = read(rfd, buffer, sizeof(buffer)-1);if (n > 0){buffer[n] = 0;cout << "client# " << buffer << endl;}else if (n == 0) // 读到文件末尾{cout << "client quit......" << endl;break;}else{cout << errno << strerror(errno) << endl;break;}}// 关闭不要的fdclose(rfd);unlink(fifoname.c_str()); // 删除文件return 0;
}

Client

/* cilent.cc */#include "communicate.hpp"
using namespace std;int main()
{// 1.不需要创建文件,只需要打开文件即可int wfd = open(fifoname.c_str(), O_WRONLY);if (wfd < 0){cout << errno << strerror(errno) << endl;return 1;}// 开始通信char buffer[NUM];while (true){cout << "请输入你的消息# ";char *msg = fgets(buffer, sizeof(buffer), stdin);assert(msg);(void)msg;buffer[strlen(buffer) - 1] = 0;if (strcasecmp(buffer, "quit") == 0)break;ssize_t n = write(wfd, buffer, sizeof(buffer));assert(n > 0);(void)n;}close(wfd);return 0;
}

在这里插入图片描述

🐧代码优化

如上图所示,client 与 server 可以正常通信了。我们好可以稍加修改,让 server 进行实时读取,即 client 无需使用回车发送消息。

Server

/* server.cc */
#include "communicate.hpp"
using namespace std;// 同步输入版
int main()
{// 1.创建管道文件umask(0); // 指挥影响当前进程,并不会影响系统默认配置int n = mkfifo(fifoname.c_str(), mode);if (n != 0) // 创建失败{cout << errno << strerror(errno) << endl;return 1;}cout << "creat fifo file sucess" << endl;// 2.服务端开启管道文件int rfd = open(fifoname.c_str(), O_RDONLY);if (rfd < 0) // 打开失败{cout << errno << strerror(errno) << endl;return 2;}cout << "open fifo sucess" << endl;// 3.开始通信char buffer[NUM];while (true){buffer[0] = 0; // 清空bufferssize_t n = read(rfd, buffer, sizeof(buffer)-1);if (n > 0){   buffer[n] = 0;// cout << "client# " << buffer << endl;printf("%c",buffer[0]);fflush(stdout);}else if (n == 0) // 读到文件末尾{cout << "client quit......" << endl;break;}else{cout << errno << strerror(errno) << endl;break;}}// 关闭不要的fdclose(rfd);unlink(fifoname.c_str());return 0;
}

Cilent

/* client.cc */
#include "communicate.hpp"
using namespace std;// 同步输入版
int main()
{// 1.不需要创建文件,只需要打开文件即可int wfd = open(fifoname.c_str(), O_WRONLY);if (wfd < 0){cout << errno << strerror(errno) << endl;return 1;}// 开始通信char buffer[NUM];while (true){system("stty raw");int c = getchar();system("stty -raw");ssize_t n = write(wfd, (char*)&c, sizeof(char));assert(n > 0);(void)n;}close(wfd);return 0;
}

在这里插入图片描述
本章的内容到这里就结束了!如果觉得对你有所帮助的话,欢迎三连~

在这里插入图片描述

这篇关于『Linux从入门到精通』第 ㉔ 期 - 命名管道(named pipe)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

linux-基础知识3

打包和压缩 zip 安装zip软件包 yum -y install zip unzip 压缩打包命令: zip -q -r -d -u 压缩包文件名 目录和文件名列表 -q:不显示命令执行过程-r:递归处理,打包各级子目录和文件-u:把文件增加/替换到压缩包中-d:从压缩包中删除指定的文件 解压:unzip 压缩包名 打包文件 把压缩包从服务器下载到本地 把压缩包上传到服务器(zip

变量与命名

引言         在前两个课时中,我们已经了解了 Python 程序的基本结构,学习了如何正确地使用缩进来组织代码,并且知道了注释的重要性。现在我们将进一步深入到 Python 编程的核心——变量与命名。变量是我们存储数据的主要方式,而合理的命名则有助于提高代码的可读性和可维护性。 变量的概念与使用         在 Python 中,变量是一种用来存储数据值的标识符。创建变量很简单,

Linux 网络编程 --- 应用层

一、自定义协议和序列化反序列化 代码: 序列化反序列化实现网络版本计算器 二、HTTP协议 1、谈两个简单的预备知识 https://www.baidu.com/ --- 域名 --- 域名解析 --- IP地址 http的端口号为80端口,https的端口号为443 url为统一资源定位符。CSDNhttps://mp.csdn.net/mp_blog/creation/editor

【Python编程】Linux创建虚拟环境并配置与notebook相连接

1.创建 使用 venv 创建虚拟环境。例如,在当前目录下创建一个名为 myenv 的虚拟环境: python3 -m venv myenv 2.激活 激活虚拟环境使其成为当前终端会话的活动环境。运行: source myenv/bin/activate 3.与notebook连接 在虚拟环境中,使用 pip 安装 Jupyter 和 ipykernel: pip instal

数论入门整理(updating)

一、gcd lcm 基础中的基础,一般用来处理计算第一步什么的,分数化简之类。 LL gcd(LL a, LL b) { return b ? gcd(b, a % b) : a; } <pre name="code" class="cpp">LL lcm(LL a, LL b){LL c = gcd(a, b);return a / c * b;} 例题:

Java 创建图形用户界面(GUI)入门指南(Swing库 JFrame 类)概述

概述 基本概念 Java Swing 的架构 Java Swing 是一个为 Java 设计的 GUI 工具包,是 JAVA 基础类的一部分,基于 Java AWT 构建,提供了一系列轻量级、可定制的图形用户界面(GUI)组件。 与 AWT 相比,Swing 提供了许多比 AWT 更好的屏幕显示元素,更加灵活和可定制,具有更好的跨平台性能。 组件和容器 Java Swing 提供了许多

【IPV6从入门到起飞】5-1 IPV6+Home Assistant(搭建基本环境)

【IPV6从入门到起飞】5-1 IPV6+Home Assistant #搭建基本环境 1 背景2 docker下载 hass3 创建容器4 浏览器访问 hass5 手机APP远程访问hass6 更多玩法 1 背景 既然电脑可以IPV6入站,手机流量可以访问IPV6网络的服务,为什么不在电脑搭建Home Assistant(hass),来控制你的设备呢?@智能家居 @万物互联

Linux_kernel驱动开发11

一、改回nfs方式挂载根文件系统         在产品将要上线之前,需要制作不同类型格式的根文件系统         在产品研发阶段,我们还是需要使用nfs的方式挂载根文件系统         优点:可以直接在上位机中修改文件系统内容,延长EMMC的寿命         【1】重启上位机nfs服务         sudo service nfs-kernel-server resta