【Linux进程间通信】四、mmap共享存储映射(二)

简介: 【Linux进程间通信】四、mmap共享存储映射

4. 使用mmap实现父子进程通信

父子等有血缘关系的进程之间也可以通过mmap()函数建立的映射区来完成通信,但相应的要在创建映射区的时候指定对应的标志位参数flags:MAP_PRIVATE(私有映射)表示父子进程各自独占映射区;MAP_SHARED(共享映射)表示父子进程共享映射区。

使用mmap来实现父子进程间通信的原理是,fork子进程是对读进程的复制,所以子进程也会复制父进程mmap得到的映射区地址等信息。所以使用mmap实现父子进程间通信,应该先使用父进程mmap映射文件,然后再fork创建子进程。

/************************************************************
  >File Name  : mmap_ipc.c
  >Author     : Mindtechnist
  >Company    : Mindtechnist
  >Create Time: 2022年05月22日 星期日 18时32分24秒
************************************************************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/mman.h>
#include <sys/wait.h>
int main(int argc, char* argv[])
{
    int fd = open("mem.txt", O_RDWR);
    int* mem = mmap(NULL, 4, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
    if(mem == MAP_FAILED)
    {
        perror("mmao err");
        return -1;
    }
    close(fd);
    pid_t pid = fork();
    if(pid == 0)
    {
        *mem = 666; /*写入整形数字,所以mmap()返回int*类型*/
        printf("child mem: %d\n", *mem);
        sleep(3); /*等待父进程修改*/
        printf("child mem: %d\n", *mem);
    }
    if(pid > 0)
    {
        sleep(1); /*给子进程时间去修改映射区*/
        printf("parent mem: %d\n", *mem);
        *mem = 777;
        printf("parent mem: %d\n", *mem);
        wait(NULL); /*回收子进程*/
    }
    munmap(mem, 4);
    return 0;
}

如果我们将MAP_SHARED改成MAP_PRIVATE,那么父进程改的是父进程的,子进程改的是子进程的,它们都是改的自己的映射区。所以,要想通信,必须用MAP_SHARED。

5. 匿名映射

通过上面的分析我们可以体会到,使用映射区来完成文件读写操作十分方便,父子进程间通信也较容易且速度更快。但不足之处在于,每次创建映射区一定要依赖一个文件才能实现。每次为了创建映射区都要open一个临时文件,创建好了再通过unlink或close删除关闭掉,比较麻烦。 通过使用匿名映射可以解决这个问题,其实Linux系统给我们提供了创建匿名映射区的方法,无需依赖一个文件即可创建映射区,匿名映射的实现需要借助标志位参数flags来指定,使用MAP_ANONYMOUS (MAP_ANON)。

使用MAP_ANONYMOUS (MAP_ANON)

/************************************************************
  >File Name  : mmap_ipc2.c
  >Author     : Mindtechnist
  >Company    : Mindtechnist
  >Create Time: 2022年05月22日 星期日 18时32分24秒
************************************************************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/mman.h>
#include <sys/wait.h>
int main(int argc, char* argv[])
{
    int* mem = mmap(NULL, 4, PROT_READ | PROT_WRITE, MAP_SHARED | MAP_ANON, -1, 0);
    if(mem == MAP_FAILED)
    {
        perror("mmap err");
        return -1;
    }
    pid_t pid = fork();
    if(pid == 0)
    {
        *mem = 666;
        printf("child: %d\n", *mem);
        sleep(3);
        printf("child: %d\n", *mem);
    }
    if(pid > 0)
    {
        sleep(1);
        printf("parent: %d\n", *mem);
        *mem = 777;
        printf("parent: %d\n", *mem);
        wait(NULL);
    }
    munmap(mem, 4);
    return 0;
}

需注意的是,MAP_ANONYMOUS和MAP_ANON这两个宏是Linux操作系统特有的宏,在类Unix系统中如果没有该宏定义,可使用如下两步来完成匿名映射区的建立。

  • fd = open("/dev/zero", O_RDWR);
  • p = mmap(NULL, size, PROT_READ|PROT_WRITE, MMAP_SHARED, fd, 0);

/dev/zero 文件号称聚宝盆,可以随意进行映射,没有大小限制;还有一个文件叫做 /dev/null 号称无底洞,任何数据都可以放入,无大小限制,但是放入的数据都消失了,不会占用磁盘空间,一般会把没用的错误信息重定向到该文件中。

6. 无血缘关系进程间通信

6.1 无血缘关系进程通信的原理

我们知道,父子进程间通信的原理是fork子进程的时候,子进程会复制得到父进程mmap映射得到的映射区首地址,所以父子进程都可以通过这个地址对映射区操作,从而实现通信。那么没有血缘关系的进程之间是如何实现通信的呢?虽然无血缘关系的两个进程都是在自己进程内mmap得到的映射区,是两个不同的内存块(父子进程通过fork复制得到映射区地址),但是这两个内存是通过通过同一个文件映射得到的。只要选择了MAP_SHARED参数,两个进程对自己的内存映射区的操作都会反映到同一个文件中,所以这个文件充当了桥梁的作用,两个进程也就实现了数据交换。

6.2 无血缘关系进程通信实例

一个进程写映射区

/************************************************************
  >File Name  : w_mmap.c
  >Author     : Mindtechnist
  >Company    : Mindtechnist
  >Create Time: 2022年05月22日 星期日 20时42分52秒
************************************************************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/mman.h>
#include <sys/wait.h>
typedef struct _str
{
    int num;
    char string[20];
}Str;
int main(int argc, char* argv[])
{
    if(argc < 2)
    {
        printf("not found mapfile\n");
        return -1;
    }
    int fd = open(argv[1], O_RDWR | O_CREAT | O_TRUNC, 0644); /*OTRUNC文件清0*/
    int st_len = sizeof(Str);
    ftruncate(fd, st_len); /*扩展文件和结构体一样大*/
    Str* str = mmap(NULL, st_len, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); /*往映射区写入的内容是结构体,mmap()的返回值是一个缓冲区地址,所以要根据写入内容的类型来决定*/
    if(str == MAP_FAILED)
    {
        perror("mmap err");
        return -1;
    }
    int count = 1;
    while(1)
    {
        str->num = count;
        sprintf(str->string, "string-%04d", count++);
        sleep(1); /*每隔一秒修改一次映射区内容*/
    }
    munmap(str, st_len);
    close(fd);
    return 0;
}

一个进程读映射区

/************************************************************
  >File Name  : r_mmap.c
  >Author     : Mindtechnist
  >Company    : Mindtechnist
  >Create Time: 2022年05月22日 星期日 20时42分47秒
************************************************************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/mman.h>
#include <sys/wait.h>
typedef struct _str
{
    int num;
    char string[20];
}Str;
int main(int argc, char* argv[])
{
    if(argc < 2)
    {
        printf("not found mapfile\n");
        return -1;
    }
    int fd = open(argv[1], O_RDWR | O_CREAT, 0644); /*O_TRUNC这里不能再阶段了,否则core dump*/
    int st_len = sizeof(Str);
    Str* str = mmap(NULL, st_len, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
    if(str == MAP_FAILED)
    {
        perror("mmap err");
        return -1;
    }
    while(1)
    {
        printf("num = %02d, string = %s\n", str->num, str->string);
        sleep(1);
    }
    munmap(str, st_len);
    close(fd);
    return 0;
}

同样先执行写进程,再执行读进程

同样可以多个进程去读,但是和FIFO不同的是,使用FIFO实现进程通信的时候,当多个进程去读的时候,被读进程1读走的数据就不会再被进程2读取了,因为FIFO是磁盘上的缓冲区。而mmap就可以被多个进程一块读,读到的数据都一样,因为mmap映射区是内存上的,不论哪个进程都可以读取数据。

相关文章
|
2月前
|
Web App开发 Linux 程序员
获取和理解Linux进程以及其PID的基础知识。
总的来说,理解Linux进程及其PID需要我们明白,进程就如同汽车,负责执行任务,而PID则是独特的车牌号,为我们提供了管理的便利。知道这个,我们就可以更好地理解和操作Linux系统,甚至通过对进程的有效管理,让系统运行得更加顺畅。
76 16
|
1月前
|
监控 Shell Linux
Linux进程控制(详细讲解)
进程等待是系统通过调用特定的接口(如waitwaitpid)来实现的。来进行对子进程状态检测与回收的功能。
44 0
|
1月前
|
存储 负载均衡 算法
Linux2.6内核进程调度队列
本篇文章是Linux进程系列中的最后一篇文章,本来是想放在上一篇文章的结尾的,但是想了想还是单独写一篇文章吧,虽然说这部分内容是比较难的,所有一般来说是简单的提及带过的,但是为了让大家对进程有更深的理解与认识,还是看了一些别人的文章,然后学习了学习,然后对此做了总结,尽可能详细的介绍明白。最后推荐一篇文章Linux的进程优先级 NI 和 PR - 简书。
38 0
|
1月前
|
存储 Linux Shell
Linux进程概念-详细版(二)
在Linux进程概念-详细版(一)中我们解释了什么是进程,以及进程的各种状态,已经对进程有了一定的认识,那么这篇文章将会继续补全上篇文章剩余没有说到的,进程优先级,环境变量,程序地址空间,进程地址空间,以及调度队列。
34 0
|
1月前
|
Linux 调度 C语言
Linux进程概念-详细版(一)
子进程与父进程代码共享,其子进程直接用父进程的代码,其自己本身无代码,所以子进程无法改动代码,平时所说的修改是修改的数据。为什么要创建子进程:为了让其父子进程执行不同的代码块。子进程的数据相对于父进程是会进行写时拷贝(COW)。
39 0
|
4月前
|
Linux 数据库 Perl
【YashanDB 知识库】如何避免 yasdb 进程被 Linux OOM Killer 杀掉
本文来自YashanDB官网,探讨Linux系统中OOM Killer对数据库服务器的影响及解决方法。当内存接近耗尽时,OOM Killer会杀死占用最多内存的进程,这可能导致数据库主进程被误杀。为避免此问题,可采取两种方法:一是在OS层面关闭OOM Killer,通过修改`/etc/sysctl.conf`文件并重启生效;二是豁免数据库进程,由数据库实例用户借助`sudo`权限调整`oom_score_adj`值。这些措施有助于保护数据库进程免受系统内存管理机制的影响。
|
4月前
|
Linux Shell
Linux 进程前台后台切换与作业控制
进程前台/后台切换及作业控制简介: 在 Shell 中,启动的程序默认为前台进程,会占用终端直到执行完毕。例如,执行 `./shella.sh` 时,终端会被占用。为避免不便,可将命令放到后台运行,如 `./shella.sh &`,此时终端命令行立即返回,可继续输入其他命令。 常用作业控制命令: - `fg %1`:将后台作业切换到前台。 - `Ctrl + Z`:暂停前台作业并放到后台。 - `bg %1`:让暂停的后台作业继续执行。 - `kill %1`:终止后台作业。 优先级调整:
212 5
|
12月前
|
运维 关系型数据库 MySQL
掌握taskset:优化你的Linux进程,提升系统性能
在多核处理器成为现代计算标准的今天,运维人员和性能调优人员面临着如何有效利用这些处理能力的挑战。优化进程运行的位置不仅可以提高性能,还能更好地管理和分配系统资源。 其中,taskset命令是一个强大的工具,它允许管理员将进程绑定到特定的CPU核心,减少上下文切换的开销,从而提升整体效率。
掌握taskset:优化你的Linux进程,提升系统性能
|
12月前
|
弹性计算 Linux 区块链
Linux系统CPU异常占用(minerd 、tplink等挖矿进程)
Linux系统CPU异常占用(minerd 、tplink等挖矿进程)
325 4
Linux系统CPU异常占用(minerd 、tplink等挖矿进程)
|
11月前
|
算法 Linux 调度
探索进程调度:Linux内核中的完全公平调度器
【8月更文挑战第2天】在操作系统的心脏——内核中,进程调度算法扮演着至关重要的角色。本文将深入探讨Linux内核中的完全公平调度器(Completely Fair Scheduler, CFS),一个旨在提供公平时间分配给所有进程的调度器。我们将通过代码示例,理解CFS如何管理运行队列、选择下一个运行进程以及如何对实时负载进行响应。文章将揭示CFS的设计哲学,并展示其如何在现代多任务计算环境中实现高效的资源分配。