Linux_进程通信_管道_system V共享内存_6

文章目录

  • 一、进程通信分类
  • 二、管道
    • 1.什么是管道
      • 1.原理
      • 2.管道的特点
    • 2.匿名管道
    • 3.命名管道
      • 1.创建命名管道文件 - mkfifo (命令)
      • 2.创建命名管道文件 - mkfifo (函数)
  • 三、system V共享内存
    • 1.原理
    • 2.共享内存函数
      • 1.fotk
      • 2.shmget
        • 1.如何知道有哪些IPC资源 - ipcs （命令）
        • 2.如何显示删除 - ipcrm (命令)
      • 3.如何使用共享内存 - shmat - shmdt
      • 4.系统接口删共享内存 -shmctl
  • 四、进程互斥
    • 1.临界资源
    • 2临界区
    • 3.原子性
    • 4.互斥

通信背景：
1.进程是具有独立性的，但进程间想要交互数据（多进程协同处理一件事情），成本会非常高 。
2.不要以为，进程独立了，就是彻底独立，我们需要双方能够进行一定程度的信息交互。

一、进程通信分类

  1. 管道
    a.匿名管道
    b.命名管道
  2. System V IPC
    a.System V 消息队列
    b.System V 共享内存
    c.System V 信号量
  3. POSIX IPC
    a.消息队列
    b.共享内存
    c.信号量
    d.互斥量
    e.条件变量
    f.读写锁

二、管道

1.什么是管道

通信之前，让不同的进程看到同一份资源（文件，内存块…）。我们要学的进程间通信，不是告诉我们如何通信，而是让两个进程看到同一份资源，因为资源不同，所以决定了不同种类的通信方式，而管道就是提供共享资源的一种手段。

管道是Unix中最古老的进程间通信的形式。
我们把从一个进程连接到另一个进程的一个数据流称为一个“管道“
在这里插入图片描述

1.原理

在这里插入图片描述
站在文件角度看管道：
在这里插入图片描述
站在内核角度看管道：

在这里插入图片描述

简单来说，看待管道，就如同看待文件一样，（不过是不在磁盘而是在内存里的文件）！管道的使用和文件一致，迎合了“Linux一切皆文件思想”。

为什么父进程要分别打开读写？
为了子进程继承，让子进程不用再打开了！
为什么父子要关闭对应的读写？
管道必须是单向通信
谁决定父子关闭什么读写？
不是由管道本身决定的，是由需求决定的！

2.管道的特点

生活中的管道都有什么共同特点：
a.都是单向的！
b.管道传输资源的
所以进程间通信管道是单向的，传输数据的！

2.匿名管道

创建管道——系统接口pipe
在这里插入图片描述
在这里插入图片描述

#include<iostream>
#include<unistd.h>
#include<cstring>
#include<sys/types.h>
#include<sys/wait.h>
using namespace std;
int main()
{
    //1.创建管道
    int pipefd[2] = {0};
    if(pipe(pipefd)!=0)
    {
        cerr<<"pipe error"<<endl;
        return 1;
    }
    //pipefd[0] 是读端
    //pipefd[1] 是写端
    //快速记忆  读写-01 0就是读 1就是写
    //2.创建子进程
    pid_t id = fork();
    if(id<0)
    {
        cerr<<"fork error"<<endl;
        return 2;
    }
    else if(id==0)
    {
        //child
        //子进程进行读取,要关闭写端
        close(pipefd[1]);
        #define NUM 1024
        char buffer[NUM];
        while(true)
        {
            memset(buffer,'\0',sizeof(buffer));

            //read返回值
            //0表示管道对端已经关闭,那么子进程是如何知道 ？
            //管道也是类似文件，和文件一样有硬链接数，当硬链接数为1时表示只有子进程在读，就表示对端已经关闭了。
            //大于0表示读到的字符长度
            //-1表示读取错误
            ssize_t s = read(pipefd[0],buffer,sizeof(buffer)-1);

            if(s>0)
            {
                //读取成功
                buffer[s] = '\0';
                cout<<"子进程收到消息，内容是: "<<buffer<<endl;
            }
            else if(s==0)
            {
                //父进程关闭管道
                cout<<"父进程写完了，我也退出啦"<<endl;
                break;
            }
            else
            {
                cerr<<"read error"<<endl;
                return 3;
            }
        }
        close(pipefd[0]);
    }
    else
    {
        //parent
        //父进程来进行写入，要关闭读端
        close(pipefd[0]);
        string msg = "你好子进程，我的父进程!,这次发送的信息编号是";
        int cnt = 0;
        while(cnt<5)
        {
            char sendBuffer[1024];
            sprintf(sendBuffer,"%s : %d",msg.c_str(),cnt);
            //不用把'\0'也写进去
            write(pipefd[1],sendBuffer,strlen(sendBuffer));
            sleep(1);
            cnt++;
        }
        close(pipefd[1]);
        cout<<"父进程写完了"<<endl;
        pid_t res  =waitpid(id,nullptr,0);
        if(res>0)
        {
            cout<<"等待子进程成功"<<endl;
        }
    }
    

    return 0;
}

在这里插入图片描述
运行上面的代码发现现象：
当父进程没有写入数据的时候，子进程在等！所以，父进程写入之后，子进程才会read（会返回）到数据，子进程打印读取数据要以父进程的节奏为主！
父进程和子进程读写的时候，是有一定的顺序的！！->父子进程各自printf的时候（向显示器写入），会有顺序吗？
不会，而这种乱序，就是缺乏访问控制。
管道内部，没有数据，reader就必须阻塞等待（read）——等管道有数据
管道内部，如果数据被写满，writer就必须阻塞等待（write）——等管道有空间
pipe内部，自带访问控制机制——同步和互斥机制！
阻塞等待，在哪个等待队列里等待？
管道资源的等待队里等待。

特征总结：
1.管道只能用来进行具有血缘关系的进程之间，进行进程通信。通常用于父子通信
2.管道只能单向通信（内核实现决定的），半双工的一种特殊情况
3.管道自带同步机制（pipe满，writer等。pipe空，reader等）——自带访问控制
4.管道是面向字节流的——先写的字符，一定是先被读取的，没有格式边界，需要用户来定义区分内容的边界
5.管道的生命周期——管道是文件吗？是——进程退出了，曾经打开的文件会怎么办？退出

3.命名管道

用于毫不相干的进程之间进行通信。

1.创建命名管道文件 - mkfifo (命令)

mkfifo 管道名

在这里插入图片描述
在这里插入图片描述

2.创建命名管道文件 - mkfifo (函数)

在这里插入图片描述

命名管道：通过一个fifo文件，有路径就 可以确认唯一性，通过路径找到同一个资源。

#include <iostream>
#include <sys/types.h>
#include 
#define IPC_PATH "./.fifo"
using namespace std;

int main()
{
    if (mkfifo(IPC_PATH,0600)!=0)
    {
        cerr<<"mkfifo error"<<endl;
        return 1;
    }
}

运行代码就创建了命名管道：
在这里插入图片描述
使用就和用文件一样，open,read,write。

三、system V共享内存

进程间通信的前提是：先让不同的进程，看到同一份资源！

1.原理

在这里插入图片描述

2.共享内存函数

1.fotk

作用：生成key值。

原型： key_t ftok(const char *pathname, int proj_id);

参数：
pathname ：路径
proj_id ：数字

返回值：成功返回key值，失败返回-1。

#pragma once
#include<iostream>
#include<sys/types.h>
#include<sys/ipc.h>
#include<string.h>
#include<errno.h>
#include<unistd.h>

#define PATH_NAME "/home/whc/study/24_4_1"
#define PROJ_ID 0x14


key_t Creatkey()
{
    key_t key =  ftok(PATH_NAME,PROJ_ID);
    if(key<0)
    {
        std::cerr<<"Creatkey error"<<strerror(errno)<<std::endl;
        exit(1);
    }
}

using namespace std;
int main()
{
    key_t key = Creatkey();
    std::cout<<"key:"<<key<<endl;


    return 0;
}

在这里插入图片描述

2.shmget

在这里插入图片描述
作用：用来创建共享内存

原型 ：int shmget(key_t key, size_t size, int shmflg);

参数：
key：这个共享内存段名字

size：共享内存大小，建议设置成为页（4KB）的整数倍

shmflg：它们的用法和创建文件时使用的mode模式标志是一样的
IPC_CREAT：创建共享内存，如果已经存在，就获取之，不存在，就创建之
IPC_EXCL：不单独使用，必须和IPC_CREAT配合使用。如果不存在指定的共享内存，创建之，如果存在了，出错返回。可以保证，如果shmegt函数调用成功，一定是一个全新的share
memory！
0600：权限

返回值：成功返回一个非负整数，即该共享内存段的标识码；失败返回-1

共享内存存在哪？
内核中，内核会给我们维护发现内存的结构！
对于OS来说，共享内存也要被管理起来，如何管理，先描述，再组织！
struct shmid_ds{
//各种数据
key_t kye;
};

我怎么知道，这个共享内存属于存在还是不存在？
先有方法，标识共享内存的唯一性，就是上面说的key。而这个key值一般是由用户提供的，让他们拥有同一个key值。

匿名管道通过约定使用同一文件。
共享内存通过约定使用同一个唯一key,来进行通信的！！

#include<iostream>
#include<time.h>
#include<iostream>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/shm.h>
#include<string.h>
#include<errno.h>
#include<unistd.h>

#define PATH_NAME "/home/whc/study/24_4_1"
#define PROJ_ID 0x14
#define MEM_SIZE 4096


key_t Creatkey()
{
    key_t key =  ftok(PATH_NAME,PROJ_ID);
    if(key<0)
    {
        std::cerr<<"Creatkey error"<<strerror(errno)<<std::endl;
        exit(1);
    }
}
std::ostream &Log()
{
    std::cout<<"For Debug | "<<"timestamp:"<<(uint64_t)time(nullptr)<<"  | ";
    return std::cout;
}
using namespace std;
int main()
{
    key_t key = Creatkey();
    Log() << "key:" << key << endl;
    int shmid = shmget(key,MEM_SIZE,IPC_CREAT|IPC_EXCL|0600);
    if(shmid<0)
    {
        Log()<<"shmget: "<<strerror(errno)<<endl;
        return 2;
    }

    Log()<<"create shm success, shmid "<<shmid<< endl;

    return 0;
}

在这里插入图片描述
当我们运行完毕创建全新共享内存的代码后（代码退出），但是第二（n）次时候，该代码无法运行，告诉我们file存在，共享内存是存在的，system v下的共享内存的生命周期是内核的。如果不显示的删除，只能通过kernel(OS)重启来解决。

1.如何知道有哪些IPC资源 - ipcs （命令）

作用：查看当前用户创建的共享内存

ipcs -m

在这里插入图片描述

2.如何显示删除 - ipcrm (命令)
ipcrm -m shmid

在这里插入图片描述

3.如何使用共享内存 - shmat - shmdt

在这里插入图片描述
作用：将共享内存和自己的进程产生关联attach

原型：void *shmat(int shmid, const void *shmaddr, int shmflg);

参数 ：
shmid ： shmid
shmaddr ： 不管 设为nullptr
shmflg : 是读还是写，不管设为默认：0

返回值：
出错返回-1，成功返回地址空间，怎么使用malloc的空间，就怎么使用共享内存的空间！

shmat(shmid,nullptr,0);

作用：将共享内存和直接的进程去关联detach

原型：int shmdt(const void *shmaddr);

参数：
shmaddr：就是shmat的返回值

返回值：失败返回-1

    //关联
    char *str = (char*)shmat(shmid, NULL, 0);
    Log()<<"attach shm: "<<shmid<< " success\n";
    sleep(5);
    //用共享内存
    while(true)
    {
        cout<<"."<<str<<endl;
        sleep(1);
    }
    //去关联
    shmdt(str);
    Log()<<"detach shm: "<<shmid<<" succsee\n";

    // 关联
    char *str = (char *)shmat(shmid, nullptr, 0);

    // 用它
    //我们把共享内存实际上是映射到了我们进程地址空间的用户空间了（堆栈之间），对每一个进程而言
    //挂接到自己的上下文的共享内存，属于自己的空间，类似于堆空间或者栈空间，可以被用户直接使用。
    int cnt = 0;
    while (cnt < 26)
    {
        str[cnt] = 'A' + cnt;
        cnt++;
        str[cnt] ='\0';
        sleep(1);
    }
    // 去关联
    shmdt(str);

在这里插入图片描述

共享内存，因为他自身的特性，他没有任何访问控制，共享内存被双方之间看到，属于双方的用户空间，可以直接通信，但是不安全！ 共享内存是所有进程通信，速度最快的！

4.系统接口删共享内存 -shmctl

在这里插入图片描述

作用：删除共享内存

原型：
int shmctl(int shmid, int cmd, struct shmid_ds *buf);

参数：
shmid：shmid

cmd : 如果要删除就传 IPC_RMID

buf：nullptr

返回值：-1就是失败

shmid(shmid,IPC_RMID,nullptr);

四、进程互斥

1.临界资源

被多个进程，能够看到的资源——临界资源。
如果没有对临界资源进行任何保护，对于临界资源的访问，双方进程在进行方法的时候，就都是乱序，可能会因为读写交叉而导致各种乱码，废弃数据，访问控制方法的问题！

2临界区

对于多个进程而言，访问临界资源的代码——临界区
我的进程中，有大量的代码没有访问临界资源，而只有一部分代码才会访问临界资源。

3.原子性

一件事，要么没做，要么做完了，没有中间状态——原子性

4.互斥

任何时刻，只允许一个进程，访问临界资源——互斥

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

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

k8s笔记28--快速在ubuntu上基于二进制和源码安装containerd

k8s笔记28--快速在ubuntu上基于二进制和源码安装containerd

k8s笔记28--快速在ubuntu上基于二进制和源码安装containerd 介绍containerd 安装方法二进制文件安装源码构建安装 注意事项说明 介绍 Containerd是一个工业标准的容器运行时&#xff0c;它强调简单、健壮和可移植性。它可作为Linux和Windows的守护进程&#xff0c;能管理主机系…
阅读更多...
Day78：服务攻防-数据库安全RedisCouchDBH2database未授权访问CVE漏洞

Day78：服务攻防-数据库安全RedisCouchDBH2database未授权访问CVE漏洞

目录 前置知识 数据库应用-Redis-未授权访问&CVE漏洞 未授权访问&#xff1a;CNVD-2015-07557 未授权访问-CNVD-2019-21763 未授权访问-沙箱绕过RCE-CVE-2022-0543 数据库应用-Couchdb-未授权越权&CVE漏洞 Couchdb 垂直权限绕过&#xff08;CVE-2017-12635&…
阅读更多...
怎么倒放视频教程？3个简单易行方法分享

怎么倒放视频教程？3个简单易行方法分享

怎么倒放视频教程&#xff1f;视频倒放是一种创意性的视频编辑方式&#xff0c;通过倒序播放视频内容&#xff0c;可以为观众带来全新的视觉体验。无论是为了制作搞笑视频&#xff0c;还是为了创作具有艺术感的短片&#xff0c;倒放视频都是一个非常实用的技巧。同时&#xff0…
阅读更多...
数学矩阵（详解）

数学矩阵（详解）

矩阵乘法 知阵乘法是《线性代数》中的基础内容&#xff0c;但在考察数学的算法题中也会出现。 本节我们学习基础的矩阵乘法规则。 每个矩阵会有一个行数和一个列数&#xff0c;只有当相乘的两个矩阵的左矩阵的列数等于右矩阵的行数 时&#xff0c;才能相乘&#xff0c;否则不允…
阅读更多...
【计算机毕业设计】黄河交通学院教学质量评价系统的设计与实现（付系统源码）

【计算机毕业设计】黄河交通学院教学质量评价系统的设计与实现（付系统源码）

&#x1f389;**欢迎来到我的技术世界&#xff01;**&#x1f389; &#x1f4d8; 博主小档案&#xff1a; 一名来自世界500强的资深程序媛&#xff0c;毕业于国内知名985高校。 &#x1f527; 技术专长&#xff1a; 在深度学习任务中展现出卓越的能力&#xff0c;包括但不限于…
阅读更多...
跑步用什么运动耳机？推荐几款跑步时超好用的运动耳机

跑步用什么运动耳机？推荐几款跑步时超好用的运动耳机

跑步健身成为了很多都市白领喜欢的运动方式之一&#xff0c;而为专业运动健身领域设计的运动耳机&#xff0c;近年来也受到了越来越多运动爱好者和数码爱好者的关注。相比于传统蓝牙耳机&#xff0c;运动耳机在运动过程中带给用户更舒适和安全的使用体验&#xff0c;因此也受到…
阅读更多...
什么是AIGC，AIGC的应用领域有哪些，以及对AIGC的未来展望有什么值得关注的方向

什么是AIGC，AIGC的应用领域有哪些，以及对AIGC的未来展望有什么值得关注的方向

AIGC：人工智能生成内容的深度解析 在数字技术的浪潮中，AIGC（ArtificialIntelligenceGeneratedContent，人工智能生成内容）逐渐崭露头角，成为继专业生产内容（PGC）和用户生产内容（UGC）之后的新型内容创作方式。它不仅改变了内容生产的传统模式，更在多个行业中展现出…
阅读更多...
钉钉服务端API报错 43008 参数需要multipart类型

钉钉服务端API报错 43008 参数需要multipart类型

钉钉服务端API报错 43008 参数需要multipart类型 problem 使用媒体文件上传接口&#xff0c;按照文档输入参数&#xff0c;结果返回报错 # 参数 {"access_token": "xxx""type": "image","media": "/Users/xxx/xxx/s…
阅读更多...
mongodb sharding分片模式的集群数据库，日志治理缺失导致写入数据库报错MongoWriteConcernException的问题总结（下）

mongodb sharding分片模式的集群数据库，日志治理缺失导致写入数据库报错MongoWriteConcernException的问题总结（下）

一、接着上文 上文介绍了mongodb sharding的分片集群搭建&#xff0c;本文侧重于讲述日志治理。 这里使用linux自带的日志治理工具logrotate&#xff0c;无论是哪个端口的进程&#xff0c;其日志治理方式类似。 查看/data目录下的文件大小&#xff0c; du -hs *二、Logrota…
阅读更多...
Django创建多app应用

Django创建多app应用

目录 1. 引言 2. 多app创建的两种方式 2.1 多个app结构 2.2 单个apps多个app 3. 最后 1. 引言 在平常业务开发中&#xff0c;我们遇到的功能可能会有很多&#xff0c;单个app的应用可能无法满足我们 这个时候&#xff0c;我们就需要多app应用&#xff0c;例如&#xff1a…
阅读更多...
知识图谱概论

知识图谱概论

文章目录 语言与知识相关知识图谱知识图谱价值知识图谱技术内涵 语言与知识 人的大脑依赖所学的知识进行思考、推理、理解语言… 人类通过认识世界积累知识&#xff0c;并通过语言来描述、记录和传承关于世界的知识。同时&#xff0c;准确理解语言也极大依赖大脑中所习得的各种…
阅读更多...
【御控物联】JavaScript JSON结构转换（13）：对象To数组——多层属性重组

【御控物联】JavaScript JSON结构转换（13）：对象To数组——多层属性重组

文章目录 一、JSON结构转换是什么&#xff1f;二、案例之《JSON对象 To JSON数组》三、代码实现四、在线转换工具五、技术资料 一、JSON结构转换是什么&#xff1f; JSON结构转换指的是将一个JSON对象或JSON数组按照一定规则进行重组、筛选、映射或转换&#xff0c;生成新的JS…
阅读更多...
电梯四种事故检测YOLOV8

电梯四种事故检测YOLOV8

电梯四种事故检测&#xff0c;采用YOLOV8训练得到PT模型&#xff0c;然后转换成ONNX&#xff0c;OPENCV调用&#xff0c;支持C/PYTHON/ANDORID开发 电梯四种事故检测YOLOV8
阅读更多...
matlab——基于三维激光扫描点云的树冠体积计算方法

matlab——基于三维激光扫描点云的树冠体积计算方法

目录 一、算法原理1、原理概述2、参考文献二、代码实现三、结果展示本文由CSDN点云侠原创，原文链接。如果你不是在点云侠的博客中看到该文章，那么此处便是不要脸的爬虫与GPT。 一、算法原理 1、原理概述 针对树冠形状不规则，树冠体积难以测量和计算的问题，提出一种基于三…
阅读更多...
Android Studio调试中的坑

Android Studio调试中的坑

1、新建Android工程后编译发现报错 2、发现无33和34的SDK更新 3、查看google相关文档 Android Gradle 插件 8.3 版本说明 | Android Studio | Android Developers 如果需要支持相关更高SDK需要的Android Studio版本和Android Gradle 插件是有版本要求的&#xff0c;相关要…
阅读更多...
C++提高编程之STL初始

C++提高编程之STL初始

1.STL的诞生 长久以来&#xff0c;软件界一直希望建立重复性的东西C的面向对象和泛型编程思想&#xff0c;目的就是复用性的提升大多情况下&#xff0c;数据结构和算法都未能有一套标准,导致被迫从事大量重复工作为了建立数据结构和算法的一套标准,诞生了STL 2&#xff0c;ST…
阅读更多...
ubuntu18.04 pycharm

ubuntu18.04 pycharm

一、下载pycharm &#xff08;1&#xff09;进入官网下载Download PyCharm: The Python IDE for data science and web development by JetBrains 选择专业版&#xff08;professional&#xff09;直接点击下载&#xff08;download&#xff09;&#xff0c;我下载的是2023.3…
阅读更多...
Netty学习——源码篇10 Netty内存分配ByteBuf基础

Netty学习——源码篇10 Netty内存分配ByteBuf基础

1 初始ByteBuf ByteBuf是Netty整个结构中最为底层的模块&#xff0c;主要负责把数据从底层I/O读取到ByteBuf&#xff0c;然后传递给应用程序&#xff0c;应用程序处理完成后再把数据封装成ByteBuf写回I/O。所以&#xff0c;ByteBuf是直接与底层打交道的一层抽象。 2 ByteBuf的…
阅读更多...
计算机网络-HTTP相关知识-HTTPS基础

计算机网络-HTTP相关知识-HTTPS基础

HTTP与HTTPS的区别&#xff1a; HTTPS在TCP和HTTP网络层之间加入了SSL/TLS安全协议层。这个安全协议层可以对数据进行加密&#xff0c;确保数据在传输过程中的安全。HTTPS在TCP三次握手之后&#xff0c;还需进行SSL/TLS的握手过程。这个握手过程主要是为了在客户端和服务器之间…
阅读更多...
react16路由缓存react-activation详解

react16路由缓存react-activation详解

react PC端项目构建TS&#xff0c;react18.2.0antdviteaxiosreduxsassts 完整版代码下载&#xff1a; https://download.csdn.net/download/randy521520/88922625 react PC端项目构建&#xff0c;react18.2.0antdviteaxiosreduxsass完整版代码下载&#xff1a; https://downloa…
阅读更多...
最新文章

Copyright @ 2022~2023