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

4. 实现无血缘关系进程间通信

4.1 写进程示例

下面是一个写进程的示例代码，它向命名管道写入数据：

#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;
}

4.2 读进程示例

下面是一个读进程的示例代码，它从命名管道读取数据：

#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;
}

4.3 运行示例

要运行这个示例，首先需要创建命名管道，然后分别编译和运行写进程和读进程。需要注意的是，读进程应该先于写进程启动，因为读进程在打开命名管道时会阻塞，直到有另一个进程以写方式打开同一个命名管道。

# 创建命名管道
mkfifo /tmp/my_fifo
# 编写进程
gcc writer.c -o writer
./writer
# 读进程
gcc reader.c -o reader
./reader

5. 命名管道的高级特性

5.1 非阻塞打开命名管道

默认情况下，以只读或只写方式打开命名管道会导致进程阻塞，直到有另一个进程以相反的方式打开同一个命名管道。为了避免阻塞，可以在打开命名管道时指定 O_NONBLOCK 标志：

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

5.2 使用 select 或 poll 监控命名管道

可以使用 select 或 poll 函数来监控命名管道的可读性或可写性，从而避免阻塞：

#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) {
        // 命名管道可读
        // 执行读取操作
    }
}

6. 命名管道的注意事项

1. 单向通信：命名管道是单向的，如果需要双向通信，需要创建两个命名管道。
2. 阻塞行为：默认情况下，打开命名管道会导致进程阻塞，直到有另一个进程以相反的方式打开同一个命名管道。
3. 数据完整性：写入命名管道的数据可能会被截断，特别是在写入大量数据时。因此，需要确保数据的完整性。
4. 错误处理：在使用命名管道时，需要正确处理各种错误情况，如管道不存在、权限不足等。
5. 资源清理：使用完命名管道后，应该关闭文件描述符，并在不需要时删除命名管道文件。

7. 实际应用场景

命名管道在实际开发中有多种应用场景，例如：

1. 日志收集系统：多个不同的应用程序可以将日志写入同一个命名管道，而日志收集进程则从该管道读取日志。
2. 服务间通信：在微服务架构中，可以使用命名管道作为轻量级的进程间通信机制。
3. 命令行工具：命令行工具可以使用命名管道接收来自其他程序的输入或发送输出到其他程序。
4. 测试框架：在测试过程中，可以使用命名管道模拟不同组件之间的交互。

8. 总结

本文介绍了 Linux 命名管道 (FIFO) 的基本概念、创建方法以及如何使用它来实现无血缘关系进程间的通信。通过示例代码，展示了如何创建命名管道、打开和关闭命名管道，以及如何使用命名管道进行进程间通信。此外，还介绍了命名管道的高级特性和注意事项。

命名管道是一种简单而有效的进程间通信机制，特别适用于不相关的进程之间的通信。通过合理使用命名管道，可以实现进程间的数据交换和同步，提高程序的灵活性和可扩展性。