目录

0. 前言

1. 进程通信的目的

2. 进程通信发展及分类

3. 进程通信匿名管道

3.1 什么是管道？

3.2 匿名管道系统调用

3.3 fork后子进程继承（基于内存级）

3.4 站在文件描述符角度-深度理解管道

3.5 站在内核角度-管道本质

3.6 父子进程单向通信示例代码

3.7 管道读写规则

3.8 总结管道特点，理解|管道

3.9 派发任务—单机版负载均衡

4. 进程通信命名管道

4.1 命名管道

4.2 命名管道系统调用

4.3 命名管道与匿名管道及读写规则

4.4 示例用命名管道实现server&client通信

5. system V共享内存

5.1 共享内存示意图

5.2 共享内存数据结构

5.3 共享内存系统调用

1. 共享内存的创建及key_t:

2. 共享内存关联进程：

3. 解除关联该进程的共享内存：

4. 删除共享内存：

5.4  命名管道访问控制共享内存

5.5 共享内存总结

6. system V消息队列 — 选学

7. system V信号量 — 选学

---

0. 前言

进程具有独立性：

        进程想要通信，难度其实是比较大的

进程通信的本质：

        先让不同进程看到同一份资源（内存空间）

        所以进程看到同一块“内存”，不能隶属于任何一个进程，更应该强调共享

为什么要进行进程通信？

        交互数据，控制，通知等的目标

进程间通信的必要性？

        单进程无法使用并发能力，更加无法实现多进程协同

        进程间通信是一种手段，目的是为了实现多进程协同

1. 进程通信的目的

• 数据传输：一个进程需要将它的数据发送给另一个进程
• 资源共享：多个进程之间共享同样的资源。
• 通知事件：一个进程需要向另一个或一组进程发送消息，通知它（它们）发生了某种事件（如进程终止 时要通知父进程）。
• 进程控制：有些进程希望完全控制另一个进程的执行（如Debug进程），此时控制进程希望能够拦截另 一个进程的所有陷入和异常，并能够及时知道它的状态改变。

2. 进程通信发展及分类

主流通信标准：

• 管道
• System V进程间通信（接口复杂，不能很好整合文件场景，侧重于本地通信）
• POSIX进程间通信（多线程，将网络通信纳入，即能本地通信，又能网络编程通信，写出代码具有高扩展高可用性）

进程间通信分类：

管道：匿名管道pipe，命名管道

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

POSIX IPC： 消息队列，共享内存，信号量，互斥量，条件变量，读写锁

3. 进程通信匿名管道

3.1 什么是管道？

管道是Unix中最古老的进程间通信的形式。

我们把从一个进程连接到另一个进程的一个数据流称为一个“管道”

管道都是单向传输内容的，传输的都是“资源”（计算机通信领域设计的一种单项通信方式）

因为进程具有独立性，因此管道不能是进程给你的，一定是操作系统提供的，可以使用某种方式使用管道进行通信

3.2 匿名管道系统调用

#include <unistd.h>

功能:创建一无名管道

原型 int pipe(int fd[2]);

参数 fd：文件描述符数组,其中fd[0]表示读端, fd[1]表示写端

返回值:成功返回0，失败返回-1错误代码 and errno is set appropriately.

3.3 fork后子进程继承（基于内存级）

fork之后，子进程会继承父进程的PCB（环境变量，命令行参数，task_struct）、地址空间、页表，并且会继承文件描述符表（stdin、stdout、stderr及其他父进程打开文件，此时，父子进程操作同一个文件），并不会新创建拷贝一个同名文件！

此时父子进程就看到同一份文件资源，这份资源就叫做管道，而如果文件存在磁盘上，每次读写都需要刷新到磁盘，且管道文件只是负责进程间通信，并不负责保存数据，因此在内存上创建管道文件能大幅度提高通信效率，操作系统便提供系统调用pipe创建内存级的匿名管道，匿名管道文件生命周期一般都是随父子进程的生命周期！

3.4 站在文件描述符角度-深度理解管道

1. 父进程创建管道

2. 父进程fork创建子进程

3. 父进程关闭fd[0]，子进程关闭fd[1]

3.5 站在内核角度-管道本质

看待管道，就如同看待文件一样！管道的使用和文件一致，迎合了“Linux一切皆文件思想”。

父子进程task_struct -> files_struct* files -> struct file* fd_array[] -> 找到对应文件描述符对应的file结构体 -> 内部含有f_inode、读写操作方法函数指针数组f_op -> 进行读写操作  

3.6 父子进程单向通信示例代码

#include <iostream>
#include <assert.h>
#include <string>
#include <cstdio>
#include <cstring>
#include <unistd.h>
#include <sys/types.h>
#include <sys/wait.h>

using namespace std;

int main()
{
    // 1. 创建管道
    //      int pipe(int pipefd[2]) 输出型参数，期望调用，得到被打开文件fd
    //      创建成功返回0， 失败返回-1
    int pipefd[2] = {0}; // pipefd[0] 读端 pipefd[1] 写端
    int n = pipe(pipefd);
    assert(n != -1);
    (void)n; // 避免release版本下报警问题,debug assert not use

#ifdef DEBUG
    cout << "pipefd[0]:" << pipefd[0] << endl; // 3
    cout << "pipefd[1]:" << pipefd[1] << endl; // 4
#endif

    // 2. 创建子进程
    pid_t id = fork();
    assert(id != -1);
    if (id == 0)
    {
        // 3. 构建单向通信的信道,子进程读取
        // 3.1 关闭子进程不需要的fd
        close(pipefd[1]);
        char buffer[1024 * 8];
        int count = 0;
        while (true)
        {
            // 3.2 故意sleep，写的快，读慢，具有访问控制
            //sleep(20);

            //写入一方，fd没有关闭，如果有数据，就读，没有就等
            //写入一方，fd关闭，读取的一方，read返回0，表示读到了文件结尾！
            ssize_t s = read(pipefd[0], buffer, sizeof(buffer) - 1);
            if (s > 0)
            {
                buffer[s] = '\0';
                cout << "child get a message[" << getpid() << "] frome Father# " << buffer << endl;
            }else if(s == 0){
                cout << "write quit(father), me quit!" << endl;
                break;
            }
            
        }
        // close(pipefd[0]);
        exit(0);
    }
    // 3. 构建单向通信的信道，父进程写入
    // 3.1 关闭子进程不需要的fd
    close(pipefd[0]);
    string message = "我是父进程，我在给你发消息";
    int count = 0;
    char send_buffer[1024];
    while (true)
    {
        // 3.2 构建一个变化的字符串
        snprintf(send_buffer, sizeof(send_buffer), "%s[%d] : %d",
                 message.c_str(), getpid(), count);
        // 3.3 发送（写入）
        ssize_t s = write(pipefd[1], send_buffer, strlen(send_buffer));
        count++;
        assert(s != -1);
        sleep(1);
        //cout << count << endl;
        if(count == 10){
            break;
        }
    }
    close(pipefd[1]);

    pid_t ret = waitpid(id, nullptr, 0);
    assert(ret != -1);
    (void)ret;

    //close(pipefd[1]);
    return 0;
}

3.7 管道读写规则

a. 写快，读慢，写满就不能再写了，等待读取后才可以写

b. 写慢，读快，管道没有数据的时候，读必须等待

c. 写关，读0，表示读到文件结尾

d. 读关，写继续写，OS终止写进程

当没有数据可读时

O_NONBLOCK disable：read调用阻塞，即进程暂停执行，一直等到有数据来到为止。 O_NONBLOCK enable：read调用返回-1，errno值为EAGAIN。

当管道满的时候

O_NONBLOCK disable： write调用阻塞，直到有进程读走数据

O_NONBLOCK enable：调用返回-1，errno值为EAGAIN

如果所有管道写端对应的文件描述符被关闭，则read返回0

如果所有管道读端对应的文件描述符被关闭，则write操作会产生信号SIGPIPE,进而可能导致write进程退出

当要写入的数据量不大于PIPE_BUF时，linux将保证写入的原子性。

当要写入的数据量大于PIPE_BUF时，linux将不再保证写入的原子性。

3.8 总结管道特点，理解|管道

1. 管道是用来进行具有血缘关系的进程，进行进程间通信（常用于父子进程）

只能用于具有共同祖先的进程（具有亲缘关系的进程）之间进行通信；通常，一个管道由一个进程创建，然后该进程调用fork，此后父、子进程之间就可应用该管道。

2. 管道具有能通过让进程协同，提供访问控制

管道是一个文件 - 读取时需要等待管道文件被写入  -  具有访问控制

显示器也是一个文件，父子进程同时往显示器写入的时候，有没有说一个会等另一个的情况呢？  -  缺乏访问控制

3. 管道提供的时面向流式的通信服务 —— 面向字节流 —— 定制协议

4. 一般而言，内核会对管道操作进行同步与互斥

6. 管道是基于文件的，文件的生命周期一般是随进程的，因此管道的生命周期一般也随进程的！

7. 管道是单向通信的，就是半双工通信（要么收，要么发）的一种特殊情况，数据只能向一个方向流动；需要双方通信时，需要建立起两个管道

3.9 派发任务—单机版负载均衡

由父进程创建多个子进程，对每个进程创建管道，每个子进程等待父进程写入，派发任务，执行对应的任务，而父进程写入不同的管道（文件描述符），调用的便是不同的进程，写入的内容便是派发的具体任务！

task.hpp

#pragma once
#include<iostream>
#include<unistd.h>
#include<string>
#include<functional>
#include<vector>
#include<map>

//typedef std::function<void()> func;
using func = std::function<void()>;

std::vector<func> callBacks;
std::map<int, std::string> desc;

void readMySQL(){
    std::cout << "new process[ " << getpid() << " ]执行访问数据库的任务\n" << std::endl;
}


void execuleURL(){
    std::cout << "new process[ " << getpid() << " ]执行url解析\n" << std::endl;
}

void cal(){
    std::cout << "new process[ " << getpid() << " ]执行加密任务\n" << std::endl;
}

void save(){
    std::cout << "new process[ " << getpid() << " ]执行数据持久化任务\n" << std::endl;
}

void load(){
    desc.insert({callBacks.size(), "readMySQL"});
    callBacks.push_back(readMySQL);

    desc.insert({callBacks.size(), "execuleURL"});
    callBacks.push_back(execuleURL);

    desc.insert({callBacks.size(), "cal"});
    callBacks.push_back(cal);

    desc.insert({callBacks.size(), "save"});
    callBacks.push_back(save);
}

void showHandler(){
    for(const auto& iter : desc){
        std::cout << iter.first << "\t" << iter.second << std::endl;
    }
}

int handlerSize(){
    return callBacks.size();
}

proPool.cc

#include<iostream>
#include<vector>
#include<unistd.h>
#include<sys/types.h>
#include<sys/wait.h>
#include<cassert>
#include"task.hpp"
using namespace std;

#define PROCESS_NUM 5

int waitCommand(int waitFd, bool& quit)
{
    uint32_t command = 0;
    ssize_t s = read(waitFd, &command, sizeof(command));
    //assert(s == sizeof(uint32_t));
    if(s == 0){
        quit = true;
        return -1;
    }
    return command;
}

void sendAndWakeUp(pid_t who, int fd, uint32_t command)
{
    write(fd, &command, sizeof(command));
    cout << "main call process : " << who << " execute : \"" << desc[command] << "\" through : " << fd << endl;
}

int main(){
    load();
    // pid : pipefd 键值对
    vector<pair<pid_t,int>> slots;
    
    for(int i = 0; i < 5; ++i){
        int pipefd[2] = {0};
        int pp = pipe(pipefd);
        assert(pp != -1);
        (void)pp;

        int id = fork();
        assert(id != -1);
        (void)id;

        if(id == 0){
            close(pipefd[1]);
            while(true){
                bool quit = false;
                int command = waitCommand(pipefd[0], quit);

                if(quit){
                    break;
                }

                if (command >= 0 && command < handlerSize())
                {
                    callBacks[command]();
                }
                else
                {
                    cout << "非法command : " << command << endl;
                }
            }

            exit(0);
        }
        close(pipefd[0]);
        slots.push_back({id, pipefd[1]});
    }

    srand((unsigned int)time(nullptr) ^ getpid() ^ 233323123123L); // 让数据源更加随机
    
    while(true){
        int choice = rand() % slots.size();
        int command = rand() % handlerSize();
        sendAndWakeUp(slots[choice].first, slots[choice].second, command);
        sleep(1);
    }


    // while (true)
    // {
    //     int select;
    //     int command;
    //     sleep(1);
    //     cout << "###############################################" << endl;
    //     cout << "#      1. show functions   2. send commend     " << endl;
    //     cout << "###############################################" << endl;
    //     cout << "Please Select> ";
    //     cin >> select;
    //     if (select == 1)
    //     {
    //         showHandler();
    //     }
    //     else if (select == 2)
    //     {
    //         cout << "Enter Your Command>";
    //         cin >> command;
    //         // 选择进程
    //         int choice = rand() % slots.size();
    //         // 布置任务
    //         sendAndWakeUp(slots[choice].first, slots[choice].second, command);
    //     }
    //     else
    //     {
    //         break;
    //     }
    // }

    for(const auto &iter : slots){
        close(iter.second);
    }

    for(const auto &slot : slots){
        pid_t s = waitpid(slot.first, nullptr, 0);
        assert(s != -1);
    }

    return 0;
}

4. 进程通信命名管道

4.1 命名管道

• 管道应用的一个限制就是只能在具有共同祖先（具有亲缘关系）的进程间通信。
• 如果我们想在不相关的进程之间交换数据，可以使用FIFO文件来做这项工作，它经常被称为命名管道。
• 命名管道是一种特殊类型的文件,可以被打开，但是不会将内存数据刷新到磁盘

4.2 命名管道系统调用

$命名管道可以从命令行上创建，命令行方法是使用下面这个命令：

        $ mkfifo filename

$命名管道也可以从程序里创建，相关函数有：

        int mkfifo(const char *filename,mode_t mode);

头文件：

         #include <sys/types.h>
         #include <sys/stat.h>

返回值：

        On success mkfifo() returns 0.  In the case of an error, -1 is returned (in which case, errno is set appropriately).

当要写入的数据量不大于PIPE_BUF时，linux将保证写入的原子性。4096

当要写入的数据量大于PIPE_BUF时，linux将不再保证写入的原子性。

创建命名管道:

#include <iostream>
#include <sys/types.h>
#include <sys/stat.h>
int main(int argc, char *argv[])
{
 mkfifo("p2", 0644);
 return 0;
}

4.3 命名管道与匿名管道及读写规则

• 匿名管道由pipe函数创建并打开。
• 命名管道由mkfifo函数创建，打开用open
• FIFO（命名管道）与pipe（匿名管道）之间唯一的区别在它们创建与打开的方式不同，一但这些工作完成之后，它们具有相同的语义。

如果当前打开操作是为读而打开FIFO时

O_NONBLOCK disable：阻塞直到有相应进程为写而打开该FIFO

O_NONBLOCK enable：立刻返回成功

如果当前打开操作是为写而打开FIFO时

O_NONBLOCK disable：阻塞直到有相应进程为读而打开该FIFO

O_NONBLOCK enable：立刻返回失败，错误码为ENXIO

4.4 示例用命名管道实现server&client通信

log.hpp _ 输出日志信息

#ifndef _LOG_H_
#define _LOG_H_

#include <iostream>
#include <ctime>
#include <string>

#define Error 0
#define Warning 1
#define Notice 2
#define Debug 3

const std::string msg[] = {
    "Error",
    "Warning",
    "Notice",
    "Debug"
    };

std::ostream &Log(const std::string message, int level)
{
    std::cout << " | " << (unsigned)time(nullptr) << " | " << msg[level] << " | " << message;
    return std::cout;
}

#endif

comm.h _ 头文件

#ifndef _COMM_H_
#define _COMM_H_

#include <iostream>
#include <unistd.h>
#include <string>
#include <sys/types.h>
#include <cstdio>
#include <cstdlib>
#include <cstring>
#include <sys/stat.h>
#include <fcntl.h>
#include "log.hpp"
using namespace std;

#define MODE 0666
#define BUFSZ 128
string ipcPath = "./fifo.ipc";

#endif

#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <string.h>

server.cxx

#include "comm.hpp"
#include <sys/wait.h>

static void getMessage(int fd)
{
    // 3.编写正常通信代码
    char buffer[BUFSZ] = {0};
    while (true)
    {
        memset(buffer, '\0', sizeof(buffer));
        ssize_t s = read(fd, buffer, sizeof(buffer) - 1);
        if (s > 0)
        {
            buffer[s] = '\0';
            cout << "[" << getpid() << "] "
                 << "server from client say :" << buffer << endl;
        }
        else if (s == 0)
        {
            // end of file
            cout << "[" << getpid() << "] "
                 << "read end of file, client quit, server quit too!" << endl;
            break;
        }
        else
        {
            perror("read");
            exit(3);
        }
    }
}

int main()
{
    // 1.创建管道文件
    if (mkfifo(ipcPath.c_str(), MODE) == -1)
    {
        perror("mkfifo");

        exit(1);
    }
    Log("创建管道文件成功", Debug) << " |step 1" << endl;

    // 2.正常文件操作
    int fd = open(ipcPath.c_str(), O_RDONLY);
    if (fd == -1)
    {
        perror("open");

        exit(2);
    }
    Log("打开管道文件成功", Debug) << " |step 2" << endl;

    int nums = 3;
    for (int i = 0; i < nums; ++i)
    {
        pid_t id = fork();
        if (id == 0)
        {
            getMessage(fd);
            exit(4);
        }
    }

    for (int i = 0; i < nums; ++i)
    {
        waitpid(-1, nullptr, 0);
    }

    // 3.编写正常通信代码
    // getMessage(fd);

    // 4.关闭文件
    close(fd);
    Log("关闭管道文件成功", Debug) << " |step 3" << endl;

    // 5.通信完毕，删除管道文件
    unlink(ipcPath.c_str());
    Log("删除管道文件成功", Debug) << " |step 4" << endl;

    return 0;
}

client.cxx

#include"comm.hpp"

int main(){
    //1.打开管道文件
    int fd = open(ipcPath.c_str(), O_WRONLY);
    if(fd == -1){
        perror("open");
        exit(1);
    }
    //2.编写正常通信代码
    string buffer;
    while(true){
        cout << "Please Enter Message Line (Enter Exit):> ";
        getline(cin, buffer);
        ssize_t s = write(fd, buffer.c_str(), buffer.size());
        if(s == -1){
            perror("write");
            exit(2);
        }else if(s == 0){
            cout << "Exit client !" << endl;
            break;
        }
    }
    //3.关闭管道文件
    close(fd);
    return 0;
}

5. system V共享内存

共享内存区是最快的IPC形式。一旦这样的内存映射到共享它的进程的地址空间，这些进程间数据传递不再涉及到内核，换句话说是进程不再通过执行进入内核的系统调用来传递彼此的数据

system V IPC资源，生命周期随内核（手动删除 #ipcrm -m shmid，代码删除）

5.1 共享内存示意图

共享内存不属于任何一个进程，属于操作系统

堆栈之间共享区域：属于操作系统，还是属于用户呢？ —— 属于用户，用户空间 (32位下，进程地址空间0-3G属于用户，1G属于内核)，用户空间意味着，拿到后不用使用系统调用，可以直接使用！

获取到共享内存后，双方进程如果要通信，直接进行内存级的读和写即可

5.2 共享内存数据结构

共享内存由操作系统维护，因此需要有对应的数据结构维护

struct shmid_ds {
 struct ipc_perm shm_perm; /* operation perms */
 int shm_segsz; /* size of segment (bytes) */
 __kernel_time_t shm_atime; /* last attach time */
 __kernel_time_t shm_dtime; /* last detach time */
 __kernel_time_t shm_ctime; /* last change time */
 __kernel_ipc_pid_t shm_cpid; /* pid of creator */
 __kernel_ipc_pid_t shm_lpid; /* pid of last operator */
 unsigned short shm_nattch; /* no. of current attaches */
 unsigned short shm_unused; /* compatibility */
 void *shm_unused2; /* ditto - used by DIPC */
 void *shm_unused3; /* unused */
};

共享内存 = 共享内存块 + 对应的共享内存的内核数据结构

5.3 共享内存系统调用

1. 共享内存的创建及key_t:

shmget函数：

功能：用来创建共享内存
原型
 int shmget(key_t key, size_t size, int shmflg);
参数
 key:这个共享内存段名字
 size:共享内存大小
 shmflg:IPC_CREAT and IPC_EXCL 两个选项
返回值：成功返回一个非负整数，即该共享内存段的标识码；失败返回-1

shmget参数中shmflg选项含义：

• 单独使用IPC_CREAT：如果创建共享内存时，若底层已经存在，获取之，并且返回，如果不存在，创建之，并返回
• 单独适应IPC_EXCL：没有意义
• 共同使用：如果底层不存在，创建并返回，如果存在，出错返回，因此，返回的一定是一个新的shm！

ftok函数：只有创建的时候用key，大部分情况用户访问共享内存，都用的shmid

NAME
       ftok - convert a pathname and a project identifier to a System V IPC
       key

SYNOPSIS
       #include <sys/types.h>
       #include <sys/ipc.h>

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

RETURN VALUE
       On success, the generated key_t value is returned.  On failure -1 is
       returned, with errno indicating the error as for the stat(2)  system
       call.

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

sgmctl函数中cmd选项：

IPC_STAT         Copy information from the kernel data structure associated
                 with  shmid into the shmid_ds structure pointed to by buf.
                 The caller must have read permission on the shared  memory
                 segment.

IPC_SET          Write the values of some members of the shmid_ds structure
                 pointed to by buf to the kernel data structure  associated
                 with   this  shared  memory  segment,  updating  also  its
                 shm_ctime member.  The following fields  can  be  changed:
                 shm_perm.uid,  shm_perm.gid,  and (the least significant 9
                 bits of) shm_perm.mode.  The effective UID of the  calling
                 process  must  match  the  owner (shm_perm.uid) or creator
                 (shm_perm.cuid) of the shared memory segment, or the call‐
                 er must be privileged.

IPC_RMID         Mark  the  segment to be destroyed.  The segment will only
                 actually be destroyed after the last process  detaches  it
                 (i.e., when the shm_nattch member of the associated struc‐
                 ture shmid_ds is zero).  The caller must be the  owner  or
                 creator,  or  be privileged.  If a segment has been marked
                 for destruction, then the (nonstandard) SHM_DEST  flag  of
                 the  shm_perm.mode  field in the associated data structure
                 retrieved by IPC_STAT will be set.

                 The caller  must  ensure  that  a  segment  is  eventually
                 destroyed;  otherwise  its pages that were faulted in will
                 remain in memory or swap.

5.4  命名管道访问控制共享内存

log.hpp

#ifndef _LOG_H_
#define _LOG_H_

#include <iostream>
#include <ctime>
#include <string>

#define Error 0
#define Warning 1
#define Notice 2
#define Debug 3

const std::string msg[] = {
    "Error",
    "Warning",
    "Notice",
    "Debug"
    };

std::ostream &Log(const std::string message, int level)
{
    std::cout << " | " << (unsigned)time(nullptr) << " | " << msg[level] << " | " << message;
    return std::cout;
}

#endif

comm.hpp

#pragma once

#include<iostream>
#include<string>
#include<cstdlib>
#include<cstring>
#include<unistd.h>
#include<sys/stat.h>
#include<sys/types.h>
#include<sys/ipc.h>
#include<sys/shm.h>
#include<fcntl.h>
#include<cassert>
#include"log.hpp"

#define PATH_NAME "/home/customer"
#define PROJ_ID 0x66
//共享内存的大小，最好是页（PAGE ：4096）的整数倍
#define SHM_SIZE 4096

#define FIFO_NAME "./fifo"

class Init{
public:
    Init(){
        umask(0);
        int n = mkfifo(FIFO_NAME, 0666);
        assert(n != -1);
        (void)n;
        Log("create fifo success", Notice) << std::endl;
    }
    ~Init(){
        unlink(FIFO_NAME);
        Log("remove fifo success", Notice) << std::endl;
    }
};

#define READ O_RDONLY
#define WRITE O_WRONLY

int openFIFO(std::string pathName, int flags){
    int fd = open(pathName.c_str(), flags);
    assert(fd != -1);
    Log("open fifo sucess", Notice) << std::endl;
    return fd;
}

void Wait(int fd){
    Log("等待中...", Notice) << std::endl;
    uint32_t temp = 0;
    ssize_t s = read(fd, &temp, sizeof(uint32_t));
    assert(s == sizeof(uint32_t));
    (void)s;
}

void Signal(int fd){
    Log("唤醒中...", Notice) << std::endl;
    uint32_t temp = 1;
    ssize_t s = write(fd, &temp, sizeof(uint32_t));
    assert(s == sizeof(uint32_t));
    (void)s;
}

void closeFIFO(int fd){
    Log("close fifo success", Notice) << std::endl;
    close(fd);
}

shmServer.cc

#include"comm.hpp"
Init init;


int main(){
    Log("Server process pid is ", Debug) << getpid() << std::endl;
    //1.创建公共的key值
    key_t k = ftok(PATH_NAME, PROJ_ID);
    if(k == -1){
        perror("ftok");
        exit(1);
    }
    Log("create key done! ", Debug);
    printf(" server key :  0x%x\n", k);
    //2.创建共享内存 -- 建议创建一个全新的共享内存 -- because this process is 通信的发起者
    //  IPC_CREAT 没有，建之，返回，有，返回
    //  IPC_EXCL 存在，报错，单独使用，无意义
    //  IPC_CREAT | IPC_EXCL 没有，建之，并返回，有，报错 ———— 一定是创建一个新的shm
    int shmid = shmget(k, SHM_SIZE, IPC_CREAT | IPC_EXCL | 0666);
    //  共享内存创建不删除，第二次以同样key值创建共享内存，便会报错
    if(shmid == -1){
        perror("shmget");
        exit(2);
    }
    Log("create shm done! ", Debug) << " server shmget() shmid : " << shmid << std::endl;
    //sleep(10);



    //3.将创建的shared memory，挂接到该进程的地址空间处
    char* shmaddr = (char*)shmat(shmid, nullptr, 0);
    if(shmaddr == (void*)-1){
        perror("shmat");
        exit(3);
    }
    Log("attach shm done! ", Debug) << " server shmat() shmid : " << shmid << std::endl;

//【通信逻辑区


    //char buffer[SHM_SIZE];
    int fd = openFIFO(FIFO_NAME, READ);

    for(;;){
        Wait(fd);

        printf("%s\n", shmaddr);
        if(strcmp(shmaddr, "quit") == 0){
            break;
        }
        //sleep(1);
    }


//通信逻辑区】

    //sleep(10);
    //4.将指定的shared memory，从自己的地址空间处去挂接
    int detach = shmdt(shmaddr);
    if(detach == -1){
        perror("shmdt");
        exit(4);
    }
    Log("detach shm done! ", Debug) << " server shmdt() shmid : " << shmid << std::endl;



    //5.删除共享内存，IPC_RMID即便是由进程和当下的shm挂接，依旧删除共享内存
    int rmshmid = shmctl(shmid, IPC_RMID, nullptr);
    if(rmshmid == -1){
        perror("shmctl");
        exit(6);
    }
    Log("delete shm done! ", Debug) << " server shmctl() shmid : " << shmid << std::endl;

    closeFIFO(fd);

    return 0;
}

shmClient.cc

#include "comm.hpp"

int main()
{
    Log("Client process pid is ", Debug) << getpid() << std::endl;
    // 1.创建公共的key值
    key_t k = ftok(PATH_NAME, PROJ_ID);
    Log("create key done! ", Debug);
    printf(" server key :  0x%x\n", k);
    if (k == -1)
    {
        perror("ftok");
        exit(1);
    }

    // 2.获取共享内存的id
    int shmid = shmget(k, SHM_SIZE, 0);
    if (shmid == -1)
    {
        perror("shmget");
        exit(2);
    }
    Log("create shm done! ", Debug) << " server shmget() shmid : " << shmid << std::endl;
    //sleep(10);

    // 3.挂接
    char *shmaddr = (char *)shmat(shmid, nullptr, 0);
    if (shmaddr == (void *)-1)
    {
        perror("shmat");
        exit(3);
    }
    Log("attach shm done! ", Debug) << " server shmat() shmid : " << shmid << std::endl;
    // 【通信逻辑区


    int fd = openFIFO(FIFO_NAME, WRITE);

    while ((true))
    {
        
        size_t i = 0;
        shmaddr[i] = std::cin.get();
        while(shmaddr[i] != '\n'){
            shmaddr[++i] = std::cin.get();
        }
        shmaddr[i] = 0;
        // std::cin >> shmaddr;

        Signal(fd);

        if(strcmp(shmaddr, "quit") == 0){
            break;
        }
    }
    

    // char a = 'a';
    // for (; a <= 'z'; a++)
    // {
    //     shmaddr[a - 'a'] = a;
    //     shmaddr[a - 'a' + 1] = '\0'; 
    //     sleep(1);
    //     // snprintf(shmaddr, SHM_SIZE - 1,
    //     //          "hello serve，我是 Client 进程，我的pid：%d，inc：%c\n", getpid(), a);
    //     // sleep(5);
    // }
    // strcpy(shmaddr, "quit");

    // 通信逻辑区】
    //sleep(20);
    // 4.去挂接
    int detach = shmdt(shmaddr);
    if (detach == -1)
    {
        perror("shmdt");
        exit(4);
    }
    Log("detach shm done! ", Debug) << " server shmdt() shmid : " << shmid << std::endl;

    closeFIFO(fd);

    return 0;
}

5.5 共享内存总结

结论1：只要是通信双方使用shm，一方直接向共享内存中写入数据，另一方，就可以立马看到对方写入的数据！

共享内存是所有进程间通信IPC，速度最快的！原因 ： 不需要过多的拷贝（不需要陷入内核，不需要将数据给操作系统）！！！

结论2：共享内存缺乏访问控制！会带来并发问题！

注意：共享内存没有进行同步与互斥！

6. system V消息队列 — 选学

• 消息队列提供了一个从一个进程向另外一个进程发送一块数据的方法
• 每个数据块都被认为是有一个类型，接收者进程接收的数据块可以有不同的类型值
• 特性方面: IPC资源必须删除，否则不会自动清除，除非重启，所以system V IPC资源的生命周期随内核

7. system V信号量 — 选学

信号量主要用于同步和互斥的，下面先来看看什么是同步和互斥。

进程互斥:

• 由于各进程要求共享资源，而且有些资源需要互斥使用，因此各进程间竞争使用这些资源，进程的这种关系为进程的互斥
• 系统中某些资源一次只允许一个进程使用，称这样的资源为临界资源或互斥资源。
• 在进程中涉及到互斥资源的程序段叫临界区
• 特性方面: IPC资源必须删除，否则不会自动清除，除非重启，所以system V IPC资源的生命周期随内核