0

我正在研究 linux fifos，我制作了两个通过 fifo 进行通信的小型 C 程序。第一个充当服务器，它接收模式并使用该模式执行命令。第二个就像一个客户端，它发送模式并接收结果。我希望服务器能够服务多个请求，不一定同时，但奇怪的是，在第一个客户端被服务后，它就停止了，尽管我在那里设置了一个无限循环。

服务器.c

#include <sys/types.h>
#include <sys/stat.h>
#include <string.h>
#include <signal.h>
#include <fcntl.h>


void siginthandler(int i){
    remove("./fifo1");
    remove("./fifo2");
    printf("Got SIGINT signal\n");
    exit(EXIT_SUCCESS);
}


int main(int argc, char *argv[]){
    signal(SIGINT, siginthandler);
    int f = mkfifo("./fifo1", 0600);
    if (f == -1){
        perror("Unable to create fifo1\n");
        exit(EXIT_FAILURE);
    }
    f = mkfifo("./fifo2", 0600);
    if (f == -1){
        perror("Unable to create fifo2\n");
        exit(EXIT_FAILURE);
    }
    int fd1 = open("./fifo1", O_RDONLY);
    int fd2 = open("./fifo2", O_WRONLY);
    if (fd1 == -1 || fd2 == -1){
        perror("Unable to open fifos\n");
        exit(EXIT_FAILURE);
    }
    while (1){
        char buf[50];
        char pattern[50];
        read(fd1, pattern, 50);
        char command[80] = "ps -e | grep ";
        strcat(command, pattern);
        FILE *result = popen(command, "r");
        while (fgets(buf, 50, result)){
            write(fd2, buf, 50);
            //printf("%s", buf);
        }
        memset((void *) buf, 0, 50);
        write(fd2, buf, 50);
        pclose(result);
    }
    remove("./fifo1");
    remove("./fifo2");
    return 0;
}

客户端.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
#include <stdlib.h>

int main(int argc, char *argv[]){
    int fd1 = open("./fifo1", O_WRONLY);
    int fd2 = open("./fifo2", O_RDONLY);
    if ((fd1 == -1) || (fd2 == -1)){
        perror("Unable to find fifos");
        exit(EXIT_FAILURE);
    }
    char input[50];
    printf("Give pattern: ");
    scanf("%s", input);
    write(fd1, input, 50);
    char buf[50];
    while (read(fd2, buf, 50) == 50){
        if (buf[0] == 0){
            break;
        }
        printf("%s", buf);
    }
    return 0;
}
4

2 回答 2

3

如果没有阅读器，写入管道会给你一个 SIGPIPE；您需要让服务器打开管道进行读取，因此有一个阅读器（它不读取任何内容，但它存在）。

于 2013-07-21T20:19:05.553 回答
3

当第一个客户端关闭 FIFO 时，服务器会在 FIFO 上获得 EOF，并且永远不会继续获得新数据。服务器必须为下一个客户端重新打开 FIFO。如果有多个同时打开 FIFO 的客户端，则在最后一个客户端断开连接之前，服务器不会获得 EOF（只要有一个写入器，读取器 - 服务器 - 就可以了）。

这是预期的行为——或者，因为你没有预料到，所以应该是预期的行为。

当然，由于您的代码完全忽略了 from 的返回值read()，因此您不知道正在读取什么（如果有的话）。

编码：

memset((void *) buf, 0, 50);
write(fd2, buf, 50);

好奇；为什么要向客户端发送一个 50 0 字节的缓冲区？您可以完全关闭 FIFO 而无需发送它。

另请注意，在没有读取器的 FIFO 上写入会生成 SIGPIPE 信号——而您并没有处理这些信号。SIGPIPE 的默认操作是退出。

于 2013-07-21T20:19:31.337 回答