Netty Tăng ChannelBuffer Size

Question

Xin chào Tôi có một Netty Server với một trình xử lý chấp nhận chuỗi. Có vẻ như chỉ nhận nội dung tối đa 1024 byte. Làm thế nào tôi có thể tăng kích thước bộ đệm. Tôi đã thử

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

không thành công.

Việc xử lý như sau

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

Bạn đang sử dụng UDP? Nếu vậy, các gói tin sẽ tối đa ở mức 1024 byte. Nhận xét mã này nằm trong mẫu mã QOTM:

Cho phép các gói lớn tới 1024 byte (mặc định là 768). Bạn có thể tăng hoặc giảm giá trị này để tránh các gói bị cắt bớt hoặc để cải thiện dấu chân bộ nhớ tương ứng.

Cũng xin lưu ý rằng một gói UDP lớn có thể bị cắt hoặc bỏ bởi bộ định tuyến của bạn bất kể bạn định cấu hình tùy chọn này như thế nào. Trong UDP, gói bị cắt bớt hoặc bị xóa nếu kích thước lớn hơn một kích thước nhất định, tùy thuộc vào cấu hình bộ định tuyến. Bộ định tuyến IPv4 cắt ngắn và IPv6 bộ định tuyến thả một gói lớn. Đó là lý do tại sao nó an toàn để gửi các gói nhỏ trong UDP.

Nếu bạn đang sử dụng TCP, bạn nên thêm bộ giải mã khung và bộ giải mã chuỗi vào đường dẫn trước khi xử lý; Một cái gì đó như thế này:

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

Tâm trí bạn, bạn sẽ cần phải sửa đổi trình xử lý kiểm tra của bạn vì MessageEvent thực sự chứa chuỗi của bạn.

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

Có ý nghĩa?

Answer 2

Trong phiên bản 4.0.10.Đối với kích thước bộ đệm UDP được đặt thành 2048 byte.

Nếu bạn muốn tăng nó thiết lập ChannelOptions như sau:

option(ChannelOption.SO_RCVBUF, int bytes) 

và cũng

option(ChannelOption.RCVBUF_ALLOCATOR, new FixedRecvByteBufAllocator(int Bytes))