ByteBuf 초기 용량 크기

Question

ByteBuf 초기 용량을 늘리는 방법을 알려주십시오.
에서 같은 상황 : ByteBuf의 최대 용량보다 소득 메시지보다 경우

@Override 
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception { 

    byte[] byteinput = new byte[in.readableBytes()]; 
    in.readBytes(byteinput); 

//further handling... 
} 

- 난의 cutted 데이터를 얻을. 이 프로젝트가 전체적이고 비 청크진 메시지를 얻는 것이 중요합니다.

ByteBuf의 초기 용량을 bootstraps childOptions 어딘가에 설정하거나 cannel.config() ... ChannelInitializer 내부에 설정해야한다고 가정합니다.
그리고 난

ch.config().setReceiveBufferSize(1024) 

설정과 같은 여러 가지 방법을 시도하지만 난 여전히 ByteBuf 용량 (예를 들면. 496)의 같은 값을 가지고있다.

UPD

나는 Wireshark를 내 프로토콜 트래픽을 발견하고, 내 테스트 사용자 클라이언트에서 밖으로와에서 손상되지 않은 것 1,4k까지 패킷. 이 문제는 netty 설정의 문제 일뿐입니다. 운영 체제 소켓 버퍼는 메시지를 자르지 않습니다.

Answer 1

파이처럼 쉬웠습니다.

ServerBootstrap b = new ServerBootstrap(); // (2) 
     b.group(bossGroup, workerGroup) 
       .channel(NioServerSocketChannel.class) // (3) 
       .childHandler(new ChannelInitializer<SocketChannel>() { // (4) 
        @Override 
        public void initChannel(SocketChannel ch) throws Exception { 

         //decrypt //checknum 

         ch.config().setRecvByteBufAllocator(new FixedRecvByteBufAllocator(2048)); //set buf size here 
         ch.pipeline().addLast(new InboundDecryptor()); 
. 
. 
. 

Answer 2

Netty의 버퍼 할당 크기를 구성 할 수는 있지만보다 일반적인 제한 사항이있을 수 있습니다. Netty는 비동기 프레임 워크입니다. 즉, OS에서 사용 가능한 내용을 읽고이를 사용자에게 전달합니다. Netty는 네트워크 상태, 네트워킹 하드웨어 동작, OS 동작 또는 데이터 생산자와 Netty 응용 프로그램 사이의 다른 것을 제어하지 않습니다. 응용 프로그램 논리에 완전한 응용 프로그램 레벨 메시지가 필요한 경우이 응용 프로그램 논리를 호출하기 전에 데이터를 집계해야 할 수 있습니다. Netty는 이것을 돕기위한 몇 가지 편리한 방법을 가지고 있는데, MessageAggregator.java을 참조하고 HTTP 특정 구현은 HttpObjectAggregator.java을 참조하십시오.

Answer 3

Scott이 맞습니다. 버퍼의 크기 만 늘려도 문제는 해결되지 않습니다.

ch.config().setRecvByteBufAllocator(new FixedRecvByteBufAllocator(2048)); 

또한 HTTP 요청의 경우 HTTPObjectAggregator을 사용해야합니다. 그것은 나를 위해 일했습니다.