管道损坏，FIFO 文件

Question

我正在尝试一个程序使用FIFO文件，但我得到破碎的管道作为输出。这是代码 -

#include<iostream>
#include<stdlib.h>
#include<fcntl.h>
#include<stdio.h>
#include<string.h>
#include<unistd.h>
#include<sys/stat.h>
#include<sys/types.h>
using namespace std;
int main(int argc,char *argv[])
{
int fd; //stores file descriptor returnd from open
char buf[256];
if(argc<2||argc>3)
{
    cout<<"Invalid Arguments";
    return 1;
}
mkfifo(argv[1],0777);
if(argc==3)
{   
    cout<<"Writern";
    if((fd=open(argv[1],O_WRONLY))==-1)
    {
        perror("open");
        return 1;
    }
    write(fd,argv[2],strlen(argv[2]));
    sleep(10);
}
else
{   cout<<"Readern";
    if((fd=open(argv[1],O_RDONLY|O_NONBLOCK))==-1)
    {       
        perror("open");
        return 1;
    }
    read(fd,&buf,sizeof(buf));
    cout<<buf;
}
 close(fd);
 return 1;
 }

输出：Fifo下面是文件的名称，Hello是内容。

./a.out fifo hello &
Writer
./a.out fifo
Reader
[1]+  Broken pipe  

我应该得到"你好"作为输出。谁能帮忙？

Answer 1

你的写作发生在你开始阅读之前。当你写入管道并且它没有阅读器时，你会得到SIGPIPE。

在此特定设计中，您需要使用重试逻辑处理 SIGPIPE。

Answer 2

你得到的错误是EPIPE，如果你阅读write手册，你会看到你得到EPIPE

fd连接到读取端关闭的管道或插座。

您收到此错误是因为您在非阻塞模式下打开管道的读取端，这意味着read调用不会阻塞并等待接收数据，而是当read调用立即返回时，关闭管道并退出进程。

这意味着当你运行编写器时，没有人等待你写入的数据，你得到错误。

您需要以相反的顺序运行读取和编写器：首先是写入器，以便写入管道，然后读取器从管道读取数据。