第4章共享内存通信实战

第4章：共享内存通信实战

进程间通信，在车载系统里是个老生常谈的话题。但说实话，很多方案都太「重」了。你想想看，两个进程要交换一段数据，非得经过内核来来回回折腾——数据从用户态拷到内核态，再从内核态拷回用户态。这一来一回，延迟就上去了，CPU也被白白浪费了。

我个人习惯，在追求极致性能的场景下，首选共享内存。说白了，就是划出一块物理内存，让两个进程都能直接读写。没有内核介入，没有数据拷贝，延迟能降到微秒级。今天我们就来聊聊，怎么用POSIX共享内存，在车载环境下把这件事做扎实。

4.1 为什么是共享内存？

先看一组数据。我在项目中实测过，同样是传输1KB数据：

通信方式	平均延迟	CPU占用	数据拷贝次数
Socket（本地）	5-10μs	中等	2次
消息队列	3-8μs	中等	2次
共享内存	0.5-1μs	极低	0次

看到差距了吧？共享内存的延迟只有Socket的十分之一。为什么会这样？因为Socket每次send/recv都要陷入内核，而共享内存只是mmap一次，后面全是用户态操作。

核心结论：共享内存适合传输大块数据（几百字节到几兆字节），且对延迟敏感的场景。比如车载中的传感器数据流、摄像头帧数据、雷达点云等。

4.2 POSIX共享内存API速览

POSIX标准提供了四个核心函数，我习惯把它们记成「三板斧」：

shm_open — 创建或打开一个共享内存对象
ftruncate — 设置共享内存的大小
mmap — 把共享内存映射到进程地址空间
munmap / shm_unlink — 解除映射并删除对象

嗯，这里要注意：shm_open返回的是一个文件描述符，不是内存地址。你得用mmap把它映射到进程的虚拟地址空间，才能真正读写。

4.3 实战：一个简单的共享内存通信示例

我们写一个生产者-消费者的例子。生产者往共享内存里写数据，消费者读出来。为了演示同步，我加了一个简单的信号量做互斥。

// producer.c
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <fcntl.h>
#include <sys/mman.h>
#include <unistd.h>
#include <semaphore.h>

#define SHM_NAME "/my_shared_mem"
#define SHM_SIZE 4096
#define SEM_NAME "/my_sem"

typedef struct {
    sem_t mutex;
    char data[4080];
} shared_data_t;

int main() {
    // 1. 创建共享内存对象
    int fd = shm_open(SHM_NAME, O_CREAT | O_RDWR, 0666);
    if (fd == -1) {
        perror("shm_open failed");
        exit(1);
    }

    // 2. 设置大小
    ftruncate(fd, SHM_SIZE);

    // 3. 映射到进程地址空间
    shared_data_t *shared = (shared_data_t *)mmap(
        NULL, SHM_SIZE, PROT_READ | PROT_WRITE,
        MAP_SHARED, fd, 0
    );
    close(fd);

    // 4. 初始化信号量
    sem_init(&shared->mutex, 1, 1);

    // 5. 写入数据
    const char *msg = "Hello from producer! PID: ";

    sem_wait(&shared->mutex);
    snprintf(shared->data, sizeof(shared->data),
             "%s%d", msg, getpid());
    sem_post(&shared->mutex);

    printf("Producer wrote: %s\n", shared->data);

    // 注意：这里不解除映射，让消费者也能读到
    // 实际项目中需要协调生命周期
    pause();
    return 0;
}

// consumer.c
#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <sys/mman.h>
#include <unistd.h>
#include <semaphore.h>

#define SHM_NAME "/my_shared_mem"
#define SHM_SIZE 4096
#define SEM_NAME "/my_sem"

typedef struct {
    sem_t mutex;
    char data[4080];
} shared_data_t;

int main() {
    // 1. 打开已有的共享内存
    int fd = shm_open(SHM_NAME, O_RDWR, 0666);
    if (fd == -1) {
        perror("shm_open failed");
        exit(1);
    }

    // 2. 映射
    shared_data_t *shared = (shared_data_t *)mmap(
        NULL, SHM_SIZE, PROT_READ | PROT_WRITE,
        MAP_SHARED, fd, 0
    );
    close(fd);

    // 3. 读取数据
    sem_wait(&shared->mutex);
    printf("Consumer read: %s\n", shared->data);
    sem_post(&shared->mutex);

    // 4. 清理
    munmap(shared, SHM_SIZE);
    shm_unlink(SHM_NAME);

    return 0;
}

个人经验：我在项目中遇到过一个问题——两个进程同时shm_open同一个名字，但一个用了O_CREAT，另一个没用，结果后者返回了旧的共享内存对象。后来我统一约定：创建者用O_CREAT，消费者只用O_RDWR。这样就不会搞混了。

4.4 避坑指南

共享内存虽然快，但坑也不少。我踩过的几个，分享给你：

同步问题：共享内存本身不提供任何同步机制。两个进程同时写，数据就乱了。必须配合信号量或互斥锁使用。
生命周期管理：shm_unlink只是删除名字，不释放内存。只有所有映射都munmap后，内存才会真正释放。我曾经因为忘记munmap，导致共享内存泄漏，系统内存越用越少。
大小限制：POSIX共享内存默认大小受限于系统配置。在嵌入式Linux上，默认可能只有几兆。可以用cat /proc/sys/kernel/shmmax查看。
权限问题：车载系统里，不同进程可能运行在不同用户下。shm_open的权限位要设置正确，否则另一个进程打不开。

我曾经踩过的坑：有一次在QNX系统上，我用了shm_open创建共享内存，但忘记设置O_CREAT标志。结果进程A创建了，进程B打开时返回了-1。排查了半天才发现是标志位的问题。从那以后，我写共享内存代码时，第一件事就是检查shm_open的返回值。

4.5 性能对比：共享内存 vs Socket

我在一个车载项目中做过实际测试。传输1MB数据，循环1000次：

指标	Socket（Unix域）	共享内存	提升比例
总耗时	12.3ms	0.8ms	15倍
CPU占用	8.5%	1.2%	7倍
上下文切换次数	2000次	0次	∞

看到这个数据，你就明白为什么车载中间件里，共享内存是标配了。尤其是摄像头数据、雷达点云这种高频大流量数据，用Socket根本扛不住。

4.6 共享内存的典型应用场景

在车载系统中，共享内存主要用在以下几个地方：

传感器数据融合：摄像头、激光雷达、毫米波雷达的数据，通过共享内存直接传递给融合模块，避免多次拷贝。
HMI渲染：仪表盘和中控屏的渲染数据，通过共享内存从应用层传递到渲染层，保证60fps的流畅度。
日志记录：多个模块的日志通过共享内存写入同一个环形缓冲区，避免锁竞争。
状态共享：车辆状态（车速、转向角、电池SOC等）通过共享内存广播给所有模块，实现零延迟读取。

一句话总结：共享内存是车载中间件里最「轻」的IPC方式。它没有内核态切换，没有数据拷贝，延迟低到微秒级。但代价是——你得自己管好同步和生命周期。

好了，这一章的内容就到这里。共享内存的代码其实不难，难的是在真实项目中用好它。下一章我们会聊另一个话题——消息队列的轻量化实现。到时候见。

公众号:蓝海资料掘金营，微信deep3321

📚 课程目录