Netty отправляет 2 пакета вместо одного - PullRequest
Новая
       21

Netty отправляет 2 пакета вместо одного

0 голосов
/ 03 марта 2019

Я делаю свои первые шаги с netty, и мне интересно следующее поведение netty:

Когда я использую следующий обработчик: 

public class SimpleServerHandler extends ChannelInboundHandlerAdapter {

DateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");

@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
    ByteBuf inBuffer = (ByteBuf) msg;

    String received = inBuffer.toString(CharsetUtil.UTF_8);
    System.out.println(dateFormat.format(new Date()) + " Server received: " + received);

    ctx.writeAndFlush(Unpooled.copiedBuffer("Hello " + received, CharsetUtil.UTF_8));
}

@Override
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
}

@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
    cause.printStackTrace();
    ctx.close();
}
}

И я затем отправляюTCP-пакет с «Packet Sender» Я получаю три пакета

, первый от «отправителя пакета» на сервер, второй ответ от сервера (так что-то вроде «Hello testtest»), а затем... и я не знаю, откуда этот пакет: третий от сервера до "отправителя пакета", без содержимого

Java моего сервера: 

public class MainNettyApplicationServer {

public static void main(String[] args) throws InterruptedException {
    EventLoopGroup group = new NioEventLoopGroup();

    try {
        ServerBootstrap serverBootstrap = new ServerBootstrap();
        serverBootstrap.group(group);
        serverBootstrap.channel(NioServerSocketChannel.class);
        serverBootstrap.localAddress(new InetSocketAddress("10.0.0.2", 11111));

        serverBootstrap.childHandler(new ChannelInitializer<SocketChannel>() {
            protected void initChannel(SocketChannel socketChannel) throws Exception {
                socketChannel.pipeline().addLast(new SimpleServerHandler());
            }
        });
        ChannelFuture channelFuture = serverBootstrap.bind().sync();
        System.out.println("Server started.");
        channelFuture.channel().closeFuture().sync();
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        group.shutdownGracefully().sync();
    }
}

}
...