Linux应用开发（8）：Linux进程间通信（IPC）：管道

news2024/11/12 20:35:19

Linux应用开发（7）：Linux进程间通信（IPC）：POSIX消息队列https://blog.csdn.net/tecsai/article/details/137879465

1. 简述

我们在前面已经介绍了进程间通信（IPC）常用的“消息队列”。本节将讲解另外一种常用的IPC机制，我们称作管道。

管道可以理解为一种特殊的文件，也可以理解为一种特殊的缓冲区，它允许两个进程通过一个半双工的通道进行数据通信。

2. 基本概念

上面提到，管道是半双工的，数据只能向一个方向流动。在使用过程中，需要双方同时打开（也可以由父进程先打开，再由子进程继承）。管道分为无名管道和命名管道。

无名管道

无名管道只能用于父子进程或者兄弟进程之间（具有亲缘关系的进程），它之所以成为无名管道，是因为它们不需要文件系统中的文件支持。管道的缓冲区是有限的。

命名管道

相对于无名管道，命名管道是基于特殊的文件来进行通信的。在使用时，首先需要文件系统中有一个路径和名称，因此命名管道是可以允许不相关的进程进行通信。

3. 无名管道

无名管道顾名思义，是没有被命名的管道，其存在于内存中，仅允许相关的两个进程间进行通信。

PS：可以联想到无名信号量和有名信号量，前者在内存中，仅允许关联进程同步，后者则可以在不相关联的进程间进行同步。

无名管道的创建采用如下API。

#include <unistd.h>

int pipe(int fd[2]);

fd 是一个整型数组，包含两个元素：fd[0] 用于读取，fd[1] 用于写入。

无名管道例程。

#include <stdio.h>

#include <unistd.h>

#include <stdlib.h>

#include <string.h>

#include <sys/wait.h>


int main(int argc, char* argv[])

{

    int fds[2];

    pid_t pid;

    char buffer[50];

    if (pipe(fds) == -1) {

        perror("pipe");

        exit(EXIT_FAILURE);

    }

    /** 创建进程. */

    pid = fork();

    if (pid == -1) {

        perror("fork");

        exit(EXIT_FAILURE);

    }

    if (pid == 0) {

        /** 子进程：写入管道. */

        close(fds[0]); ///< 关闭读端

        write(fds[1], "Hello, Parent!", 15);

        close(fds[1]); ///< 写入后关闭写端

    } else {

        /** 父进程：读取管道。 */

        wait(NULL); ///< 等待子进程结束

        close(fds[1]); ///< 关闭写端

        read(fds[0], buffer, 50);

        close(fds[0]); ///< 读取后关闭读端

        printf("Parent Process: %s\n", buffer);

    }

    return 0;

}

4. 命名管道

命名管道（FIFO）是一种特殊的文件，它允许不相关的进程通过一个命名的路径进行通信。与无名管道不同，命名管道在文件系统中有一个路径和名称。

创建命名管道的API如下。

#include <sys/stat.h>

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

命名管道例程。

#include <stdio.h>

#include <stdlib.h>

#include <unistd.h>

#include <fcntl.h>

#include <sys/stat.h>


int main(int argc, char* argv[])

{

    /** 文件路径. */

    const char *fifo_name = "my_fifo";

    int fd;

    /** 创建命名管道. */

    if (mkfifo(fifo_name, 0666) == -1) {

        perror("mkfifo");

        exit(EXIT_FAILURE);

    }

    /** 打开命名管道进行写入. */

    fd = open(fifo_name, O_WRONLY);

    if (fd == -1) {

        perror("open");

        exit(EXIT_FAILURE);

    }

    /** 写入命名管道. */

    write(fd, "Hello, through FIFO!", 20);

    close(fd);

    /** 清理命名管道. */

    unlink(fifo_name);

    return 0;

}