使用Linux命名管道(FIFO)实现无血缘关系进程间的通信

mkfifo my_pipe

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

int main() {
    const char *fifo_path = "/tmp/my_fifo";
    
    // 创建命名管道
    if (mkfifo(fifo_path, 0666) == -1) {
        perror("mkfifo");
        exit(EXIT_FAILURE);
    }
    
    printf("Named pipe created: %s\n", fifo_path);
    return 0;
}

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>

int main() {
    const char *fifo_path = "/tmp/my_fifo";
    const char *message = "Hello from writer process!";
    
    // 以只写方式打开命名管道
    int fd = open(fifo_path, O_WRONLY);
    if (fd == -1) {
        perror("open");
        exit(EXIT_FAILURE);
    }
    
    // 向命名管道写入数据
    write(fd, message, strlen(message));
    
    printf("Message sent: %s\n", message);
    
    // 关闭命名管道
    close(fd);
    
    return 0;
}

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>

#define BUFFER_SIZE 256

int main() {
    const char *fifo_path = "/tmp/my_fifo";
    char buffer[BUFFER_SIZE];
    
    // 以只读方式打开命名管道
    int fd = open(fifo_path, O_RDONLY);
    if (fd == -1) {
        perror("open");
        exit(EXIT_FAILURE);
    }
    
    // 从命名管道读取数据
    int bytes_read = read(fd, buffer, BUFFER_SIZE - 1);
    if (bytes_read == -1) {
        perror("read");
        exit(EXIT_FAILURE);
    }
    
    buffer[bytes_read] = '\0'; // 确保字符串以null结尾
    printf("Message received: %s\n", buffer);
    
    // 关闭命名管道
    close(fd);
    
    return 0;
}

# 创建命名管道
mkfifo /tmp/my_fifo

# 编写进程
gcc writer.c -o writer
./writer &

# 读进程
gcc reader.c -o reader
./reader

// 非阻塞方式打开命名管道
int fd = open(fifo_path, O_RDONLY | O_NONBLOCK);

#include <sys/select.h>
#include <poll.h>

// 使用select监控命名管道
fd_set read_fds;
struct timeval timeout;

FD_ZERO(&read_fds);
FD_SET(fd, &read_fds);

timeout.tv_sec = 5; // 5秒超时
timeout.tv_usec = 0;

int ret = select(fd + 1, &read_fds, NULL, NULL, &timeout);
if (ret > 0) {
    if (FD_ISSET(fd, &read_fds)) {
        // 命名管道可读
        // 执行读取操作
    }
}

// 使用poll监控命名管道
struct pollfd fds;

fds.fd = fd;
fds.events = POLLIN; // 监控可读事件

int ret = poll(&fds, 1, 5000); // 5秒超时
if (ret > 0) {
    if (fds.revents & POLLIN) {
        // 命名管道可读
        // 执行读取操作
    }
}