channelRead del servidor de Netty recibe ButBuf vacío con el tamaño 0

votos
0

------------ tubería del lado del cliente (cliente puede enviar cualquier tipo de mensajes, es decir, las solicitudes HTTP, o paquetes binarios) --------

Bootstrap bootstrap = new Bootstrap()
        .group(group)
     //   .option(ChannelOption.TCP_NODELAY, true)
    //    .option(ChannelOption.SO_KEEPALIVE, true)
        .channel(NioSocketChannel.class)
        .handler(new ChannelInitializer() {
            @Override
            protected void initChannel(Channel channel) throws Exception {
                channel.pipeline()
                        .addLast(agent-traffic-shaping, ats)
                        .addLast(length-decoder, new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4, 0, 4))
                        .addLast(agent-client, new AgentClientHandler())
                        .addLast(4b-length, new LengthFieldPrepender(4))
                ;
            }
        });

------------------------------ tubería del lado del servidor ---------------- -

ServerBootstrap b = new ServerBootstrap()
        .group(group)
  //      .option(ChannelOption.TCP_NODELAY, true)
 //       .option(ChannelOption.SO_KEEPALIVE, true)
        .channel(NioServerSocketChannel.class)
        .localAddress(new InetSocketAddress(port))
        .childHandler(new ChannelInitializer() {
                          @Override
                          protected void initChannel(Channel channel) throws Exception {
                              channel.pipeline()
                                      .addLast(agent-traffic-shaping, ats)
                                      .addLast(length-decoder, new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4, 0, 4))
                                      .addLast(new AgentServerHandler())
                                      .addLast(4b-length, new LengthFieldPrepender(4));
                          }
                      }
        );

ChannelFuture f = b.bind().sync();
log.info(Started agent-side server at Port {}, port);

-------- método channelRead del servidor -----------------

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) {

    ByteBuf data = (ByteBuf) msg;
    log.info(SIZE {}, data.capacity());
    String s = data.readCharSequence(data.capacity(), Charset.forName(utf-8)).toString();
    System.out.print(s);
    if (buffer != null) buffer.incomingPacket((ByteBuf) msg);
    else {
        log.error(Receiving buffer NULL for Remote Agent {}:{} , remoteAgentIP, remoteAgentPort);
        ((ByteBuf) msg).release();
    }
 /*   totalBytes += ((ByteBuf) msg).capacity();*/
}

------------ escritura de cliente en el canal (ByteBuf de datos contiene solicitud HTTP válida con un tamaño de 87 Bytes) --------

private void writeToAgentChannel(Channel currentChannel, ByteBuf data) {

    String s = data.readCharSequence(data.capacity(), Charset.forName(utf-8)).toString();
    log.info(SIZE {}, data.capacity());
    System.out.print(s);

    ChannelFuture cf = currentChannel.write(data);
    currentChannel.flush();

 /*   wCount++;
    if (wCount >= request.getRequest().getBufferSize() * request.getRequest().getNumParallelSockets()) {
        for (Channel channel : channels)
            channel.flush();
        wCount = 0;
    }*/
    cf.addListener(new ChannelFutureListener() {
        @Override
        public void operationComplete(ChannelFuture channelFuture) throws Exception {
            if (cf.isSuccess()) {
                totalBytes += data.capacity();
            }
            else log.error(Failed to write packet to channel {}, cf.cause());
        }
    });
}

Sin embargo Server recibe un ByteBuf vacío con tamaño de cero. Lo que podría ser causa posible aquí?

Publicado el 19/09/2018 a las 17:11
fuente por usuario
En otros idiomas...                            


1 respuestas

votos
0

Su problema parece venir desde el cliente, donde se consume accidentalmente todos los bytes dentro de un bytebuf cuando intenta depurarlo.

String s = data.readCharSequence(data.capacity(), Charset.forName("utf-8")).toString();
log.info("SIZE {}", data.capacity());
System.out.print(s);

Llamadas readCharSequenceconsume los datos, dejándole con 0 bytes que quedan.

Se sugiere emplear una DebugHandlerdepurar la tubería, como se prueba que no afecte a los datos

Respondida el 27/09/2018 a las 13:47
fuente por usuario

Cookies help us deliver our services. By using our services, you agree to our use of cookies. Learn more