【Linux】命名管道

简介: 【Linux】命名管道

一、命名管道的原理

      在前面的博客中,我们学习了匿名管道,了解到了两个具有血缘关系的进程之间是如何进行通信的?那么在没有血缘关系(毫不相关)的进程之间是如何进行通信的?

      大致思路是一样的,我们还是需要能够进行让两个进程之间可以看到同一份资源,然后在同一份资源中进行读写和通信。如何让两个进程看见同一份文件呢??由于在Linux系统中,Linux的树形结构保证了一个文件只有一个唯一的路径。我们可以根据文件的路径来找到同一份文件。

二、使用指令来看一下命名管道

在man手册中,可以查到指令的命名管道:

mkfifo  XXXX

      我们可以进行通信,复制一下终端,利用两个终端进行通信:在一个终端中利用echo来打印到屏幕中,用另一个终端进行接收显示。

1. // 循环打印到命名管道的命令为:
2. while :; do echo "Hello world" ; sleep 1; done > myfifo
3. 
4. // 接收的命令为:
5. cat < myfifo

在一个过程中有两个细节:

1. 在向命名管道中写入时,管道中的容量大小怎么进行改变?

为什么会有上面的现象呢??

      命名管道和匿名管道一样,都是内存文件,只不过命名管道在磁盘有一个简单的映像,但这个映像的大小永远为0,因为命名管道和匿名管道都不会将通信数据刷新到磁盘当中。

2. 我在接收端将读端进行关闭,为什么进程会直接退出呢?

      在之前的匿名管道的博客中,我们知道:读端直接关闭,写端一直在写,写端进程会被操作系统直接使用13号信号进行关闭,相当于程序出现异常。因为echo是内建命令,是有bash进程进行控制的。当我们终止掉读端进程后,因为写端执行的循环脚本是由命令行解释器bash执行的,所以此时bash就会被操作系统杀掉,我们的云服务器也就退出了

三、命名管道的代码

      现在,我们使用代码来创建一个命名管道,具体代码如下:

3.1 先来介绍一下使用的函数

3.1.1 mkfifo函数

函数的原型:

函数的参数部分:

  • pathname:创建管道文件的文件路径
  • mode:存放创建管道文件的权限

函数的返回值:

  • 如果函数成功返回0,如果失败返回-1

函数的功能:

  • 该函数用于在文件系统中创建一个文件,该文件用于提供FIFO功能,即命名管道。

3.1.2 unlink函数

函数的原型:

函数的参数部分:

  • pathname:创建管道文件的文件路径

函数的返回值:

  • 函数的返回值为 0 表示成功,-1 表示失败,并设置相应的错误码。

函数的功能:

  • 该函数用于删除文件系统中的文件。它通过删除文件系统中文件的链接,从而使文件系统中不再存在该文件的链接。
  • 当所有链接(包括硬链接和符号链接)都被删除之后,文件系统便会回收文件占用的磁盘空间。
  • 需要注意的是,删除文件并不会立即释放文件的磁盘空间,而是在文件的引用计数为零时才会真正回收空间。

3.1.3 open函数

函数的原型:

函数的参数:

  • pathname:创建管道文件的文件路径
  • flags:一些标志位,我们需要认识一些标志位,这些标志位通过按位与进行传参,我们需要通过位图的知识点来将每一个标志位进行分开,分别进行不同函数的操作。open函数的一些标志位的写法和用途:

函数的返回值:

  • 调用成功时返回一个文件描述符fd,调用失败时返回-1,并修改errno

函数的功能:

  • 打开文件

3.1.4 write函数

3.1.5 read函数

3.2 命名管道类的编写

3.2.1 创建命名管道的代码编写

const std::string comepath = "./myfifo"; // 先确定要打开的文件路径
 
int CreateNamePipe(const std::string &path)
{
    int res = mkfifo(path.c_str(), 0666); // 在相应的路径创建管道文件,并设置其权限
    if (res != 0)
    {
        perror("mkfifo");
        std::cerr << "errno:" << errno << std::endl;
    }
    return res;
}

3.2.2 删除管道文件的代码编写

int RemoveNamePipr(const std::string &path)
{
    int res = unlink(path.c_str());
    if (res != 0)
    {
        perror("RemoveNamePipe");
    }
    return res;
}

3.2.3 最后将两个函数进行整合

class NamePipe
{
public:
    // 创建管道
    NamePipe(const std::string &path, int who)
        : fifo_pipe(path), _id(who), _fd(default)
    {
        if (_id == Creater)
        {
            int res = mkfifo(path.c_str(), 0666);
            if (res != 0)
            {
                perror("mkfifo");
            }
            std::cout << "Craeter create name pipe" << std::endl;
        }
    }
 
    // 销毁管道
    ~NamePipe()
    {
        if (_id == Creater)
        {
            int res = unlink(fifo_pipe.c_str());
            if (res != 0)
            {
                perror("RemoveNamePipe");
            }
            std::cout << "Create free name pipe" << std::endl;
        }
        if(_fd != default) close(_fd);
    }
 
private:
    const std::string &fifo_pipe;  // 存放管道文件的路径
    int _id;   // 检查是创建者还是使用者
    int _fd;   // 存放文件描述符
};

3.3 打开管道文件的代码编写

      我们已经知道了文件的路径,这时,我们需要调用open函数来进行文件的打开,并且表示是以读的形式打开,还是以写的形式打开。利用系统调用函数,将管道文件打开。

bool opennamepipe(int mode)
{
    _fd = open(fifo_pipe.c_str(), mode);  // mode传递的是标志位
    if (_fd < 0)
    {
        return false;
    }
    return true;  // _fd是文件描述符
}

3.4 以读的形式或者以写的形式打开文件的代码编写

在打开文件的open函数中有一个标志位,我们可以使用标志位对文件进行不同的操作。

#define Read O_RDONLY  // 标志位
#define Write O_WRONLY
 
// 以读的形式打开
bool openforread()
{
    return opennamepipe(Read);
}
 
// 以写的形式打开
bool operforwrite()
{
    return opennamepipe(Write);
}

3.5 读管道和写管道

// 读管道
int ReadNamePipe(std::string *out)
{
    char buff[Basesize];
    int n = read(_fd, buff, sizeof buff);
    if(n > 0)
    {
       buff[n] = '\0';
       *out = buff;
    }
    return n;
}
 
// 写管道
int WriteNamePipe(const std::string& in)
{
    return write(_fd, in.c_str(), in.size());
}

3.6 编写发送端和接收端的代码编写

读端的代码:

#include "namedpipe.hpp"
 
// server进行读取,管理命名管道的整个生命周期
int main()
{
    // 创建管道
    NamePipe fifo(comepath, Creater);
    // 对于读端而言,如果我们打开文件,但是写端还没来,我会阻塞在open调用中,直到对方打开
    // 进程同步,
    if (fifo.openforread())
    {
        while (true)
        {
            std::string message;
            int n = fifo.ReadNamePipe(&message);
            if (n > 0)
            {
                std::cout << "Client sat:" << message << std::endl;
            }
            else if(n == 0)
            {
                std::cout << "Client quit, server too" << std::endl;
                break;
            }
            else
            {
                std::cout << "fifo.ReadNamePipe error" << std::endl;
                break;
            }
        }
    }
    return 0;
}

写端的代码:

#include "namedpipe.hpp"
 
int main()
{
    NamePipe fifo(comepath, User);
 
    if (fifo.operforwrite())
    {
        while (true)
        {
            std::cout << "Plass Enter:" << std::endl;
            std::string message;
            std::getline(std::cin, message);
            fifo.WriteNamePipe(message);
        }
    }
 
    return 0;
}

有一个细节

3.7 对代码进行进一步的修改

使得代码中管道的释放可以顺序进行。

四、回归概念

      最后,我们在来复盘一下匿名管道和命名管道。让不同的进程看到同一份资源,匿名管道和命名管道的区别是:匿名管道是父子间继承的方式来进行看到同一份管道资源,而命名管道是通过文件的唯一路径来看到同一份管道资源。

相关文章
|
1月前
|
Linux
【Linux】匿名管道实现简单进程池
【Linux】匿名管道实现简单进程池
|
1月前
|
存储 负载均衡 Linux
【Linux 系统】进程间通信(匿名管道 & 命名管道)-- 详解(下)
【Linux 系统】进程间通信(匿名管道 & 命名管道)-- 详解(下)
|
1月前
|
消息中间件 Unix Linux
【Linux 系统】进程间通信(匿名管道 & 命名管道)-- 详解(上)
【Linux 系统】进程间通信(匿名管道 & 命名管道)-- 详解(上)
|
1月前
|
Linux
【Linux】命名管道的创建方法&&基于命名管道的两个进程通信的实现
【Linux】命名管道的创建方法&&基于命名管道的两个进程通信的实现
|
1月前
|
Linux
【Linux】进程通信之匿名管道通信
【Linux】进程通信之匿名管道通信
|
21天前
|
Linux Shell
【Linux】管道
【Linux】管道
|
1月前
|
消息中间件 Unix Linux
【探索Linux】P.14(进程间通信 | 匿名管道 | |进程池 | pipe() 函数 | mkfifo() 函数)
【探索Linux】P.14(进程间通信 | 匿名管道 | |进程池 | pipe() 函数 | mkfifo() 函数)
37 0
|
Linux C++ 安全
Linux进程间通信——使用命名管道
在前一篇文章——Linux进程间通信——使用匿名管道中,我们看到了如何使用匿名管道来在进程之间传递数据,同时也看到了这个方式的一个缺陷,就是这些进程都由一个共同的祖先进程启动,这给我们在不相关的的进程之间交换数据带来了不方便。
1252 0