Unix Domain Sockets收发消息丢失问题：原因与解决方法

核心原因 #

1. 流式套接字的部分读写特性未处理 #

Unix Domain Socket（SOCK_STREAM类型）属于字节流协议，不存在天然的消息边界：

• 服务端调用send()/write()时，返回值仅代表本次成功写入内核缓冲区的字节数，若缓冲区已满，会出现部分写入的情况。如果代码未循环发送剩余数据，会导致消息不完整或丢失。
• 客户端调用recv()/read()时，一次调用可能只读取到部分消息，或多条消息被内核合并（粘包）。若客户端假设一次调用能完整读取单条消息，会导致后续消息解析混乱，表现为“丢消息”。

2. 连接关闭时机不合理 #

若服务端发送完所有消息后直接关闭套接字，客户端可能在收到部分数据后触发EOF信号，提前终止读取流程，此时内核缓冲区中仍有未读取的消息，最终导致漏收。

3. 错误返回值未处理 #

代码中若忽略send()/recv()等系统调用的错误返回（如返回-1的情况），会掩盖实际发送/接收失败的问题，表现为消息丢失。

解决方案 #

1. 封装可靠的发送/接收函数 #

实现循环发送/接收逻辑，确保数据完整传输：

可靠发送函数

#include <errno.h>
#include <sys/socket.h>

ssize_t send_all(int sockfd, const void *buf, size_t len, int flags) {
    size_t total_sent = 0;
    const char *ptr = buf;
    while (total_sent < len) {
        ssize_t sent = send(sockfd, ptr + total_sent, len - total_sent, flags);
        if (sent == -1) {
            if (errno == EINTR) continue; // 被信号中断，继续发送
            return -1; // 其他错误，返回失败
        }
        total_sent += sent;
    }
    return total_sent;
}

可靠接收函数（基于固定消息长度）

如果每条消息长度固定（如"Hello X"为7字节），循环读取直到凑够指定长度：

ssize_t recv_all(int sockfd, void *buf, size_t len, int flags) {
    size_t total_recv = 0;
    char *ptr = buf;
    while (total_recv < len) {
        ssize_t recvd = recv(sockfd, ptr + total_recv, len - total_recv, flags);
        if (recvd == -1) {
            if (errno == EINTR) continue;
            return -1;
        } else if (recvd == 0) {
            return total_recv; // 连接关闭，返回已接收字节数
        }
        total_recv += recvd;
    }
    return total_recv;
}

如果消息长度不固定，可采用长度前缀法（每条消息前先发送4字节的长度值）或分隔符法（用换行符等特殊字符标记消息边界）来拆分数据。

2. 优化连接关闭逻辑 #

服务端发送完所有消息后，不要直接关闭套接字：

• 调用shutdown(sockfd, SHUT_WR)关闭写端，告知客户端无更多数据发送，客户端可继续读取直到EOF，确保所有数据被读完。
• 或等待客户端发送确认消息后再关闭连接。

3. 严格处理错误返回值 #

所有套接字相关系统调用（send()/recv()/bind()/connect()等）必须检查返回值，处理EINTR、EAGAIN等特殊错误，避免错误被掩盖。

4. 客户端读取逻辑调整 #

客户端需循环读取直到接收完预期的消息数量，而非收到EOF就终止：

int received_count = 0;
char msg_buf[16]; // 足够容纳"Hello X"
while (received_count < 5) {
    ssize_t n = recv_all(sockfd, msg_buf, 7, 0);
    if (n <= 0) {
        // 处理错误或连接关闭
        break;
    }
    msg_buf[n] = '\0';
    printf("%s\n", msg_buf);
    received_count++;
}

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