Netty 4.0.x 正确捕获 ConnectException

Question

我正在使用 Netty 开发一个应用程序，我需要处理客户端抛出的 ConnectException，以防例如连接超时。

这是代码

import io.netty.bootstrap.Bootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.util.concurrent.Future;
import io.netty.util.concurrent.FutureListener;

public class ConnectTest {

public static void main(String[] args) throws Exception {
    Bootstrap b = new Bootstrap();
    b.group(new NioEventLoopGroup()).channel(NioSocketChannel.class)
    .handler(new ChannelInitializer<SocketChannel>() {

        @Override
        public void initChannel(SocketChannel ch) throws Exception {

        }
    });
    final ChannelFuture f = b.connect("0.0.0.0", 8080);
    f.addListener(new FutureListener<Void>() {

        @Override
        public void operationComplete(Future<Void> future) throws Exception {
            if (!f.isSuccess())
                System.out.println("Test Connection failed");
        }
    });
    f.sync();
}
}

结果如下：

测试连接失败 线程“主”中的异常 java.net.ConnectException：连接被拒绝：没有更多信息：/0.0.0.0:8080 在 sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) 在 sun.nio.ch.SocketChannelImpl.finishConnect（未知来源） 在 io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:208) 在 io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:287) 在 io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:524) 在 io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized (NioEventLoop.java:464) 在 io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:378) 在 io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:350) 在 io.netty.util.concurrent.SingleThreadEventExecutor$2.run（SingleThreadEventExecutor.java:116） 在 java.lang.Thread.run（未知来源）

正如您所见，监听器工作正常，但我仍然打印出丑陋的堆栈跟踪，我不知道在哪里拦截它。

有什么提示吗？

Answer 1

罪魁祸首是

f.sync() 

您可以在侦听器中处理 ConnectExceptions：

    final ChannelFuture f = b.connect("0.0.0.0", 8080);
    f.addListener(new FutureListener<Void>() {

        @Override
        public void operationComplete(Future<Void> future) throws Exception {
            if (!f.isSuccess()) {
                System.out.println("Test Connection failed");
                handleException(future.cause());

            }
        }
    });
    //f.sync();