Linux FIFO命名管道短间隔发消息时相邻内容合并问题咨询

核心原因 #

FIFO（命名管道）属于字节流类型的IPC机制，内核层面不会维护任何消息边界，所有写入的数据都会被当做连续的字节流存放在内核缓冲区中：

• 发送间隔较小时，两次write写入的1000字节和2000字节会连续存放在FIFO的内核缓冲区中，读端调用read时会一次性读取缓冲区中所有可读内容（最多不超过传入的缓冲区大小），就会出现两次消息合并读出的情况。
• 你将发送间隔调整到50ms后正常，本质是靠时间差让第一次写入的内容在读端被及时读取走，缓冲区清空后第二次写入的内容才进入，这种靠时间差拆分消息的方式本身不可靠，只要读端调度出现轻微延迟，依然会触发合并问题。

代码问题说明 #

你提供的读端代码存在观测逻辑错误：read的返回值才是实际读到的字节数，你当前打印的sizeof(buf)是固定值500，完全无法反映实际接收的字节数，修正后的读端打印逻辑如下：

while(1) {
    ssize_t recv_len = read(fd, buf, sizeof(buf));
    if (recv_len > 0) {
        printf("Received buffer: %zd (bytes)\n", recv_len);
    }
}

解决方案 #

要在字节流上实现可靠的消息拆分，有三种常用实现方案：

• 固定长度消息：所有消息都使用统一的长度，读端每次固定读取该长度即可拆分消息
• 自定义消息头：在每个消息头部添加固定长度的字段，标记后续消息体的长度，读端先读取固定长度的头，再按照头中标记的长度读取对应长度的消息体
• 特殊分隔符：约定消息之间使用不会出现在消息内容中的特殊字符作为分隔，读端读到分隔符即判定一个消息结束

注意：POSIX标准中规定小于等于PIPE_BUF（Linux下默认4096字节）的写入是原子的，该特性仅保证多进程同时写入时单个write的内容不会被其他进程的写入穿插，依然不会维护消息边界，不要将原子写入和消息边界特性混淆。

内容的提问来源于stack exchange，提问作者Triho