Java ByteBuffer 读取不完整时怎样正确使用 flip 和 compact

Java NIO 的分段读取不能把一次 read 当成一条完整消息。正确做法是：写入完成后用 flip() 把 position/limit 切到读取模式；解析到不完整消息时，把 position 恢复到这条消息的起点；本轮结束调用 compact()，让未消费字节回到缓冲区开头，下一次读取接在它后面。只有已经消费完的数据才应该被覆盖，不能用 clear() 代替保留动作。

先把三个位置信息分清楚

ByteBuffer 同时承担读和写两个角色。接收数据前通常处于写入模式：position 指向下一个可写位置，limit 等于 capacity。调用 flip() 后，limit 被改成原来的 position，position 归零，于是 0 到 limit 之间就是本轮收到的数据。

例如容量为 1024，本轮读到 37 字节，flip() 后就是 position=0、limit=37；如果解析只消费了 12 字节，剩下 25 字节仍是有效输入。

解析不完整消息时保留整条边界

假设协议头部包含 4 字节长度，后面跟消息体。解析器不能先把长度字段取走，发现消息体不够后再等待，因为这样下一轮已经失去当前帧的起点。更稳妥的方式是先保存 frameStart，确认头部和完整消息都在当前可读范围内后再推进 position。

import java.nio.ByteBuffer;

// 读取一轮数据；返回 false 表示遇到 EOF，true 表示本轮可继续。
static boolean readAndParse(java.nio.channels.ReadableByteChannel channel,
                            ByteBuffer buffer) throws java.io.IOException {
    int n = channel.read(buffer); // 写入模式：新数据追加到 position
    if (n == -1) {
        return buffer.position() == 0; // 没有保留数据才算正常结束
    }

    buffer.flip(); // 将本轮写入范围切换成可读范围
    while (buffer.hasRemaining()) {
        int frameStart = buffer.position(); // 不完整时回到整帧起点
        if (buffer.remaining()  buffer.capacity() - Integer.BYTES) {
            throw new java.io.IOException("消息长度超出缓冲区边界");
        }
        if (buffer.remaining() 

这里的关键不是“读到多少就处理多少”，而是让解析器只提交完整帧。遇到半个头部或半个消息体时，恢复到 frameStart，随后 compact() 会把整段未消费内容搬到索引 0。

flip、compact 和 clear 的调用边界

一轮读取的顺序可以固定为“read → flip → parse → compact → read”。clear() 只适用于确认缓冲区中没有需要保留的数据；它会把 position 置零并把 limit 恢复为 capacity，但不会真的擦除字节。对半帧调用 clear，下一轮就无法补齐原消息。

如果本轮恰好消费完所有数据，解析结束时 position 等于 limit，compact() 会留下 0 个字节，下一次读取自然从索引 0 开始。如果只消费了部分数据，compact 后 position 就是剩余长度，不能再额外调用 flip 后直接继续写入，否则会把写入位置切回错误的范围。

生产环境的检查清单

• 每次成功写入后只 flip 一次；解析循环内部不要重复 flip。
• 协议长度必须有上限，防止异常输入让缓冲区永远等待或触发过大分配。
• read() 返回 0 时不要当作 EOF；非阻塞通道应回到选择器等待可读事件。
• 收到 -1 时先判断 compact 后是否还留有半帧，再决定记录截断并关闭连接。
• 只在完整帧提交后推进外层 position，异常路径要关闭通道并释放连接状态。

相关问题

为什么 flip 后不能直接继续 read？

flip 后是读取模式，read 会把数据写入 position 到 limit 的范围；要继续接收，必须先完成解析并 compact，恢复可写空间。

compact 会不会丢掉已经读过的字节？

会。它只复制 position 到 limit 的未消费区，已经消费的字节不会保留，这正是下一轮避免重复解析所需要的行为。

半帧一定要扩大 ByteBuffer 吗？

不一定。先设置协议最大帧长；未超过容量时等待下一轮并 compact，超过上限则拒绝消息或切换到专门的分片存储策略。