如何阻止Socket/ServerSocket将两条消息合并为单个事件？

核心结论：无法完全禁用TCP的这种合并行为 #

你看到的现象是TCP粘包，这是TCP协议的本质特性——它是面向字节流的传输协议，本身不区分“消息边界”。Dart的Socket.add()只是把数据写入TCP发送缓冲区，底层操作系统会根据网络状况、缓冲区大小等因素决定何时发送数据，可能合并多次写入的内容，也可能拆分单次写入的内容。

关于SocketOption.tcpNoDelay的作用 #

tcpNoDelay禁用的是Nagle算法（该算法会合并小数据包以减少网络开销），它能降低数据发送的延迟，但无法保证每次add()的内容都会作为独立数据包发送。操作系统的TCP栈仍可能根据自身策略合并数据，比如当缓冲区未满时，或者后续数据很快到来时。

正确的解决方案：在应用层定义消息边界 #

既然TCP本身不提供消息边界，必须在应用层实现消息的拆分与重组，常用方案有三种：

1. 长度前缀法（最可靠）

在每个消息前添加固定长度的前缀（比如4字节），表示后续消息的字节数。服务端先读取长度前缀，再读取对应长度的字节作为完整消息。

客户端代码示例：

void sendFramedMessage(Socket socket, List<int> message) {
  // 将消息长度转换为4字节大端序
  final lengthBytes = ByteData(4)..setUint32(0, message.length, Endian.big);
  socket.add(lengthBytes.buffer.asUint8List());
  socket.add(message);
}

// 使用方式
sendFramedMessage(clientSocket, [1,2,3]);
sendFramedMessage(clientSocket, [4,5,6]);

服务端代码示例：

void handleSocket(Socket socket) {
  final buffer = <int>[];
  
  socket.listen((data) {
    buffer.addAll(data);
    
    // 循环解析完整的消息
    while (buffer.length >= 4) {
      // 读取长度前缀
      final lengthBytes = buffer.sublist(0, 4);
      final messageLength = ByteData.sublistView(lengthBytes).getUint32(0, Endian.big);
      
      // 检查是否有足够的字节组成完整消息
      if (buffer.length >= 4 + messageLength) {
        final message = buffer.sublist(4, 4 + messageLength);
        print(message); // 会分别输出 [1,2,3] 和 [4,5,6]
        buffer.removeRange(0, 4 + messageLength);
      } else {
        break; // 字节不足，等待下一次数据到来
      }
    }
  });
}

// 服务端监听时使用
serverSocket.listen(handleSocket);

2. 分隔符法

用特定的分隔符（比如换行符\n、特殊字符序列）分隔消息，服务端读取数据时按分隔符拆分。但要注意消息内容不能包含分隔符，否则会导致拆分错误。

3. 序列化协议法

使用成熟的序列化协议（如Protobuf、MsgPack），这些协议本身内置了消息边界的处理，能自动拆分和重组消息。

总结 #

无论如何配置Socket选项，都无法绕过TCP字节流的本质。只有在应用层实现消息边界的处理，才能确保服务端能准确拆分每次发送的消息。

内容的提问来源于stack exchange，提问作者Rémi Rousselet