Linux——进程间通信——system V系列-Toy模板网

这篇具有很好参考价值的文章主要介绍了Linux——进程间通信——system V系列。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

✅<1>主页：：我的代码爱吃辣
📃<2>知识讲解：Linux——进程间通信——system V系列
☂️<3>开发环境：Centos7
💬<4>前言：system V 版本进程间通信的机制。

一.共享内存介绍

二.共享内存函数

1.shmget函数

2.shmat函数

3.shmdt函数

4.shmctl函数

三.代码示例

1.Comm.hpp

2.client.cc

3.server.cc

4.测试结果

四. 消息队列

五.信号量

1.互斥

Linux——进程间通信——system V系列,linux,linux,运维,服务器

system共有三个IPC方案：

System V 共享内存
System V 消息队列
System V 信号量

今天我们重点讲解 system共享内存。

一.共享内存介绍

共享内存是进程间通信中最简单的方式之一，也是最快的IPC形式，因为进程可以直接读写内存，而不需要任何数据的拷贝。共享内存允许两个或更多进程访问同一块内存，就如同malloc()函数向不同进程返回了指向同一个物理内存区域的指针。

共享内存在进程空间的映射：使用共享内存通信的一个进程可以将共享内存映射到自己的地址空间中，这样就可以像操作普通变量一样操作这块内存了。另外一个进程也可以通过相同的方式将这块内存映射到自己的地址空间中，然后进行读写操作。

示意图：

Linux——进程间通信——system V系列,linux,linux,运维,服务器

查看内核中的共享内存使用命令：

ipcs

Linux——进程间通信——system V系列,linux,linux,运维,服务器

二.共享内存函数

1.shmget函数

功能：用来创建共享内存。
原型：int shmget(key_t key, size_t size, int shmflg)。
参数：

key：这个共享内存段名字。

size：共享内存大小。

shmflg：由九个权限标志构成，它们的用法和创建文件时使用的mode模式标志是一样的。

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

2.shmat函数

功能：将共享内存段连接到进程地址空间。
原型：void *shmat(int shmid, const void *shmaddr, int shmflg);
参数

shmid: 共享内存标识。

shmaddr:指定连接的地址。

shmflg:它的两个可能取值是SHM_RND和SHM_RDONLY。

返回值：成功返回一个指针，指向共享内存第一个节；失败返回-1 。

说明：

shmaddr为NULL，核心自动选择一个地址。

shmaddr不为NULL且shmflg无SHM_RND标记，则以shmaddr为连接地址。

shmaddr不为NULL且shmflg设置了SHM_RND标记，则连接的地址会自动向下调整为SHMLBA的整数倍。公式：shmaddr -(shmaddr % SHMLBA)。

shmflg=SHM_RDONLY，表示连接操作用来只读共享内存。

3.shmdt函数

功能：将共享内存段与当前进程脱离。
原型：int shmdt(const void *shmaddr);
参数：shmaddr: 由shmat所返回的指针。
返回值：成功返回0；失败返回-1。
注意：将共享内存段与当前进程脱离不等于删除共享内存段。

4.shmctl函数

功能：用于控制共享内存。
原型：int shmctl(int shmid, int cmd, struct shmid_ds *buf);
参数

shmid:由shmget返回的共享内存标识码。

cmd:将要采取的动作（有三个可取值）。

buf:指向一个保存着共享内存的模式状态和访问权限的数据结构。

返回值：成功返回0；失败返回-1。

三.代码示例

基于共享内存实现server，client通信：

1.Comm.hpp

#include <iostream>
#include <cstring>
#include <cerrno>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <unistd.h>

using namespace std;

// 项目路径
const char *pathname = "/home/wq/23_10_1";
// 项目编号
const int pro_id = 0664;
// 共享内存大小
const size_t gsize = 4096;

#define CLIENT 1
#define SERVER 0

class Shm
{
public:
    Shm(int type)
        : _type(type)
    {
        getkey();
        if (_type == 0)
            createshmserver();
        else
            createshmclient();
        hookshm();
    }
    char *getstart()
    {
        return _start;
    }
    ~Shm()
    {
        Leaveshm();

        if (_type == 0)
        {
            sleep(3);
            delshm();
        }
    }

private:
    void To_Hex(key_t k)
    {
        printf("0x%x\n", k);
    }

    // 1.获取唯一共享内存段名字key
    void getkey()
    {
        _key = ftok(pathname, pro_id);
        To_Hex(_key);
        if (_key == -1)
        {
            cerr << "shm:" << errno << ":" << strerror(errno) << endl;
        }
    }

    // 2.创建共享内存
    int createshm(int flag)
    {
        int shmid = shmget(_key, gsize, flag);

        return shmid;
    }

    // 2.1创建共享内存客户端接口
    void createshmclient()
    {
        // 客户端仅仅找到服务端创建的shm
        _shmid = createshm(IPC_CREAT);
        if (_shmid == -1)
        {
            cerr << "client shm create:" << errno << ":" << strerror(errno) << endl;
            exit(2);
        }
    }

    // 2.2创建共享内存服务端接口
    void createshmserver()
    {
        // 创建shm，如果已经存在就报错，不存在创建一个新的共享内存
        _shmid = createshm(IPC_CREAT | IPC_EXCL | 0666);
        if (_shmid == -1)
        {
            cerr << "server shm create:" << errno << ":" << strerror(errno) << endl;
            exit(3);
        }
    }

    // 3.将共享内存段连接到进程地址空间
    void hookshm()
    {
        _start = (char *)shmat(_shmid, NULL, SHM_RND);
        if (_start == NULL)
        {
            cerr << "hookshm:" << errno << ":" << strerror(errno) << endl;
        }
    }

    // 4.将共享内存段与到进程地址空间断开
    void Leaveshm()
    {
        int n = shmdt(_start);
        if (n == -1)
        {
            cerr << "shmdt:" << errno << ":" << strerror(errno) << endl;
        }
    }

    // 5.删除共享内存
    void delshm()
    {
        int n = shmctl(_shmid, IPC_RMID, NULL);
        if (n == -1)
        {
            cerr << "shmdt:" << errno << ":" << strerror(errno) << endl;
        }
    }

private:
    key_t _key;   // 共享内存段名字
    int _shmid;   // 共享内存段的标识码
    char *_start; // 共享内存映射到地址空间的起始地址，将来当作一段malloc的空间使用
    int _type;    // 身份 —— SERVER，CLIENT
};

2.client.cc

#include "Comm.hpp"

int main()
{
    // 1.创建共享内存对象
    Shm shm(CLIENT);
    // 2.得到内存块
    char *start = shm.getstart();
    // 3.读取数据
    while (1)
    {
        sleep(2);
        printf("%s", start);
    }

    return 0;
}

3.server.cc

#include "Comm.hpp"

int main()
{
    // 1.创建共享内存对象
    Shm shm(SERVER);
    // 2.得到内存块
    char *start = shm.getstart();
    // 3.写入数据
    while (1)
    {
        char buff[1024] = {0};
        char *str = fgets(buff, sizeof(buff), stdin);
        buff[strlen(str)] = 0;
        for (int i = 0; i < strlen(str); i++)
        {
            start[i] = buff[i];
        }
        start[strlen(str)] = 0;
    }
    sleep(20);

    return 0;
}

makefile：

.PHONY:all
all:server client

server:server.cc
	g++ -o $@ $^ -std=c++11

client:client.cc
	g++ -o $@ $^ -std=c++11

.PHONY:clean
clean:
	rm -rf server client