【Linux】进程间通信 - 管道

news2024/11/15 23:33:26

文章目录

  • 1. 进程间通信介绍
    • 1.1 进程间通信目的
    • 1.2 进程间通信发展
    • 1.3 进程间通信分类
  • 2. 管道
    • 2.1 什么是管道
    • 2.2 匿名管道
    • 2.3 用 fork 来共享管道原理
    • 2.4 站在文件描述符角度 - 深入理解管道
    • 2.5 站在内核角度 - 管道本质
    • 2.6 管道读写规则
    • 2.7 管道特点
  • 3. 命名管道
    • 3.1 匿名管道与命名管道的区别
    • 3.2 命名管道的打开规则
    • 例：用命名管道实现 server & client 通信

在这里插入图片描述

1. 进程间通信介绍

两个进程间，可以进行“数据”的直接传递吗？不能！进程具有独立性！

进程间通信的本质：先让不同的进程，看到同一份资源（一般都是要由 OS 提供）。

1.1 进程间通信目的

  • 数据传输：一个进程需要将它的数据发送给另一个进程。
  • 资源共享：多个进程之间共享同样的资源。
  • 通知事件：一个进程需要向另一个或一组进程发送消息，通知它（它们）发生了某种事件（如进程终止时要通知父进程）。
  • 进程控制：有些进程希望完全控制另一个进程的执行（如 Debug 进程），此时控制进程希望能够拦截另一个进程的所有陷入和异常，并能够及时知道它的状态改变。

1.2 进程间通信发展

  • 管道
  • System V 进程间通信
  • POSIX 进程间通信

1.3 进程间通信分类

  • 管道
    • 匿名管道 pipe
    • 命名管道
  • System V IPC
    • System V 消息队列
    • System V 共享内存
    • System V 信号量
  • POSIX IPC
    • 消息队列
    • 共享内存
    • 信号量
    • 互斥量
    • 条件变量
    • 读写锁

2. 管道

2.1 什么是管道

  • 管道是 Unix 中最古老的进程间通信的形式。
  • 我们把从一个进程连接到另一个进程的一个数据流称为一个“管道”。

在这里插入图片描述

2.2 匿名管道

#include <unistd.h>

功能：创建一个无名管道
原型：
int pipe(int fd[2]);
参数：
fd：文件描述符数组，其中fd[0]表示读端，fd[1]表示写端
返回值：成功返回0，失败返回错误代码

在这里插入图片描述

实例代码

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

// 例子：从键盘读取数据，写入管道，读取管道，写到屏幕
int main()
{
    int fds[2];
    char buf[100];
    int len;

    if (pipe(fds) == -1)
        perror("make pipe"), exit(1);

    // read from stdin
    while (fgets(buf, 100, stdin))
    {
        len = strlen(buf);
        // write into pipe
        if (write(fds[1], buf, len) != len)
        {
            perror("write to pipe");
            break;
        }
        memset(buf, 0x00, sizeof(buf));

        // read from pipe
        if ((len = read(fds[0], buf, 100)) == -1)
        {
            perror("read from pipe");
            break;
        }

        // write to stdout
        if (write(1, buf, len) != len)
        {
            perror("write to stdout");
            break;
        }
    }

    return 0;
}

2.3 用 fork 来共享管道原理

在这里插入图片描述

2.4 站在文件描述符角度 - 深入理解管道

在这里插入图片描述

2.5 站在内核角度 - 管道本质

在这里插入图片描述

所以，看待管道，就如同看待文件一样！管道的使用和文件一致，迎合了 “Linux 一切皆文件” 思想。

fork 共享管道测试代码

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

// child
void writer(int wfd)
{
    const char *str = "hello father, I am child";
    char buffer[128];
    int cnt = 0;
    pid_t pid = getpid();
    while (1)
    {
        sleep(1);
        char c = 'A';
        write(wfd, &c, 1);
        cnt++;

        printf("cnt: %d\n", cnt);
    }
    close(wfd);
}

// father
void reader(int rfd)
{
    char buffer[1024];
    int cnt = 10;
    while (1)
    {
        ssize_t n = read(rfd, buffer, sizeof(buffer) - 1);
        if (n > 0)
            printf("father get a message: %s, n: %ld\n", buffer, n);
        else if (n == 0)
        {
            printf("read pipe done, read file done!\n");
            break;
        }
        else
            break;

        cnt--;
        if (cnt == 0)
            break;
    }
    close(rfd);
    printf("read endpoint close!\n");
}

int main()
{
    printf("PIPE_BUF: %d\n", _PC_PIPE_BUF);

    // 1.
    int pipefd[2];
    int n = pipe(pipefd);
    if (n < 0)
        return 1;

    //                                       read       write
    printf("pipefd[0]: %d, pipefd[1]: %d\n", pipefd[0], pipefd[1]); // 3, 4

    // 2.
    pid_t id = fork();
    if (id == 0)
    {
        // child: w
        close(pipefd[0]);
        writer(pipefd[1]);
        exit(0);
    }

    // father: r
    close(pipefd[1]);
    reader(pipefd[0]);

    int status = 0;
    pid_t rid = waitpid(id, &status, 0);
    if (rid == id)
    {
        printf("exit code: %d, exit signal: %d\n", WEXITSTATUS(status), status & 0x7F);
    }

    return 0;
}

2.6 管道读写规则

  1. 当没有数据可读时
    • O_NONBLOCK disable：read 调用阻塞，即进程暂停执行，一直等到有数据来到为止。
    • O_NONBLOCK enable：read 调用返回 -1，errno 值为 EAGAIN。
  2. 当管道满的时候
    • O_NONBLOCK disable：write 调用阻塞，直到有进程读走数据。
    • O_NONBLOCK enable：调用返回 -1，errno 值为 EAGAIN。
  3. 如果所有管道写端对应的文件描述符被关闭，则 read 返回 0。
  4. 如果所有管道读端对应的文件描述符被关闭，则 write 操作会产生信号 SIGPIPE，进而可能导致 write 进程退出。
  5. 当要写入的数据量不大于 PIPE_BUF 时，Linux 将保证写入的原子性。
  6. 当要写入的数据量大于 PIPE_BUF 时，Linux 将不再保证写入的原子性。

2.7 管道特点

  • 只能用于具有共同祖先的进程（具有亲缘关系的进程）之间进行通信；通常，一个管道由一个进程创建，然后该进程调用 fork，此后父、子进程之间就可应用该管道。
  • 管道提供流式服务。
  • 一般而言，进程退出，管道释放，所以管道的生命周期随进程。
  • 一般而言，内核会对管道操作进行同步与互斥。
  • 管道是半双工的，数据只能向一个方向流动；需要双方通信时，需要建立起两个管道。

在这里插入图片描述

3. 命名管道

  • 命名管道可以从命令行上创建，命令行方法是使用下面这个命令：

    $ mkfifo filename

  • 命名管道也可以从程序里创建，相关函数有：

    int mkfifo(const char* filename, mode_t mode);

创建命名管道：

int main(int argc, char* argv[])
{
	mkfifo("p2", 0644);
	return 0;
}

3.1 匿名管道与命名管道的区别

  • 匿名管道由 pipe 函数创建并打开。
  • 命名管道由 mkfifo 函数创建，打开用 open。
  • FIFO（命名管道）与 pipe（匿名管道）之间唯一的区别在于它们创建与打开的方式不同，一旦这些工作完成之后，它们具有相同的意义。

3.2 命名管道的打开规则

  • 如果当前打开操作是为读而打开 FIFO 时：
    • O_NONBLOCK disable：阻塞直到有相应进程为写而打开该 FIFO。
    • O_NONBLOCK enable：立刻返回成功。
  • 如果当前打开操作是为写而打开 FIFO 时：
    • O_NONBLOCK disable：阻塞直到有相应进程为读而打开该 FIFO。
    • O_NONBLOCK enable：立刻返回失败，错误码为 ENXIO。

例：用命名管道实现 server & client 通信

$ ls -l
total 16
-rw-rw-r-- 1 ubuntu ubuntu 1009 May  4 17:16 Comm.hpp
-rw-rw-r-- 1 ubuntu ubuntu  193 May  4 15:14 Makefile
-rw-rw-r-- 1 ubuntu ubuntu  656 May  4 17:44 PipeClient.cc
-rw-rw-r-- 1 ubuntu ubuntu  929 May  4 17:44 PipeServer.cc

Makefile：

$ cat Makefile 
.PHONY:all
all:pipe_client pipe_server

pipe_server:PipeServer.cc
	g++ -o $@ $^ -std=c++11
pipe_client:PipeClient.cc
	g++ -o $@ $^ -std=c++11

.PHONY:clean
clean:
	rm -f pipe_client pipe_server

Comm.hpp：

#ifndef __COMM_HPP__
#define __COMM_HPP__

#include <iostream>
#include <string>
#include <cerrno>
#include <cstring>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>

using namespace std;

#define Mode 0666
#define Path "./fifo"

class Fifo
{
public:
    Fifo(const string &path)
        : _path(path)
    {
        umask(0);
        int n = mkfifo(_path.c_str(), Mode);
        if (n == 0)
        {
            cout << "mkfifo success" << endl;
        }
        else
        {
            cerr << "mkfifo failed, errno: " << errno << ", errstring: " << strerror(errno) << endl;
        }
    }

    ~Fifo()
    {
        int n = unlink(_path.c_str());
        if (n == 0)
        {
            cout << "remove fifo file " << _path << " success" << endl;
        }
        else
        {
            cerr << "remove failed, errno: " << errno << ", errstring: " << strerror(errno) << endl;
        }
    }

private:
    string _path; // 文件路径 + 文件名
};

#endif

PipeServer.cc：

#include "Comm.hpp"

int main()
{
    Fifo fifo(Path);

    int rfd = open(Path, O_RDONLY);
    if (rfd < 0)
    {
        cerr << "open failed, errno: " << errno << ", errstring: " << strerror(errno) << endl;
        return 1;
    }
    // 如果我们的写端没打开，先读打开，open的时候就会阻塞，直到把写端打开，读open才会返回
    cout << "open success" << endl;

    char buffer[1024];
    while (true)
    {
        ssize_t n = read(rfd, buffer, sizeof(buffer) - 1);
        if (n > 0)
        {
            buffer[n] = 0;
            cout << "client sat : " << buffer << endl;
        }
        else if (n == 0)
        {
            cout << "client quit, me too!" << endl;
            break;
        }
        else
        {
            cerr << "read failed, errno: " << errno << ", errstring: " << strerror(errno) << endl;
            break;
        }
    }

    close(rfd);
    return 0;
}

PipeClient.cc：

#include "Comm.hpp"

int main()
{
    int wfd = open(Path, O_WRONLY);
    if (wfd < 0)
    {
        cerr << "open failed, errno: " << errno << ", errstring: " << strerror(errno) << endl;
        return 1;
    }

    string inbuffer;
    while (true)
    {
        cout << "Please Enter Your Message# ";
        std::getline(cin, inbuffer);
        if (inbuffer == "quit")
            break;

        ssize_t n = write(wfd, inbuffer.c_str(), inbuffer.size());
        if (n < 0)
        {
            cerr << "write failed, errno: " << errno << ", errstring: " << strerror(errno) << endl;
            break;
        }
    }

    close(wfd);
    return 0;
}

结果：

在这里插入图片描述

END

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

运行时数据区-基础

运行时数据区-基础

运行时数据区-基础 为什么学习运行时数据区Java内存区域&#xff08;运行时数据区域&#xff09;和内存模型&#xff08;JMM&#xff09; 区别组成部分&#xff08;jdk1.7 / jdk1.8&#xff09;从线程隔离性分类与类加载的关系每个区域的功能参考文章 为什么学习运行时数据区 …
阅读更多...
【云原生】Docker 的网络通信

【云原生】Docker 的网络通信

Docker 的网络通信 1.Docker 容器网络通信的基本原理1.1 查看 Docker 容器网络1.2 宿主机与 Docker 容器建立网络通信的过程 2.使用命令查看 Docker 的网络配置信息3.Docker 的 4 种网络通信模式3.1 bridge 模式3.2 host 模式3.3 container 模式3.4 none 模式 4.容器间的通信4.…
阅读更多...
【翻译】REST API

【翻译】REST API

自动伸缩 API 创建或更新自动伸缩策略 API 此特性设计用于 Elasticsearch Service、Elastic Cloud Enterprise 和 Kubernetes 上的 Elastic Cloud 的间接使用。不支持直接用户使用。 创建或更新一个自动伸缩策略。 请求 PUT /_autoscaling/policy/<name> {"rol…
阅读更多...
c语言：打印任意行数的菱形

c语言：打印任意行数的菱形

例如&#xff1a;以下图片形式 #include <stdio.h> int main() {int line 0;scanf_s("%d", &line);int i 0;//打印上半部分for (i 0; i < line; i){//打印空格数int j 0;for (j 0; j < line - 1 - i; j){printf(" ");}//打印*数量for…
阅读更多...
vue3（实现上下无限来往滚动）

vue3（实现上下无限来往滚动）

一、问题描述 一般在大屏项目中&#xff0c;很常见的效果&#xff0c;就是容器中的内容缓慢地向下移动&#xff0c;直到底部停止&#xff0c;然后快速滚动回顶部&#xff0c;然后接着缓慢滚动到底部。并且在特定的情况下&#xff0c;还需要进行一些小交互&#xff0c;那就还得让…
阅读更多...
【Linux 进程】 自定义shell

【Linux 进程】 自定义shell

目录 关于shell 1.打印提示符&&获取用户命令字符​编辑 2.分割字符串 3.检查是否为内建命令 cd命令 export命令 echo命令 1.输出最后一个执行的命令的状态退出码&#xff08;返回码&#xff09; 2.输出指定环境变量 4.执行外部命令 关于shell Shell 是计算机操…
阅读更多...
【精】hadoop、HIVE大数据从0到1部署及应用实战

【精】hadoop、HIVE大数据从0到1部署及应用实战

目录 基本概念 Hadoop生态 HIVE hdfs(hadoop成员) yarn(hadoop成员) MapReduce(hadoop成员) spark flink storm HBase kafka ES 实战 安装并配置hadoop 环境准备 准备虚拟机 安装ssh并设置免密登录 安装jdk 安装、配置并启动hadoop 添加hadoop环境变量&…
阅读更多...
翻译《The Old New Thing》 - Why does the CreateProcess function do autocorrection?

翻译《The Old New Thing》 - Why does the CreateProcess function do autocorrection?

Why does the CreateProcess function do autocorrection? - The Old New Thing (microsoft.com)https://devblogs.microsoft.com/oldnewthing/20050623-03/?p35213 Raymond Chen 在 2005 年 6 月 23 日 为什么 CreateProcess 函数会进行自动更正&#xff1f; 译注&#xff…
阅读更多...
智能工业相机哪家好？

智能工业相机哪家好？

一、什么是智能工业相机 在工业自动化的浪潮中&#xff0c;智能工业相机扮演着至关重要的角色。它们如同工业领域的“眼睛”&#xff0c;为生产过程提供精准的视觉监测和数据采集。然而&#xff0c;面对众多的智能工业相机品牌&#xff0c;如何选择一款真正适合的产品成为了众多…
阅读更多...
Python面试十问

Python面试十问

一、深浅拷贝的区别&#xff1f; 浅拷⻉&#xff1a; 拷⻉的是对象的引⽤&#xff0c;如果原对象改变&#xff0c;相应的拷⻉对象也会发⽣改变。 深拷⻉&#xff1a; 拷⻉对象中的每个元素&#xff0c;拷⻉对象和原有对象不在有关系&#xff0c;两个是独⽴的对象。 浅拷⻉(c…
阅读更多...
Python量化炒股的数据信息获取— 获取上市公司股东和股本信息

Python量化炒股的数据信息获取— 获取上市公司股东和股本信息

Python量化炒股的数据信息获取— 获取上市公司股东和股本信息 获取上市公司股东和股本信息&#xff0c;即获取上市公司的十大股东信息、十大流通股东信息、股东股份质押信息、股东股份冻结信息、股东户数信息、大股东减持信息和上市公司股本变动信息。 获取上市公司的十大股东…
阅读更多...
一、运维概述

一、运维概述

章节目标 了解运维的基本概念了解企业的运行模式了解操作系统发展史以及作用 一、运维的基本概念 1、什么是运维&#xff1f; 在技术人员&#xff08;写代码的&#xff09;之间&#xff0c;一致对运维有一个开玩笑的认知&#xff1a;运维就是修电脑的、装网线的、背锅的岗位…
阅读更多...
力扣hot100：199. 二叉树的右视图/437. 路径总和 III（dfs/回溯/树上前缀和/哈希表）

力扣hot100：199. 二叉树的右视图/437. 路径总和 III（dfs/回溯/树上前缀和/哈希表）

文章目录 一、LeetCode&#xff1a;199. 二叉树的右视图二、LeetCode&#xff1a;437. 路径总和 III 一、LeetCode&#xff1a;199. 二叉树的右视图 LeetCode&#xff1a;199. 二叉树的右视图 差点因为是个中等题打退堂鼓。其实比较简单。 右视图实际上只需要找到&#xff0c…
阅读更多...
编译 x264 for iOS

编译 x264 for iOS

文章目录 编译在 FFMpeg 启用 x264其他编译选项报错处理 环境 &#xff1a; macOS 14.3.1 x264 - 20191217-2245 编译 1、下载 x264 源码 http://download.videolan.org/pub/videolan/x264/snapshots/ 这里我下载x264-snapshot-20191217-2245.tar.bz2 &#xff08;截止2024-…
阅读更多...
sql注入工具-​sqlmap

sql注入工具-​sqlmap

介绍&#xff1a; sqlmap是一款开源的自动化SQL注入工具&#xff0c;用于自动化检测和利用Web应用程序中的SQL注入漏洞。它具有强大的参数化查询和自定义注入脚本的功能&#xff0c;可以通过检测和利用SQL注入漏洞来获取数据库的敏感信息&#xff0c;如用户名、密码和其他重要…
阅读更多...
Dockerfile镜像实例

Dockerfile镜像实例

目录 一、构建SSH镜像 1. 建立工作目录 2. 生成镜像 3. 启动容器并修改root密码 二、systemctl镜像 1. 建立工作目录 2. 生成镜像 3. 运行镜像容器 ​编辑 4. 测试容器systemct 三、Nginx镜像 1. 建立工作目录 2. 编写Dockerfile脚本 3. 编写run.sh启动脚本 4. …
阅读更多...
Java之SimpleDateFormat

Java之SimpleDateFormat

系列文章目录 文章目录 系列文章目录前言前言 前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到网站，这篇文章男女通用，看懂了就去分享给你的码吧。 在多线程环境下，当多个线程同时使用相同的SimpleDateFormat对象（如stat…
阅读更多...
数据结构---时间复杂度+空间复杂度

数据结构---时间复杂度+空间复杂度

算法(algorithm)简单说就是解决问题的方法。方法有好坏&#xff0c;同样算法也是&#xff0c;有效率高的算法&#xff0c;也有效率低的算法。衡量算法的好坏一般从时间和空间两个维度衡量&#xff0c;也就是本文要介绍的时间复杂度和空间复杂度。有些时候&#xff0c;时间与空间…
阅读更多...
(三)JVM实战——对象的内存布局与执行引擎详解

(三)JVM实战——对象的内存布局与执行引擎详解

对象的内存布局 对象的实例化 对象的创建方式 - new的方式 - Class的newInstance():反射的方式 - Construct的newInstance() - clone:实现Cloneable接口,默认浅拷贝 - 使用反序列化&#xff1a;将二进制流转化为内存对象 创建对象的步骤 - 判断对象对应的类是否加载、链接、初…
阅读更多...
RabbitMQ之生产批量发送

RabbitMQ之生产批量发送

为什么要用生产批量发送&#xff1f; 批量发送消息&#xff0c;可以提高MQ发送性能。但是 RabbitMQ 并没有提供了批量发送消息的 API 接口,使用 spring-amqp 的 BatchingRabbitTemplate 实现批量能力。 SimpleBatchingStrategy 发送策略满足以下规则会进行发送&#xff1a; ba…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023