当前位置：首页 > 文章列表 > 文章 > linux > Linux命名管道：进程通信与实时交互技巧

Linux命名管道：进程通信与实时交互技巧

2025-07-04 23:00:52 0浏览收藏

珍惜时间，勤奋学习！今天给大家带来《Linux命名管道：进程控制与实时交互技巧》，正文内容主要涉及到等等，如果你正在学习文章，或者是对文章有疑问，欢迎大家关注我！后面我会持续更新相关内容的，希望都能帮到正在学习的大家！

1. 进程池

在匿名管道学习后，我们已经实现了一个基于匿名管道的简单进程控制，现在我们学习了命名管道来试试用命名管道来实现进程控制吧。正在匿名管道时，我们已经实现了进程的控制，命名管道只要在其基础上进行一些修改就可以了。

2. 进程池的功能2.1 可被执行的任务

进程池是为了实现对进程的控制，通过父进程对众多子进程的管理，实现高效的进程执行任务。我们可以先虚构一些任务出来，后续的子进程就来执行这些任务：

打印日志将数据插入数据库请求网络可以用这些任务可以写成单独的函数，然后用一个类来管理这些任务。类的成员变量：利用哈希表来存储这些任务类的功能有：展示可执行的任务执行任务具体的代码如下：代码语言：javascript代码运行次数：0运行复制

typedef void(*task_t)(void);/*函数指针*///任务集void printLog(){    std::cout st_;public:    Task()    {        st_ = {{"打印日志",printLog},{"插入数据",MySQLInsert},{"请求网络",NetRequest}};    }    void showTask()/*展示任务*/    {        std::cout

2.2 进程控制(重点)

进程控制是进程池的重点、核心。我们实现进程池也就是为了执行对进程的控制。如何控制进程呢？

创建进程展示空闲子进程子进程等待任务的发配父进程为子进程发配任务杀死/回收进程2.2.1 子进程类

为了实现这些功能，同样我们用一个类来封装它们。除此之外，还记得我们在实现基于匿名管道的进程控制吗？我们还需要一个类来描述子进程。因为我们需要知道父进程的每个写端的文件描述符和哪个子进程通过命名管道建立起来联系。所以子进程类具有的属性就有了：

子进程的PID写端的文件描述符编号名字其中第3和第4个属性是为了方便父进程管理而加入的，后续进程控制类需要用数组将各个子进程存储起来。子进程类代码如下：代码语言：javascript代码运行次数：0运行复制

class SubProcesses{private:    pid_t id_;    int processNum_;    int wfd_;    std::string name_;    static int cnt_;public:    SubProcesses(pid_t id,int wfd)    :id_(id),processNum_(cnt_++),wfd_(wfd)    {        char buff[SIZE]{0};        snprintf(buff,SIZE,"Process %d | pid:wfd [%d:%d]",processNum_,id_,wfd_);        name_ = buff;    }    pid_t getId()    {        return id_;    }    std::string getName()    {        return name_;    }    int getWfd()    {        return wfd_;    }};int SubProcesses::cnt_ = 1;

2.2 进程控制

那么进程类会具有什么属性呢？我们需要将创建出子进程进行管理可以用一个vecotr来对其进行管理，还需要知道我们需要创建的子进程数量，因为是基于命名管道的进程控制，为此我们还必须对个个进程管道进行管理，同样用vector将它们装起来。除此之外在来个权限掩码也可以。如此进程控制类的成员变量：

管理着子进程的vector类。管理着命名管道的vector类。记录需要创建的子进程数目。权限掩码。下面开始实现函数：2.2.2 创建子进程

创建子进程，创建子进程同样还是用到fork函数，不同的是不在需要pipe函数来创建管道了。现在已经变成了mkfifo函数。和匿名管道那一样，我们要记得关闭子进程的写端，尽管子进程并没有主动打开写端，但是因为子进程继承父进程的缘故，依然会吧父进程的写端给继承过了的。一点定是要关闭的。

代码语言：javascript代码运行次数：0运行复制

void createProcess(){std::vector vfd;/*关闭子进程的写端*/for(int i = 1;i

2.2.3 子进程等待任务

死循环等待任务，当写端关闭再退出。

代码语言：javascript代码运行次数：0运行复制

void waitTask(int rfd)/*子进程等待任务委派*/{while(true){char buff[SIZE];int n = read(rfd,buff,SIZE);if(n == -1){perror("read");exit(1);}else if(n>0){Task().curTask((std::string)buff);}else if(n == 0){/*证明写端没有写消息了*/std::cout

2.2.4 展示空闲进程代码语言：javascript代码运行次数：0运行复制

/*展示可选进程*/    void showProcess()    {        std::cout

2.2.5 分配任务给子进程

该函数的功能就分配任务，由用户自己选择子进程来执行任务。

代码语言：javascript代码运行次数：0运行复制

/*下达任务给子进程*/void sendTask(){std::cout>input;   }while(input=subProcessNum_);Task().showTask();std::string taskName;std::cout>taskName;if(taskName == "exit"){break;}std::cout "

2.2.6 回收子进程

回收子进程的同时也不能忘记关闭文件描述符和关闭命名管道

代码语言：javascript代码运行次数：0运行复制

/*关闭写端、删除文件、等待子进程退出*/    void waitProcess()    {        for(int i = 0;i

代码代码语言：javascript代码运行次数：0运行复制

#include #include #include #include #include #include #include #include #include #include /** * 该文件为进程池的公共代码段 * 进程池为利用命名管道实现的，简称命名管道进程池 * 代码的主要功能包括：创建进程，控制进程实现委派给它的任务，等待进程 */#define SIZE 1024typedef void(*task_t)(void);//任务集void printLog(){    std::cout st_;public:    Task()    {        st_ = {{"打印日志",printLog},{"插入数据",MySQLInsert},{"请求网络",NetRequest}};    }    void showTask()/*展示任务*/    {        std::cout subProcess_;/*子进程信息表*/    std::vector<:string> namePipe_;/*命名管道信息表*/    int subProcessNum_ ;/*需要创建的子进程数目*/    mode_t mode_ ;public:    ProcessCtrl(int subProcessNum = 3,mode_t mode = 0666)    :subProcessNum_(subProcessNum),mode_(mode)    {createProcess();/*开始创建子进程*/}    void createProcess()    {        std::vector vfd;/*关闭子进程的写端*/        for(int i = 1;i0)            {                Task().curTask((std::string)buff);            }            else if(n == 0)            {                /*证明写端没有写消息了*/                std::cout>input;               }while(input=subProcessNum_);            Task().showTask();            std::string taskName;            std::cout>taskName;            if(taskName == "exit")            {                break;            }            std::cout "

运行结果

3. 实时读取字符

我们还可以通过命名管道来实现字符的实时读取，还挺有意思的，为了实现这个功能，我们不仅需要会使用命名管道，还有如system()和fflush()函数。

3.1 公共区域代码语言：javascript代码运行次数：0运行复制

#include #include #include #include #include #include #include #include #define SIZE 1024//命名管道const char* namePipe = "./fifo";//权限掩码const mode_t mode = 0666;

3.2 客户端

客户端用来向服务端发送消息

代码语言：javascript代码运行次数：0运行复制

/** * 该文件为客户端，用来实时向服务端发送字符 */#include "common.hpp"int main(){    /**主要步骤:     * 1.创建命名管道     * 2.打开命名管道     * 3.写入字符到命名管道当中     * 4.关闭命名管道        * */    int mk = mkfifo(namePipe,mode);    if(mk == -1)    {        perror("mkfifo");        exit(1);    }    int fd = open(namePipe,O_WRONLY);//写方式打开    if(fd == -1)    {        perror("open");        exit(1);    }    std::cout=0);        (void)n;/*消除未使用警告*/    }    close(fd);    unlink(namePipe);    return 0;}

3.3 服务端代码语言：javascript代码运行次数：0运行复制

/** * 该文件为服务端，用来实时接受客户端输出的字符 */#include "common.hpp"int main(){    /**     * 实时读取客户端发来的字符     * 主要功能：     *      * 1.已读方式打开命名管道文件     * 2.利用fflush实时刷新缓冲区的字符     * 3.关闭文件描述符     */    int fd = open(namePipe,O_RDONLY);    assert(fd!=-1);    while(true)    {        char buff[SIZE]{0};        ssize_t n = read(fd,buff,SIZE-1);        if(n>0)        {            buff[n] = 0;            printf("%c",buff[0]);            fflush(stdout);        }        else if(n == 0)        {            std::cout

效果图

屏幕录制 2024-11-20 202850

往期Linux文章：Linux专栏

4.总结

通过命名管道实现了这两个简单的小程序，其实这些小程序的本质都是一样的：创建命名管道 -> 打开命名管道 -> 通信 -> 关闭命名管道，掌握其中一个即可融会贯通！感谢阅读。

好了，本文到此结束，带大家了解了《Linux命名管道：进程通信与实时交互技巧》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多文章知识！

进程池