Netty TCP Server-ByteBuff大小在解码消息时停留在1024的Project Reactor

Question

public class StringDecoder implements Function<Buffer, String> {

    // Buffer is limited to 1024 but the message the client sent
    // was 2k
    @Override
    public String apply(Buffer bytes) {
        return bytes.toString();
    }
}

问题二：如何将apply函数（上面的）分块？这意味着，当Netty的缓冲区达到极限时，我的apply函数可以创建自己的缓冲区（并管理缓冲区），最终我可以解码消息，Reactory/Netty可以将其传递给使用者。

注意：在我的“main”方法中，以下内容用于设置环境。Netty服务器运行在Windows下，客户端运行在Linux上。这与TCP的Windows实现有关吗？

// NOTES: ServerSocketOptions sets the max buffer for send and receive to 
// something much larger than 1024. Verified with debugger
TcpServerSpec<String, String> spec = new TcpServerSpec<String, String>(NettyTcpServer.class);
spec.env(env);
spec.listen(port);
spec.dispatcher("sync");
spec.codec(new AgentCodec());
spec.consume(connectionHandler(handler));

TcpServer<String, String> tcp = spec.get();
tcp.start().await();

Answer 1

好的，在调试了代码之后，我发现了问题所在--顺便说一下，这在我在Reactor项目（tisk tisk）上找到的任何文档中都找不到。

apply函数将继续被调用更多的消息。因此，如果消息是2K，apply将被调用两次。第一次用1K，第二次用2K。

注意：如果您没有前进的缓冲区位置，它将追加到缓冲区。如果您将缓冲区位置提前，则当apply再次调用时，它将被移除。