【Linux】单机版QQ之管道中的命名管道

这篇具有很好参考价值的文章主要介绍了【Linux】单机版QQ之管道中的命名管道。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

还记得上一篇的匿名管道吗?

文章目录

  • 前言
  • 一、命名管道
  • 总结

前言

命名管道是什么呢?

管道应用的一个限制就是只能在具有共同祖先(具有亲缘关系)的进程间通信。
如果我们想在不相关的进程之间交换数据,可以使用FIFO文件来做这项工作,它经常被称为命名管道。
命名管道是一种特殊类型的文件。

一、命名管道

在学习命名管道前我们先看看在命令行创建命名管道的函数mkfifo:

【Linux】单机版QQ之管道中的命名管道

 fifo的意思就是first in first out也就是先进先出的意思,比如我们直接在目录下创建一个命名管道文件:

【Linux】单机版QQ之管道中的命名管道

在文件的权限部分的第一个P代表的是管道文件,下面我们讲讲命名管道的原理:

【Linux】单机版QQ之管道中的命名管道同样有两个进程,上面的是父进程下面是子进程,父进程的一个3号文件描述符表中记录一个文件的地址,这也是被父进程打开的文件,当我们创建一个子进程时,想让子进程打开和父进程打开的相同的那个文件,对于操作系统来说是不会重新再创建一个相同的文件的,操作系统会查询子进程要打开的文件是否已经被打开,如果找到这个被打开的文件就把这个文件的地址填入子进程的文件描述符表中,这样子进程就指向父进程打开的这个文件了,并且在文件中会有像ret这样的变量,当我们有文件描述符指向这个文件时这个变量就会++这也就是引用计数,关闭文件后就会--。那么如何保证两个毫不相关的进程看到的是同一个文件并打开呢?其实很简单,因为文件的唯一性是用路径表示的,只要让不同的进程通过文件路径+文件名看到同一个文件并打开,就是看到了同一个资源,这就具备了进程间通信的前提

 接下来我们用代码演示命名管道,首先需要创建两个文件client.cc写客户端代码,serve.cc写服务端代码,因为这次我们要实现两个可执行程序,所以我们需要在makefile中生成两个可执行程序,makefile代码如下图:

【Linux】单机版QQ之管道中的命名管道

 .PHONY后面加上all,就是说我的目标文件是all,我们让all只有依赖关系没有依赖方法,这样就会去找server和client的依赖关系,就生成了两个可执行程序。下面我们正式编写代码,还记得我们刚开始讲的mkfifo函数吗?此函数的参数需要路径和选项(下面有C库中的mkfifo函数的说明),对于路径我们直接搞一个const string类型的字符串来保存路径,因为服务端和客户端需要打开同一份文件所以我们再创建一个公共的hpp头文件,把我们刚刚定义的路径放进去:

【Linux】单机版QQ之管道中的命名管道

下面我们再看一下C库中的mkfifo函数说明:

【Linux】单机版QQ之管道中的命名管道

 我们可以看到此函数有两个参数,第一个参数是路径,第二个参数是mode,mode是什么呢?mode_t类型又是什么呢?实际上mode_t就是一种无符号整数,我们在讲文件的时候提到过,就是一种让你控制要创建的文件初始是什么权限,我们默认将权限给成0666。

【Linux】单机版QQ之管道中的命名管道

下面我们编写服务端的代码,不知道大家还记不记得之前说过的,对于权限我们给的是0666但是经过权限掩码的影响会变成其他的,所以我们如果不想被权限掩码所影响就将默认的权限掩码设置为0。

【Linux】单机版QQ之管道中的命名管道 因为我们在创建管道文件的时候会有可能失败,所以我们用if语句判断一下,函数返回值如果等于0就是成功否则就是失败,失败我们就打印对应的错误然后返回1.下一步就是让服务端开启管道文件,开启后就可以正常通信了:

int main()
{
    //1.创建管道文件,我们今天只需要一次创建
    umask(0);   //这个设置并不影响系统的默认设置,只会影响当前进程
    int n = mkfifo(fifoname.c_str(),mode);
    if (n!=0)
    {
        std::cout<<errno<<" : "<<strerror(errno)<<std::endl;
        return 1;
    }
    std::cout<<"creat fifo file sucess"<<std::endl;
    // 2.让服务端直接开启管道文件
    int rfd = open(fifoname.c_str(),O_RDONLY);
    if (rfd<=0)
    {
        std::cout<<errno<<" : "<<strerror(errno)<<std::endl;
        return 2;
    }
    std::cout<<"open fifo success , begin ipc"<<std::endl;
    return 0;
}

 开启管道文件很简单,就是打开我们创建的管道文件,这里只需要以只读方式打开就可以。同样要判断打开失败的情况,成功后我们就打印打开管道文件成功。下面我们实现开始正常通信的代码:

int main()
{
    //1.创建管道文件,我们今天只需要一次创建
    umask(0);   //这个设置并不影响系统的默认设置,只会影响当前进程
    int n = mkfifo(fifoname.c_str(),mode);
    if (n!=0)
    {
        std::cout<<errno<<" : "<<strerror(errno)<<std::endl;
        return 1;
    }
    std::cout<<"creat fifo file sucess"<<std::endl;
    // 2.让服务端直接开启管道文件
    int rfd = open(fifoname.c_str(),O_RDONLY);
    if (rfd<=0)
    {
        std::cout<<errno<<" : "<<strerror(errno)<<std::endl;
        return 2;
    }
    std::cout<<"open fifo success , begin ipc"<<std::endl;
    //3.正常通信
    char buffer[NUM];
    while (true)
    {
        buffer[0] = 0;
        ssize_t n = read(rfd,buffer,sizeof(buffer)-1);
        if (n>0)
        {
            buffer[n] = 0;
            std::cout<<"client# "<<buffer<<std::endl;
        }
        else if (n==0)
        {
            std::cout<<"client quit,me to"<<std::endl;
            break;
        }
        else 
        {
            std::cout<<errno<<" : "<<strerror(errno)<<std::endl;
            break;
        }

    }

    //关闭不要的fd
    close(rfd);
    return 0;
}

当我们正常通信的时候需要从缓冲区读数据所以先创建一个缓冲区,缓冲区大小设置为宏放在公共头文件中,因为我们把读到的数据当字符串看,所以在调用read函数的时候要让sizeof-1不要读\0,然后把缓冲区初始化一下对于C语言,直接在0位置放个\0就会认为是空字符串。然后我们判断函数返回值,如果已经读到数据结尾我们就在最后的位置放一个\0,因为我们打印字符串的时候是按照C语言的标准打印,而C语言字符串必须以\0结尾,因为服务端接收客户端发来的消息,所以在打印字符串前面加上客户端的名称。当返回值等于0说明客户端不在写东西了,客户端已经退出了,客户端都退出了就让服务端也退出,else就是读取失败,打印失败原因即可。通信结束后我们关闭管道文件即可。下面我们实现客户端:

#include <iostream>
#include <cerrno>
#include <cstring>
#include <sys/types.h>
#include <sys/stat.h>
#include <unistd.h>
#include <fcntl.h>
#include "comm.hpp"
#include <assert.h>
int main()
{
    //1.不需要创建管道文件,只需要打开对应的文件即可
    int wfd = open(fifoname.c_str(),O_WRONLY);
    if (wfd<0)
    {
        std::cerr<<errno<<":"<<strerror(errno)<<std::endl;
        return 1;
    }

    close(wfd);
    return 0;
}

客户端不需要创建管道文件,因为服务端已经创建了所以我们和服务端一样打开即可,打开后因为我们的客户端要写入消息所以以只写方式打开,当打开函数的返回值小于0直接打印报错信息,接下来我们实现通信方式:

int main()
{
    //1.不需要创建管道文件,只需要打开对应的文件即可
    int wfd = open(fifoname.c_str(),O_WRONLY);
    if (wfd<0)
    {
        std::cerr<<errno<<":"<<strerror(errno)<<std::endl;
        return 1;
    }

    //可以进行常规通信了
    char buffer[NUM];
    while (true)
    {
        std::cout<<"请输入你的消息# ";
        char* msg = fgets(buffer,sizeof(buffer),stdin);
        assert(msg);
        (void)msg;
        buffer[strlen(buffer)-1] = 0;
        if (strcasecmp(buffer,"quit")==0)
        {
            break;
        }
        ssize_t n = write(wfd,buffer,strlen(buffer));
        assert(n>=0);
        (void)n;
    }
    close(wfd);
    return 0;
}

 同样我们要先创建一个缓冲区,然后直接循环写入消息,然后将写入的消息放到我们的缓冲区中,用一个指针接收客户输入的字符串,如果成功了这个指针保存的就是字符串的起始地址,我们在接收字符串的时候并不需要考虑\0,因为fgets这是C语言函数会自动加上\0的,断言一下空指针,然后将指针强转是为了防止出现在release版本变量被定义但是却没有使用的情况。buffer(len-1)是什么意思呢?这里其实是因为我们客户端输入字符串后会按一下回车,而回车也会被放入缓冲区中,这样的话在打印的时候服务端会多一行空白,所以我们把回车删掉就没有问题了。接下来我们让客户端输入quit的时候就退出程序,因为我们在服务端设置的是只要客户端退出服务端也就跟着退出了。然后我们向文件里写数据,把我们缓冲区的数据写到文件中,在这里同样不用考虑\0,因为只有C语言规定字符串后面必须加\0,而write是系统接口不会考虑\0的。做完这一步后我们断言一下函数返回值,不让返回值大于等于0的意思是如果是空串或者错误就不去写入了。然后同样强转一下刚刚的返回值n。最后我们将文件关闭即可,下面我们就试试可以运行吗:

运行的时候我们必须开两个窗口,当创建好两个可执行程序后,我们先运行服务端程序,这个时候程序会卡着不动,因为服务端要等待客户端打开同一个文件所以我们在运行客户端:

【Linux】单机版QQ之管道中的命名管道

【Linux】单机版QQ之管道中的命名管道 这样我们就完成了命名管道的通信,这里还有一个问题就是当我们运行一次程序后就有了管道文件下一次运行程序会出现文件已经存在的报错,所以我们可以直接在服务端关闭文件后取消链接这个文件:

【Linux】单机版QQ之管道中的命名管道

 这样的话我们每次运行程序就不用先将管道文件删除再运行了。

下面我们将这个命名管道改为用户每输入一个字符,服务端就相应的输出一个字符,大家可以理解为就像我们将手机投屏到电脑上手机上做什么操作电脑屏幕就是什么操作。

因为我们前面的实现每次需要输入回车服务端才会显示消息,现在我们需要不输入回车就写入内容的函数,这里我们用的getch函数,由于getch需要用到ncurses库,所以我们先安装这个库:

(按照ncurses库这个方法我们没有搞定,如果有搞定的小伙伴可以私信我哦~成功的方法在下面我用红字提醒出来了可直接找到后用系统方法)

【Linux】单机版QQ之管道中的命名管道

 如果大家是普通用户的话前面记得加上sudo提权。安装好后我们在刚刚的代码中加上这个库的头文件:

【Linux】单机版QQ之管道中的命名管道

 因为我们是在客户端完成这个操作所以只需要在client.cc文件中包上这个头文件即可。然后我们修改一下client.cc文件中的代码:

【Linux】单机版QQ之管道中的命名管道

 考虑到大家可能不熟悉getch这个函数,下面我们把这个函数的文档找出来:

【Linux】单机版QQ之管道中的命名管道

【Linux】单机版QQ之管道中的命名管道

 修改完成后下面我们把代码运行起来:

【Linux】单机版QQ之管道中的命名管道

 由于编译不通过是因为我们没有引入client的库,所以我们引入一下:

【Linux】单机版QQ之管道中的命名管道

【Linux】单机版QQ之管道中的命名管道

 引入后我们重新生成一下可执行文件:

【Linux】单机版QQ之管道中的命名管道

【Linux】单机版QQ之管道中的命名管道

 运行后我们发现服务端不能正常打印了,其实原因在于函数的返回值问题,我们刚刚看文档人家的返回值是int类型,结果我们用char类型接收了,所以就出错了,下面我们修改一下代码:

由于我们不知道返回值是什么,所以我们先在代码中直接打印一下返回值:

【Linux】单机版QQ之管道中的命名管道

 通过打印我们发现返回值为-1:

【Linux】单机版QQ之管道中的命名管道

【Linux】单机版QQ之管道中的命名管道

 然后我们将代码修改为当返回值为-1我们就继续读取字符,但是在运行的过程中由于此方法有一些错误导致还是不能成功,所以我们下面直接用系统方法不用库方法:

【Linux】单机版QQ之管道中的命名管道

 然后我们在服务端接收的时候不打印前面的客户端名称了,直接就是接收什么打印什么(在这里记得刷新缓冲区):

【Linux】单机版QQ之管道中的命名管道

 然后下面我们运行起来:

【Linux】单机版QQ之管道中的命名管道

 这样我们就实现了一开始的功能,通过以上管道的学习相信大家能明白如何创建命名管道以及使用,上面我们使用的系统方法也是从网络上搜的,如果有什么错误还请见谅。

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

命名管道的打开规则:

如果当前打开操作是为读而打开 FIFO
O_NONBLOCK disable :阻塞直到有相应进程为写而打开该 FIFO
O_NONBLOCK enable :立刻返回成功
如果当前打开操作是为写而打开 FIFO
O_NONBLOCK disable :阻塞直到有相应进程为读而打开该 FIFO
O_NONBLOCK enable :立刻返回失败,错误码为 ENXIO

总结

命名管道可用于同一主机上的任意进程间通信,并且管道通信的本质是通过内核中一块缓冲区(内存)时间数据传输,而命名管道的管道文件只是一个标识符,用于让多个进程能够访问同一块缓冲区,并且管道是半双工通信,是可以选择方向的单向通信。命名管道和匿名有一个相同点,就是他们的本质都是内核中的一块缓冲区。同时补充一点,管道的生命周期是随进程的,本质是内核中的缓冲区,命名管道文件只是标识,用于让多个进程找到同一块缓冲区,删除后,之前已经打开管道的进程依然可以通信。文章来源地址https://www.toymoban.com/news/detail-434444.html

到了这里,关于【Linux】单机版QQ之管道中的命名管道的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 安装配置 zookeeper(单机版)

    目录 一 准备并解压安装包 二 修改zoo.cfg文件 三 创建相应两个目录 四 创建文件myid  五 修改环境变量 六 启动 zookeeper         这里提供了网盘资源  http://链接: https://pan.baidu.com/s/1BybwSQ_tQUL23OI6AWxwFw?pwd=d4cf         提取码: d4cf         这里的安装包是放在/opt/install 目

    2024年02月08日
    浏览(59)
  • Elasticsearch单机版本安装

    OS: CentOS Linux release 7.9.2009 (Core) 机器: 10.28.19.107 ES、Kibana安装版本: 7.15.2 Elasticsearch:https://www.elastic.co/cn/downloads/past-releases#elasticsearch Kibana: https://www.elastic.co/cn/downloads/past-releases#kibana 提前下载好 elasticsearch-7.15.2-linux-x86_64.tar.gz 、 kibana-7.15.2-linux-x86_64.tar.gz ,上传至/opt目录下。

    2023年04月14日
    浏览(52)
  • zookeeper单机版的搭建

    1.解压压缩包 [root@localhost export]# tar -zxvf zookeeper-3.7.0-bin.tar.gz 2.创建data文件夹 [root@localhost export]# cd apache-zookeeper-3.7.0-bin/ [root@localhost apache-zookeeper-3.7.0-bin]# ls bin  conf  docs  lib  LICENSE.txt  NOTICE.txt  README.md  README_packaging.md [root@localhost apache-zookeeper-3.7.0-bin]# pwd /root/export/apache-

    2024年02月05日
    浏览(45)
  • 杂记 | 在Linux上使用Docker-compose安装单机版Milvus向量数据库并配置访问控制和可视化面板(Attu)

    Milvus是一款开源的向量数据库,它专为AI应用设计,用于管理和检索海量的特征向量。Milvus的优势主要包括: 高效的向量检索性能 :Milvus采用了多种先进的索引算法,如IVF, HNSW, ANNOY等,能够在大规模数据集上实现高效的近似最近邻搜索。 易于扩展和维护 :Milvus支持水平和垂

    2024年01月19日
    浏览(54)
  • HBase单机版安装详细步骤

    目录 一、安装HBase前置环境 1.jdk 2.hadoop 3.zookeeper 二、安装HBase步骤 (一)解压 (二)修改文件名 (三)修改配置文件 (四)配置HBase的环境变量 (五)启动HBase 1.启动hadoop 2.启动zookeeper 3.启动hbase 4.jps出现HMaster和HRegionServer 5.HBase的WebUI (六)HBase的逻辑结构: (七)HBase基本命令  1.进入HBase

    2024年02月07日
    浏览(61)
  • Nacos单机版安装启动流程

    安装地址:https://github.com/alibaba/nacos/ 1、选择自己需要的版本  2、选择自己的环境下在对应的压缩包  3、下载后放到自己的文件目录中解压 4、window环境修改startup.cmd文件,改为单机部署后,就可以直接点击cmd文件直接启动了 mac通过终端进入cd ~/nacos/bin 目录下,通过命令 

    2024年02月11日
    浏览(58)
  • 【大数据】安装 Zookeeper 单机版

    下面安装 Zookeeper,由于它是 Apache 的一个顶级项目,所以域名是 zookeeper.apache.org ,所有 Apache 的顶级项目的官网都是以项目名 .apache.org 来命名的。 点击 Download 即可下载,这里我们选择的版本是 3.5.10 ,下载之后扔到服务器上。由于 Zookeeper 是基于 Java 语言编写的,所以还需要

    2024年02月03日
    浏览(49)
  • docker 安装zookeeper单机版

    1. 安装版本3.5.7 ,  也可以自己去官网找到自己需要的版本复制命令即可    https://hub.docker.com/_/zookeeper/tags   2. 创建映射文件夹 :        3. docker命令创建容器 :     4.centos 打开防火墙2181端口,如果是云服务器的话,阿里云控制台打开云服务器2181端口就可以了。 5. 下载客

    2024年02月13日
    浏览(51)
  • milvus实战 | docker部署单机版

    单机版部署总体而言是比较简单的,但是本着鸡过拔毛,码过留痕的当下人生信条,还是即时记录下。部署过程中有些小的细节也是可以拿捏下,希望可以给有缘人一缕顺风 本文主要三部分: milvus部署 milvus可视化工具attu部署 移植到内网部署 需要有一个能连互联网的linux环

    2024年02月06日
    浏览(51)
  • 【VictoriaMetrics】VictoriaMetrics单机版数据删除

    在使用vm的过程中,我们会遇到需要删除不必要的数据,那vm是如何操作数据删除的呢? VictoriaMetrics通过发送HTTP请求到http://victoriametrics-addr:8428/api/v1/admin/tsdb/delete_series?match=timeseries_selector_for_delete 其中timeseries_selector_for_delete可以包含任何用于删除指标的时间序列选择器,只支

    2024年02月08日
    浏览(42)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包