Java NIO客户端连接遇Connection refused，如何优雅替代Thread.sleep？

首先明确：不能直接用Socket的isConnected()方法解决这个问题。原因很简单：当你调用SocketChannel.open(new InetSocketAddress(host, port))时，如果服务器未就绪，这个方法会直接抛出ConnectException，此时socketChannel实例都没有成功创建，根本没有对象可以调用isConnected()。就算改用非阻塞连接的正确流程，isConnected()也只能告诉你当前是否处于已连接状态，无法帮你处理连接失败后的重试逻辑。

正确的非阻塞连接实现方式 #

非阻塞模式下，应该采用「先打开通道→发起异步连接→轮询/监听连接状态」的流程，配合重试机制来优雅处理服务器未就绪的情况：

public void connect() {
    SocketChannel socketChannel = null;
    int retryCount = 0;
    final int MAX_RETRIES = 5; // 最大重试次数
    final long RETRY_INTERVAL_MS = 1000; // 重试间隔1秒

    try {
        // 先打开空的SocketChannel
        socketChannel = SocketChannel.open();
        socketChannel.configureBlocking(false);
        
        // 发起异步连接，非阻塞模式下会立即返回
        boolean connected = socketChannel.connect(new InetSocketAddress(host, port));
        
        // 如果没有立即连接成功，轮询等待
        while (!connected && retryCount < MAX_RETRIES) {
            // 尝试完成连接
            connected = socketChannel.finishConnect();
            if (!connected) {
                retryCount++;
                Thread.sleep(RETRY_INTERVAL_MS);
            }
        }

        if (connected) {
            this.socketChannel = socketChannel;
            System.out.println("连接服务器成功");
        } else {
            System.err.println("达到最大重试次数，连接失败");
            socketChannel.close();
        }

    } catch (IOException e) {
        // 捕获连接异常，执行重试逻辑
        if (retryCount < MAX_RETRIES && socketChannel != null) {
            try {
                socketChannel.close();
            } catch (IOException ex) {
                ex.printStackTrace();
            }
            retryCount++;
            try {
                Thread.sleep(RETRY_INTERVAL_MS);
            } catch (InterruptedException ex) {
                Thread.currentThread().interrupt();
            }
            connect();
        } else {
            e.printStackTrace();
            System.err.println("连接失败，已耗尽重试次数");
        }
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        System.err.println("连接过程被中断");
        if (socketChannel != null) {
            try {
                socketChannel.close();
            } catch (IOException ex) {
                ex.printStackTrace();
            }
        }
    }
}

进阶优化：用Selector监听连接事件 #

如果你的应用基于NIO Selector架构，可以通过注册OP_CONNECT事件来实现无轮询的连接状态监听，这是更优雅的NIO原生方式：

public void connectWithSelector() throws IOException {
    Selector selector = Selector.open();
    SocketChannel socketChannel = SocketChannel.open();
    socketChannel.configureBlocking(false);
    
    // 发起异步连接并注册连接事件
    socketChannel.connect(new InetSocketAddress(host, port));
    socketChannel.register(selector, SelectionKey.OP_CONNECT);

    while (selector.select() > 0) {
        Iterator<SelectionKey> keyIterator = selector.selectedKeys().iterator();
        while (keyIterator.hasNext()) {
            SelectionKey key = keyIterator.next();
            if (key.isConnectable()) {
                SocketChannel channel = (SocketChannel) key.channel();
                if (channel.finishConnect()) {
                    // 连接成功，切换为监听读事件
                    key.interestOps(SelectionKey.OP_READ);
                    this.socketChannel = channel;
                    System.out.println("连接服务器成功");
                } else {
                    // 连接失败，关闭通道
                    channel.close();
                }
            }
            keyIterator.remove();
        }
    }
}

为什么isConnected()不适用？ #

• 当连接直接抛出异常时，socketChannel实例尚未创建，根本无法调用该方法。
• isConnected()返回true仅代表通道曾经成功连接过，即使后续连接断开，它依然会返回true，无法准确反映当前实时的连接状态。

内容的提问来源于stack exchange，提问作者wydra__