脚本 bash 写入 fifo 并从中读取 c 程序

Question

我有一个写入 fifo 的 bash 脚本。我有一个从同一个 fifo 读取的 C 程序。

我确信脚本可以正常工作，因为我尝试使用另一个脚本从 fifo 读取数据并且一切正常。但是有些东西在 C 程序中不起作用。当我运行我的脚本和运行 C 程序时，就像他们在等待对方一样。这是代码。

脚本是（作者）：

#!/bin/bash

fifo_name="myfifo";

# Se non esiste, crea la fifo;
[ -p $fifo_name ] || mkfifo $fifo_name;

echo "3" > $fifo_name;
echo "6" > $fifo_name;

这里是 c 程序（读者）：

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

#define MAX_BUF 1024

int main(int argc, char *argv[])
{
    int fd, i;
    char * myfifo = argv[1];
    char buf[MAX_BUF];

    fd = open(myfifo, O_RDONLY);

    while (1) {
        if(read(fd, buf, MAX_BUF) > 0)
        {
            printf("Received: %s\n", buf);      
        }
    }

    close(fd);

    return 0;
}

我哪里错了？

谢谢。

Answer 1

只要您执行以下操作，它就可以正常工作。

• 确保在运行 C 程序时，为 FIFO 文件提供具有正确路径名的参数。

• 首先运行 shell 程序，因为它会在 FIFO 文件不存在时创建它。

如果 FIFO 不存在，您可以通过退出 C 程序来缓解第二个问题，例如：

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

#define MAX_BUF 1024

int main(int argc, char *argv[])
{
    int fd, i;
    char * myfifo = argv[1];
    char buf[MAX_BUF];

    fd = open(myfifo, O_RDONLY);

    if (fd == -1) {
        perror("opening fifo");
        return 1;
    }
    *buf = '0';
    while (strchr (buf,'x') ==NULL) {
        if((i = read(fd, buf, MAX_BUF)) > 0)
        {
            buf[i] = '\0';
            printf("Received: [%s]\n", buf);
        }
    }

    close(fd);

    return 0;
}

您会注意到我还允许 shell 脚本在通过 x 发送时终止它，并且我还确保缓冲区已正确终止以将其打印为字符串。

对 shell 脚本的（次要）更改是：

#!/bin/bash

fifo_name="myfifo";

# Se non esiste, crea la fifo;
[ -p $fifo_name ] || mkfifo $fifo_name;

echo "3" > $fifo_name;
echo "6" > $fifo_name;
echo "x" > $fifo_name;

然后我在C端看到的输出是：

Received: [3
]
Received: [6
x
]

你会发现它并不总是你所期望的。 read 调用可能会一次接收多个发送，因为顶部没有真正的协议分层。如果您想避免这种情况，您需要添加自己的协议。