面试题：C语言匿名管道通信的错误处理与优化

可能出现的错误及错误处理

管道创建错误：
- 错误描述：调用pipe函数创建匿名管道时可能失败，例如系统资源不足等原因。
- 错误处理：pipe函数返回 -1 表示失败，可通过perror函数打印错误信息。
```
int pipefd[2];
if (pipe(pipefd) == -1) {
    perror("pipe creation failed");
    exit(EXIT_FAILURE);
}
```
文件描述符操作错误：
- 错误描述：在使用read、write等函数操作管道的文件描述符时，可能会出现错误，如读或写操作被信号中断，或者文件描述符无效等情况。
- 错误处理：对于read和write，它们返回 -1 表示错误，可通过errno判断具体错误类型。例如，如果是被信号中断（errno == EINTR），可以选择重新执行操作。
```
ssize_t bytes_read;
while ((bytes_read = read(pipefd[0], buffer, buffer_size)) == -1 && errno == EINTR);
if (bytes_read == -1) {
    perror("read from pipe failed");
    // 处理错误，例如关闭文件描述符并退出
    close(pipefd[0]);
    close(pipefd[1]);
    exit(EXIT_FAILURE);
}
```
父子进程创建错误：
- 错误描述：在使用fork创建子进程进行管道通信时，fork可能失败，比如系统进程表已满。
- 错误处理：fork返回 -1 表示失败，同样可通过perror打印错误信息并进行相应处理，如退出程序。
```
pid_t pid = fork();
if (pid == -1) {
    perror("fork failed");
    exit(EXIT_FAILURE);
}
```

大规模数据传输场景下的优化

缓冲区优化：

阐述：增大读写缓冲区大小可以减少系统调用次数。在大规模数据传输中，频繁的系统调用会带来较大开销。通过设置较大的缓冲区，每次读写的数据量增加，从而减少系统调用的频率。
代码示例：

#define BUFFER_SIZE 1024 * 1024 // 1MB缓冲区
char buffer[BUFFER_SIZE];
// 写操作
ssize_t total_written = 0;
ssize_t bytes_to_write = data_size;
while (bytes_to_write > 0) {
    ssize_t written = write(pipefd[1], buffer + total_written, 
                            (bytes_to_write < BUFFER_SIZE)? bytes_to_write : BUFFER_SIZE);
    if (written == -1) {
        if (errno == EINTR) continue;
        perror("write to pipe failed");
        close(pipefd[0]);
        close(pipefd[1]);
        exit(EXIT_FAILURE);
    }
    total_written += written;
    bytes_to_write -= written;
}

异步 I/O 优化：

阐述：使用异步 I/O 可以让进程在进行 I/O 操作时不阻塞，继续执行其他任务，提高整体效率。在 Linux 系统中，可以使用aio系列函数实现异步 I/O。
代码示例：

#include <aio.h>
// 初始化异步 I/O 控制块
struct aiocb aio;
memset(&aio, 0, sizeof(struct aiocb));
aio.aio_fildes = pipefd[1];
aio.aio_buf = buffer;
aio.aio_nbytes = data_size;
aio.aio_offset = 0;
// 发起异步写操作
if (aio_write(&aio) == -1) {
    perror("aio_write failed");
    close(pipefd[0]);
    close(pipefd[1]);
    exit(EXIT_FAILURE);
}
// 等待异步操作完成
while (aio_error(&aio) == EINPROGRESS);
ssize_t written = aio_return(&aio);
if (written == -1) {
    perror("aio operation failed");
    close(pipefd[0]);
    close(pipefd[1]);
    exit(EXIT_FAILURE);
}

多线程/多进程协作优化：

阐述：可以利用多线程或多进程来并行处理数据的读写操作。例如，使用多个子进程同时从管道读取数据，或者使用多线程在不同线程中进行读写，充分利用多核 CPU 的优势，提高数据传输效率。
多进程示例：

#define NUM_PROCESSES 4
pid_t pids[NUM_PROCESSES];
for (int i = 0; i < NUM_PROCESSES; i++) {
    pid_t pid = fork();
    if (pid == -1) {
        perror("fork failed");
        // 处理所有已创建进程的清理
        for (int j = 0; j < i; j++) {
            kill(pids[j], SIGTERM);
        }
        close(pipefd[0]);
        close(pipefd[1]);
        exit(EXIT_FAILURE);
    } else if (pid == 0) {
        // 子进程读操作
        ssize_t bytes_read;
        while ((bytes_read = read(pipefd[0], buffer, buffer_size)) > 0) {
            // 处理读取的数据
        }
        if (bytes_read == -1) {
            perror("read from pipe failed in child");
        }
        close(pipefd[0]);
        close(pipefd[1]);
        exit(EXIT_SUCCESS);
    } else {
        pids[i] = pid;
    }
}
// 父进程写操作
ssize_t total_written = 0;
ssize_t bytes_to_write = data_size;
while (bytes_to_write > 0) {
    ssize_t written = write(pipefd[1], buffer + total_written, 
                            (bytes_to_write < buffer_size)? bytes_to_write : buffer_size);
    if (written == -1) {
        if (errno == EINTR) continue;
        perror("write to pipe failed in parent");
        // 向所有子进程发送终止信号
        for (int i = 0; i < NUM_PROCESSES; i++) {
            kill(pids[i], SIGTERM);
        }
        close(pipefd[0]);
        close(pipefd[1]);
        exit(EXIT_FAILURE);
    }
    total_written += written;
    bytes_to_write -= written;
}
// 等待所有子进程结束
for (int i = 0; i < NUM_PROCESSES; i++) {
    wait(NULL);
}
close(pipefd[0]);
close(pipefd[1]);

星途面试题库

面试题：C语言匿名管道通信的错误处理与优化

知识考点

面试题答案

可能出现的错误及错误处理

大规模数据传输场景下的优化