Java中SocketChannel非阻塞连接超时控制的核心是：先设非阻塞并调用connect()，若返回false则注册OP_CONNECT事件，用带超时的select()轮询，并在循环中通过System.nanoTime()精确计算总耗时，超时则关闭channel并取消key。
Java 中使用 SocketChannel 实现非阻塞异步连接并控制超时，核心在于结合 Selector 与 connect() 的状态轮询，而非依赖阻塞式 socket.connect()。直接调用 channel.connect() 在非阻塞模式下会立即返回 false，表示连接尚未完成，此时需注册 SelectionKey.OP_CONNECT 事件，由 Selector 通知连接结果，并在超时时间内主动检查。
设置非阻塞 SocketChannel 并发起连接
创建 SocketChannel 后必须先设为非阻塞，再调用 connect()。若返回 true，说明连接已就绪（如本地回环或服务端响应极快）；若返回 false，说明连接仍在进行中，需等待就绪通知。
- 调用
channel.configureBlocking(false) - 调用
channel.connect(new InetSocketAddress(host, port)) - 若返回
true，可立即开始读写；否则进入等待流程
用 Selector 等待 OP_CONNECT 就绪并设置超时
Selector 不支持直接指定单次 select() 的“连接超时”，但可通过带超时参数的 select(long timeout) 实现。关键是在循环中记录起始时间，每次 select() 返回后检查是否超时，同时处理就绪的 OP_CONNECT 事件。
- 将 channel 注册到 selector，关注
SelectionKey.OP_CONNECT - 在循环中调用
selector.select(timeoutMillis)，例如select(100)表示最多等 100ms - 每次 select 返回后，遍历 selectedKeys：若 key 是
OP_CONNECT，调用channel.finishConnect()判断是否成功 - 若
finishConnect()返回true，连接成功；若抛出异常（如IOException），连接失败
手动检测超时并关闭资源
超时判断不能只靠 select 超时值，因为多次 select 可能累积耗时。应在循环外记录开始时间，每次 select 后计算已耗时，超过阈值则主动退出并关闭 channel。
立即学习“Java免费学习笔记（深入）”；
- 用
System.nanoTime()记录起始纳秒时间 - 每次 select 后用当前时间减去起始时间，换算为毫秒并与目标超时比较
- 超时后调用
channel.close()，避免连接处于半开状态 - 注意：即使超时，也要确保 selector 已取消该 channel 的 key（
key.cancel()）并清理
完整逻辑示例（关键片段）
以下为简化但可运行的核心逻辑（省略异常包装和资源 try-with-resources）：
SocketChannel channel = SocketChannel.open();
channel.configureBlocking(false);
InetSocketAddress addr = new InetSocketAddress("example.com", 80);
<p>boolean connected = channel.connect(addr);
if (connected) {
// 连接立即成功
} else {
Selector selector = Selector.open();
channel.register(selector, SelectionKey.OP_CONNECT);</p><pre class='brush:java;toolbar:false;'>long startNanos = System.nanoTime();
long timeoutNanos = TimeUnit.MILLISECONDS.toNanos(5000); // 5秒超时
while (true) {
long elapsedNanos = System.nanoTime() - startNanos;
if (elapsedNanos >= timeoutNanos) {
throw new IOException("Connect timeout");
}
int ready = selector.select(Math.max(1, TimeUnit.NANOSECONDS.toMillis(timeoutNanos - elapsedNanos)));
if (ready == 0) continue;
Iterator<SelectionKey> it = selector.selectedKeys().iterator();
while (it.hasNext()) {
SelectionKey key = it.next();
it.remove();
if (key.isConnectable()) {
SocketChannel ch = (SocketChannel) key.channel();
try {
if (ch.finishConnect()) {
System.out.println("Connected!");
return ch; // 成功返回
}
} catch (IOException e) {
throw new IOException("Connection failed", e);
}
}
}
}}
