使用mkfifo函数创建有名管道,并基于该管道实现两个进程间的通信
时间: 2024-09-26 07:07:13 浏览: 81
在Unix或Linux系统中,使用`mkfifo`函数创建的是名为管道,即`named pipe`或`FIFO (First In First Out)`。它是半双工的,意味着只能在一个方向上传输数据。下面是一个简单的C语言示例,展示了如何创建一个有名管道并在两个进程中进行通信:
首先,我们需要创建管道文件:
```bash
mkdir -p /path/to/pipes
mkfifo /path/to/pipes/my_pipe
```
然后,在一个进程(例如`producer`)中:
```c
#include <stdio.h>
#include <unistd.h>
#include <fcntl.h>
int main(int argc, char *argv[]) {
if (argc != 2) {
printf("Usage: producer <message>\n");
return 1;
}
const char *msg = argv[1];
int fd = open("/path/to/pipes/my_pipe", O_WRONLY); // 写模式打开
if (fd == -1) {
perror("Failed to open the named pipe");
return 1;
}
write(fd, msg, strlen(msg) + 1); // 发送消息到管道
close(fd);
printf("Producer sent message '%s'\n", msg);
return 0;
}
```
接着,在另一个进程(例如`consumer`)中:
```c
#include <stdio.h>
#include <unistd.h>
#include <fcntl.h>
int main(int argc, char *argv[]) {
if (argc != 1) {
printf("Usage: consumer\n");
return 1;
}
int fd = open("/path/to/pipes/my_pipe", O_RDONLY); // 读模式打开
if (fd == -1) {
perror("Failed to open the named pipe");
return 1;
}
char buffer[100]; // 预设接收缓冲区大小
read(fd, buffer, sizeof(buffer)); // 从管道接收数据
buffer[strlen(buffer) - 1] = '\0'; // 删除换行符
printf("Consumer received message '%s'\n", buffer);
close(fd);
return 0;
}
```
当你运行这两个程序时,一个进程(如`producer`)可以向`my_pipe`发送一条消息,另一个进程(如`consumer`)会接收到并显示出来。
阅读全文