净额不写

Question

Wireshark确认，当尝试使用netty进行写入时，写入的数据永远不会在远端结束。

我努力了：

//Directly using writeAndFlush
channel.writeAndFlush(new Packet());

//Manually flushing
channel.write(new Packet());
channel.flush();

// Even sending bytes won't work:
channel.writeAndFlush(new byte[]{1,2,3});

当我包装它时，没有异常被捕获 try{...}catch(Throwable e){e.printStackTrace();}

我该怎么做才能调试此问题？

Answer 1

Netty是异步的，这意味着在写入失败时它不会引发异常。它不会引发异常，而是返回一个Future<?>将在请求完成后更新的。确保在第一个调试步骤中记录由此产生的所有异常：

channel.writeAndFlush(...).addListener(new GenericFutureListener<Future<Object>>() {
    @Override
    public void operationComplete(Future<Object> future) {
        // TODO: Use proper logger in production here
        if (future.isSuccess()) {
            System.out.println("Data written succesfully");
        } else {
            System.out.println("Data failed to write:");
            future.cause().printStackTrace();
        }
    }
});

或更简单地说：

channel.writeAndFlush(...).addListener(ChannelFutureListener.FIRE_EXCEPTION_ON_FAILURE);

获得异常的根本原因后，可能会出现多个问题：

unsupported message type: <type> (expected: ...)

注意：
使用时也会抛出此错误ObjectEncoder，但您的对象未实现Serializable

默认的Netty通道只能发送ByteBufs和FileRegion。您需要通过向管道添加更多处理程序，或将它们手动转换为ByteBufs
，将对象转换为这些类型。

A ByteBuf是字节数组的Netty变体，但具有性能潜力，因为它可以存储在直接存储空间中。

通常使用以下处理程序：

转换String用途StringEncoder
转换Serializable用途ObjectEncoder（警告，与普通Java对象流不兼容）转换byte[]用途ByteArrayEncoder

注意： 由于TCP是基于流的协议，因此您通常需要附加某种形式的数据包大小，因为您可能不会收到写入的确切数据包。有关更多信息，请参见Netty
Wiki中的处理基于流的传输。