NettyChannelFuture.operationComplete（）不会在IOException上调用

Question

我正在测试连接失败期间客户端服务器的处理。

在客户端，当我从客户端向服务器发送消息时，拔下LAN电缆，我的ChannelFuture(如下)没有被调用。我所期望的是，我的通道将来会发现这个异常，这样我就可以在操作完成时处理它。

相反，它只会在客户端管道中的最后一个上游处理程序中被捕获。我做错了什么吗？或者也许这是Netty 3.2.4的问题？

当我拔下LAN电缆时，处理程序中出现异常:

    java.io.IOException: An existing connection was forcibly closed by the remote host
        at sun.nio.ch.SocketDispatcher.read0(Native Method)
        at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:25)
        at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:198)
        at sun.nio.ch.IOUtil.read(IOUtil.java:166)
        at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:243)
        at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:321)
        at org.jboss.netty.channel.socket.nio.NioWorker.processSelectedKeys(NioWorker.java:280)
        at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:200)
        at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)

我的频道未来：

    ChannelFuture future = Channels.write(channel, message);
    future.addListener(new ChannelFutureListener() {

           @Override
           public void operationComplete(ChannelFuture future) throws Exception {
               if (!future.isSuccess()) {
                   LOG.error("Client failed to send message", future.getCause());
                   future.getChannel().close();
               }
           }
    });

Answer 1

从堆栈上看，写入似乎已成功完成。尝试读取通道时引发异常。如果您对这种异常感兴趣，您需要实现自己的SimpleChannelUpstreamHandler并覆盖exceptionCaught（..）方法。

请务必将处理程序添加到通道管道。