Java基于TCP Socket分开发送独立数据包的实现方法

TCP是面向字节流的协议，协议层面没有“数据包”的边界概念，只会保证发送的字节按序、不丢失到达接收端，不会把多次调用write写入的内容做逻辑拆分。操作系统默认开启的Nagle算法会主动攒集发送缓冲区里的小数据，合并成更少的TCP段传输，进一步导致多次write的内容被合并成一次接收。
不要尝试靠flush()、开启TCP_NODELAY、发送后sleep这类偏方解决问题：这些操作只能降低粘包出现的概率，遇到网络拥塞、操作系统缓存调度、中间路由转发合并包的情况，依然会出现粘包或者拆包，根本无法保证每个字符串单独触发接收事件。

要实现每个字符串对应一次独立接收事件，必须在应用层自行定义消息边界，最通用、性能最好的方案是长度前缀标记法：发送每个消息前，先固定长度的字节标记当前消息的总长度，接收端先读取长度值，再严格读取对应长度的字节内容，每读完一组就判定为一个完整消息，触发一次监听事件，完全不受TCP底层分段逻辑影响。

修正后的发送端代码 #

import java.io.DataOutputStream;
import java.net.Socket;
import java.nio.charset.StandardCharsets;

// 发送逻辑
try {
    DataOutputStream out = new DataOutputStream(socket.getOutputStream());
    String[] array = new String[]{"stack", "over", "flow", "coding"};
    for (String item : array) {
        byte[] itemBytes = item.getBytes(StandardCharsets.UTF_8);
        // 先写入4字节int类型的消息长度
        out.writeInt(itemBytes.length);
        // 写入实际消息内容
        out.write(itemBytes);
        out.flush();
    }
} catch (IOException e) {
    throw new RuntimeException(e);
}

接收端对应实现逻辑 #

import java.io.DataInputStream;
import java.net.Socket;
import java.nio.charset.StandardCharsets;

// 接收逻辑
try {
    DataInputStream in = new DataInputStream(socket.getInputStream());
    while (true) {
        // 先读取4字节的消息长度
        int msgLength = in.readInt();
        byte[] msgBuffer = new byte[msgLength];
        // readFully会保证读满指定长度的字节，自动处理TCP拆包场景
        in.readFully(msgBuffer);
        String message = new String(msgBuffer, StandardCharsets.UTF_8);
        // 此处触发你的单条消息监听逻辑
        System.out.println("Incoming Transmission => " + message);
    }
} catch (IOException e) {
    // 处理连接断开、IO异常逻辑
}

如果传输内容全是不含换行符的文本，也可以用固定分隔符法：每个字符串末尾加统一的分隔符（比如\n），接收端逐字节读取，碰到分隔符就切分出一个完整消息。这种方式实现更简单，但需要处理内容本身包含分隔符的转义问题，性能比长度前缀法稍差，适合简单文本场景。

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