0

所以我正在尝试使用 mkfifo() 在 C 中实现一个基本的 FIFO 管道。到目前为止，这是我的代码类：

主.c：

int main(int argc, char *argv[]) {
char *path = "/tmp/fifo";
pid_t pid;

setlinebuf(stdout);
unlink(path);
mkfifo(path, 0600);

pid = fork();
if (pid == 0) {
    client(path);
} else {
    server(path);
}

return(0);
}

客户端.c：

void client(char *path) {

char *input;
input = (char *)malloc(200 * sizeof(char));

read(STDIN_FILENO, input, 200);

struct Message message;
message = protocol(input); //protocol simply takes an input string and formats it
char number = message.server;
char* string;
string = message.string;

int fd;

fd = open(path, O_WRONLY);
write(fd, string, sizeof(string));
printf("Client send: %s\n", string);
close(fd);


return;
}

服务器.c：

void server(char *path) {
int fd;
char *input;
input = (char *)malloc(200 * sizeof(char));

fd = open(path, O_RDONLY);
read(fd, input, sizeof(input));
printf("Server receive: %s\n", input);
close(fd);

return;
}

现在管道正在工作，但由于某种原因，服务器只接收到部分消息。例如，如果我们从协议中获得以下字符串：“HELLO WORLD”，我们将获得以下输出：

Server receive: HELLO WO
Client send: HELLO WORLD

服务器应该收到整个消息，但事实并非如此。我究竟做错了什么？感谢您的任何帮助！

4

1 回答 1

1

open我注意到您已经省略了对andread和的返回值的通常必不可少的检查write。如果你有，你可能已经注意到这一行的错误

write(fd, string, sizeof(string));

因为string是一个指针，所以你发送的是 8 个字节（指针的大小）。您应该使用strlen(string)or that +1，具体取决于是否需要发送终止符。

write(fd, string, strlen(string));

您在最近的不明智编辑中重复了这个错误：

read(fd, input, sizeof(input));

您最好坚持使用原始文件#define并将其用于缓冲区分配和读取请求大小。

于 2016-06-02T18:06:00.047 回答