净增加ChannelBuffer大小

Question

您好，我有一个带有处理程序的Netty Server，该处理程序应接受字符串。似乎最多只能接收1024个字节的内容。我如何增加缓冲区大小。我已经尝试过

bootstrap.setOption("child.sendBufferSize", 1048576); 
bootstrap.setOption("child.receiveBufferSize", 1048576);

没有成功。

处理程序如下

public class TestHandler extends SimpleChannelHandler {


@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {

    ChannelBuffer buf = (ChannelBuffer) e.getMessage();

    String response = "";

    if (buf.readable()) {

        response = buf.toString(CharsetUtil.UTF_8);
        System.out.println("CONTENT: " + response);
    }

    System.out.println(response);


}

@Override
public void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) {
    e.getCause().printStackTrace();

    Channel ch = e.getChannel();
    ch.close();
}

}

Answer 1

您正在使用UDP吗？如果是这样，数据包将最大为1024字节。此代码注释在QOTM代码示例中：

允许的数据包最大为1024字节（默认值为768）。您可以增加或减小此值，以避免数据包被截断或分别改善内存占用。

另请注意，无论如何配置此选项，路由器都会截断或丢弃较大的UDP数据包。在UDP中，如果数据包大于特定大小，则将其截断或丢弃，具体取决于路由器配置。IPv4路由器被截断，而IPv6路由器丢弃一个大数据包。这就是为什么使用UDP发送小数据包是安全的。

如果您使用的是TCP，则应在处理程序之前将一个帧解码器和一个字符串解码器添加到管道中。像这样：

pipeline.addLast("frameDecoder", new DelimiterBasedFrameDecoder(80960, Delimiters.lineDelimiter()));
pipeline.addLast("stringDecoder", new StringDecoder(CharsetUtil.UTF_8));
pipeline.addLast("myHandler", new TestHandler());

请注意，您需要修改测试处理程序，因为MessageEvent实际上将包含您的字符串。

@Override
public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {
    String response = (String) e.getMessage();
    System.out.println(response);
}

合理 ？