【Linux】进程间通信——system V(共享内存 | 消息队列 | 信号量)(上)

简介: 【Linux】进程间通信——system V(共享内存 | 消息队列 | 信号量)(上)

> 作者:დ旧言~

> 座右铭:松树千年终是朽,槿花一日自为荣。

> 目标:理解进程通信——system V(共享内存 | 消息队列 | 信号量)

> 毒鸡汤:有些事情,总是不明白,所以我不会坚持。早安!

> 专栏选自:Linux初阶

> 望小伙伴们点赞👍收藏✨加关注哟💕💕



🌟前言

system V:同一主机内的进程间通信方案,在OS层面专门为进程间通信设计的方案

进程间通信的本质:让不同的进程看到同一份资源

system V标准下的三种通信方式

  1. 共享内存
  2. 消息队列
  3. 信号量


我们来看看 system V标准下的三种通信方式 。


⭐主体

学习【Linux学习】进程间通信——system V(共享内存 | 消息队列 | 信号量)咱们按照下面的图解:



🌙 共享内存

💫 共享内存的基本原理

概念:

共享内存:通过让不同的进程,看到通过一个内存块的方式就叫共享内存。

进程具有独立性:

内核数据结构包括对应的代码、数据与页表都是独立的。OS系统为了让进程间进行通信:


1.申请一块空间

2.将创建好的内存映射进进程的地址空间

  • 共享内存让不同的进程看到同一份的资源就是在物理内存上申请一块内存空间,如何将创建好的内存分别与各个进程的页表之间建立映射,然后在虚拟地址空间中将虚拟地址填充到各自页表的对应位置,建立起物理地址与虚拟地址的联系。



3.如果不想通信:取消进程和内存的映射关系,释放内存

  • 而我们把创建好的内存称为共享内存,把进程和共享内存建立映射关系的操作称为挂接,把取消进程和内存的映射关系称为去关联
  • 把释放内存称为释放共享内存。
  • 共享内存的建立:在物理内存当中申请共享内存空间;将申请到的共享内存挂接到地址空间,即建立映射关系。
  • 共享内存的释放:共享内存与地址空间去关联,即取消映射关系;释放共享内存空间,即将物理内存归还给系统。


对于共享内存的理解:

对比以前C语言的malloc也可以在物理内存申请空间,并把开辟好的空间经过页表映射到进程地址空间当中。

但是system V进程间通信是专门设计的,用来IPC;共享内存是一种通信方式,所有想通信的进程都可以进行使用;OS一定可能会同时存在很多的共享内存。


💫 共享内存的创建

shmget:用来创建共享内存

#include <sys/ipc.h>
#include <sys/shm.h>
 
int shmget(key_t key, size_t size, int shmflg);
 
RETURN VALUE
       On success, a valid shared memory identifier is returned.  On errir, -1 is returned, and errno is set to indicate the error.


参数讲解:

  • shmflg:通常被设置成两个选项: IPC_CREAT、 IPC_EXCL

IPC_CREAT:共享内存不存在,则创建,如果存在则获取;IPC_EXCL:无法单独使用,IPC_CREAT|IPC_EXCL:如果不存在就创建,如果存在就出错返回


  • size:共享内存的大小
  • key:保证看到同一份共享内存,能进行唯一性标识。如何去形成key:ftok


ftok:形成key

ftok作用:是通过存在的路径名pathname以及设置的标识符proj_id来形成一个key值,通过shmget创建共享内存时,key值会被填充维护共享内存的数据结构当中。


理解key:


OS一定会存在很多的共享内存,共享内存本质就是在内存中申请一块空间,而key能进行唯一标识。OS申请的,自然要做管理,共享内存也是如此,如何管理:先描述,在组织。所以共享内存=物理内存块+共享内存的相关属性。进程如果在内存中创建了共享内存,为了让共享内存在系统中保证唯一的,通过key来进行标识,只要让另一个进程也看到同一个key。而key是在哪?key作为创建共享内存时共享内存的相关属性集合,描述共享内存时就有一个字段struct shm中有key。


共享内存数据结构的第一个成员是shm_perm,shm_perm是一个ipc_perm类型的结构体变量,每个共享内存的key值存储在shm_perm这个结构体变量当中,其中ipc_perm结构体的定义如下:

    struct ipc_perm {
               key_t          __key;    /* Key supplied to shmget(2) */
               uid_t          uid;      /* Effective UID of owner */
               gid_t          gid;      /* Effective GID of owner */
               uid_t          cuid;     /* Effective UID of creator */
               gid_t          cgid;     /* Effective GID of creator */
               unsigned short mode;     /* Permissions + SHM_DEST and
                                           SHM_LOCKED flags */
               unsigned short __seq;    /* Sequence number */
           };
 


💫 共享内存的控制

shmctl:控制共享内存

 #include <sys/ipc.h>
 #include <sys/shm.h>
 
int shmctl(int shmid, int cmd, struct shmid_ds *buf);
 


参数讲解:

  • shmid:共享内存id
  • cmd:控制方式,这里我们只使用IPC_RMID 选项,表示删除共享内存
  • buf:描述共享内存的数据结构

返回值:0表示成功,-1表示失败

共享内存的内核结构shmid_ds:

//man shmctl 
struct shmid_ds {
               struct ipc_perm shm_perm;    /* Ownership and permissions */
               size_t          shm_segsz;   /* Size of segment (bytes) */
               time_t          shm_atime;   /* Last attach time */
               time_t          shm_dtime;   /* Last detach time */
               time_t          shm_ctime;   /* Last change time */
               pid_t           shm_cpid;    /* PID of creator */
               pid_t           shm_lpid;    /* PID of last shmat(2)/shmdt(2) */
               shmatt_t        shm_nattch;  /* No. of current attaches */
               ...
           };


💫 共享内存的关联

shmat:关联共享内存

 #include <sys/types.h>
 #include <sys/shm.h>
 
 void *shmat(int shmid, const void *shmaddr, int shmflg);
 


参数讲解:

  • shmid:共享内存id
  • shmaddr:挂接地址(自己不知道地址,所以默认为NULL)
  • shmflg:挂接方式,默认为0

返回值:挂接成功返回共享内存起始地址(虚拟地址),类似C语言malloc

💫 共享内存的去关联

shmdt:去关联

#include <sys/types.h>
#include <sys/shm.h>
int shmdt(const void *shmaddr);
 
RETURN VALUE
On  success  shmdt() returns 0; on error -1 is returned, and errno is set to indi‐cate the cause of the error.


参数讲解:

  • shmaddr:去关联内存地址,即shmat返回值
  • 返回值:调用成功返回0,失败返回-1


💫 查看IPC资源

概念:

对于管道:进程退出,文件描述符就会自动释放,但是对于共享内存不一样:共享内存的生命周期是随OS的,而不是随进程的,这是所有System V进程间通信的共性。


查看共享内存:ipcs -m



删除:ipcsrm -m + shmid



💫 代码实现通信

1.comm.hpp:
#ifndef __COMM_HPP_
#define __COMM_HPP_
#include <iostream>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <cstdio>
#include <cstring>
#include <cstdlib>
using namespace std;
#define PATHNAME "."
#define PROJ_JD 0x66
#define MAX_SIZE 4096
 
key_t getkey()
{
    key_t k = ftok(PATHNAME,PROJ_JD);
    if(k <0)
    {
        cerr<<errno<<":"<<strerror(errno)<<endl;
        exit(1);
    }
    return k;
}
 
int getShmHelper(key_t k,int flags)
{
    //k是要shmget,设置进入共享内存属性中的,用来标识
    //该共享难内存在内核中的唯一性
 
    //shmid与key:
    //fd     inode
    int shmid = shmget(k,MAX_SIZE,flags);
    if(shmid<0)
    {
        cerr<<errno<<":"<<strerror(errno)<<endl;
        exit(2);
    }
    return shmid;
} 
 
 
//获取
int getShm(key_t k)
{
    return getShmHelper(k,IPC_CREAT);
}
//创建
int createShm(key_t k)
{
    return getShmHelper(k,IPC_CREAT | IPC_EXCL|0600);
}
 
void delShm(int shmid)
{
    if(shmctl(shmid,IPC_RMID,nullptr)==-1)
    {
        cerr<<errno<<":"<<strerror(errno)<<endl;
    }
}
 
void * attachShm(int shmid)
{
    void*mem = shmat(shmid,nullptr,0);
    if((long long)mem==-1L)//64位系统,8个字节,L表示数字类型
    {
        cerr<<errno<<"shmat:"<<strerror(errno)<<endl;
        exit(3);
    }
    return mem;
}
 
void detachShm(void * start)
{
    if(shmdt(start)==-1)
    {
        cerr<<"shmdt:"<<errno<<":"<<strerror(errno)<<endl;
    }
}
 
#endif 


2.server.cc:
#include "comm.hpp"
#include <unistd.h>
using namespace std;
 
int main()
{
    key_t k = getkey();
    printf("key:%0x%x\n",k);
 
    int shmid = createShm(k);
    printf("shmid:%d\n",shmid);
 
    //sleep(5);
 
    char*start = (char*)attachShm(shmid);
    printf("attach success,address start:%p\n",start);
 
    //使用
    while(true)
    {
        printf("client say:%s\n",start);
        struct shmid_ds ds;
        shmctl(shmid,IPC_STAT,&ds);
        printf("获取属性:size:%d,pid:%d,myself:%d",ds.shm_segsz,ds.shm_cpid);
        sleep(1);
    }
 
    //去关联
    detachShm(start);
 
    sleep(10);
    //删除共享内存
    delShm(shmid);
    return 0;
}


3.client.cc:
#include "comm.hpp"
#include <unistd.h>
using namespace std;
 
int main()
{
    key_t k = getkey();
    printf("key:%0x%x\n",k);
 
    int shmid = getShm(k);
    printf("shmid:%d\n",shmid);
 
    char*start = (char*)attachShm(shmid);
    printf("attach success,address start:%p\n",start);
 
    const char*message = "hello server,我是另一个进程,正在和你通信";
    pid_t id = getpid();
    int count = 1;
    //char buffer[1024];
    while(true)
    {
       sleep(5);
       snprintf(start,MAX_SIZE,"%s[pid:%d][消息编号:%d]",message,id,count++);
 
       // snprintf(buffer,sizeof(buffer),"%s[pid:%d][消息编号:%d]",message,id,count++);
      //  memcpy(start,buffer,strlen(buffer)+1);
 
    }
 
 
    detachShm(start);
 
 
    return 0;
}




【Linux】进程间通信——system V(共享内存 | 消息队列 | 信号量)(下)    https://developer.aliyun.com/article/1565753

目录
相关文章
|
1月前
麒麟系统mate-indicators进程占用内存过高问题解决
【10月更文挑战第7天】麒麟系统mate-indicators进程占用内存过高问题解决
174 2
|
2月前
|
存储 Linux 调度
深入理解操作系统:从进程管理到内存分配
【8月更文挑战第44天】本文将带你深入操作系统的核心,探索其背后的原理和机制。我们将从进程管理开始,理解如何创建、调度和管理进程。然后,我们将探讨内存分配,了解操作系统如何管理计算机的内存资源。最后,我们将通过一些代码示例,展示这些概念是如何在实际操作系统中实现的。无论你是初学者还是有经验的开发者,这篇文章都将为你提供新的视角和深入的理解。
|
13天前
|
消息中间件 存储 供应链
进程间通信方式-----消息队列通信
【10月更文挑战第29天】消息队列通信是一种强大而灵活的进程间通信机制,它通过异步通信、解耦和缓冲等特性,为分布式系统和多进程应用提供了高效的通信方式。在实际应用中,需要根据具体的需求和场景,合理地选择和使用消息队列,以充分发挥其优势,同时注意其可能带来的复杂性和性能开销等问题。
|
1月前
|
缓存 算法 调度
深入浅出操作系统:从进程管理到内存优化
本文旨在为读者提供一次深入浅出的操作系统之旅。我们将从进程管理的基本概念出发,逐步深入到内存管理的复杂世界,最终探索如何通过实践技巧来优化系统性能。文章将结合理论与实践,通过代码示例,帮助读者更好地理解操作系统的核心机制及其在日常技术工作中的重要性。无论你是初学者还是有一定经验的开发者,这篇文章都将为你打开一扇通往操作系统深层次理解的大门。
|
1月前
麒麟系统mate-indicators进程占用内存过高问题解决
【10月更文挑战第5天】麒麟系统mate-indicators进程占用内存过高问题解决
131 0
|
4月前
|
存储 算法 定位技术
深入理解操作系统:从进程管理到内存分配
【7月更文挑战第27天】本文旨在为读者提供一个全面而深入的视角,以理解操作系统的核心概念和机制。我们将通过探讨进程管理、内存分配等关键主题,揭示这些复杂系统如何协同工作以确保计算环境的稳定和高效。文章将采用比喻和实例来阐释抽象的概念,使技术内容更加贴近生活,易于理解。
|
2月前
|
消息中间件
共享内存和信号量的配合机制
【9月更文挑战第16天】本文介绍了进程间通过共享内存通信的机制及其同步保护方法。共享内存可让多个进程像访问本地内存一样进行数据交换,但需解决并发读写问题,通常借助信号量实现同步。文章详细描述了共享内存的创建、映射、解除映射等操作,并展示了如何利用信号量保护共享数据,确保其正确访问。此外,还提供了具体代码示例与步骤说明。
|
2月前
|
监控 Ubuntu API
Python脚本监控Ubuntu系统进程内存的实现方式
通过这种方法,我们可以很容易地监控Ubuntu系统中进程的内存使用情况,对于性能分析和资源管理具有很大的帮助。这只是 `psutil`库功能的冰山一角,`psutil`还能够提供更多关于系统和进程的详细信息,强烈推荐进一步探索这个强大的库。
42 1
|
2月前
|
消息中间件 Unix Linux
C语言 多进程编程(五)消息队列
本文介绍了Linux系统中多进程通信之消息队列的使用方法。首先通过`ftok()`函数生成消息队列的唯一ID,然后使用`msgget()`创建消息队列,并通过`msgctl()`进行操作,如删除队列。接着,通过`msgsnd()`函数发送消息到消息队列,使用`msgrcv()`函数从队列中接收消息。文章提供了详细的函数原型、参数说明及示例代码,帮助读者理解和应用消息队列进行进程间通信。
|
2月前
|
缓存 Linux C语言
C语言 多进程编程(六)共享内存
本文介绍了Linux系统下的多进程通信机制——共享内存的使用方法。首先详细讲解了如何通过`shmget()`函数创建共享内存,并提供了示例代码。接着介绍了如何利用`shmctl()`函数删除共享内存。随后,文章解释了共享内存映射的概念及其实现方法,包括使用`shmat()`函数进行映射以及使用`shmdt()`函数解除映射,并给出了相应的示例代码。最后,展示了如何在共享内存中读写数据的具体操作流程。