Java NIO可通过非阻塞SocketChannel+Selector+手动计时实现带超时的连接建立并长期运行：1. 非阻塞connect后注册OP_CONNECT，轮询finishConnect()判断结果；2. 用ConcurrentHashMap记录起始时间，每次select前后检查超时并清理；3. 守护线程中while(running)驱动Selector，配合shutdown钩子优雅退出。
Java NIO 本身不直接提供连接超时（connect timeout）的阻塞式语义，但可以通过 SocketChannel 的非阻塞模式 + Selector + 手动计时，实现带超时控制的连接建立，并长期运行作为守护进程。关键在于：把 connect 过程变成可轮询、可中断、可超时的异步操作。
1. 使用非阻塞 SocketChannel 发起连接
调用 channel.configureBlocking(false) 后，channel.connect(address) 立即返回 false（表示连接未完成），此时需注册 SelectionKey.OP_CONNECT 到 Selector，等待连接就绪事件。
- 不要在非阻塞 channel 上调用
finishConnect()前做任何 I/O 操作 - 每次
selector.select(timeout)返回后，遍历 selectedKeys，对 OP_CONNECT 事件调用channel.finishConnect() - 若返回
true，说明连接成功；若抛出异常（如 IOException），说明连接失败
2. 手动维护连接超时逻辑
NIO 没有内置 connect 超时，需自己记录连接开始时间，并在每次 select 前检查是否超时。推荐为每个待连接的 channel 关联一个“连接开始时间戳”（如用 ConcurrentHashMap<SocketChannel, Long> 存储）。
- 发起 connect 时，存入当前
System.nanoTime() - 在 select 循环中，对每个 pending connect 的 channel，计算已耗时：
(now - start) >= timeoutNanos - 超时则关闭 channel，清理 key，触发自定义超时回调
- 注意：超时检查应在 select 前或 select 返回后立即做，避免漏判
3. 构建守护式主循环（Daemon Loop）
守护进程本质是长期运行、不退出的后台线程。用 Thread.setDaemon(true) 标记，并在 while(true) 中驱动 Selector，同时支持优雅关闭。
立即学习“Java免费学习笔记（深入）”；
- 用
AtomicBoolean running = new AtomicBoolean(true)控制循环生命周期 - 主循环结构：
while (running.get()) { selector.select(100); handleSelectedKeys(); cleanupTimeouts(); } - 注册 JVM 关闭钩子（
Runtime.getRuntime().addShutdownHook(...)）来关闭 selector 和 channels - 捕获
ClosedSelectorException等异常，避免循环崩溃
4. 示例关键片段（简化版）
// 初始化
Selector selector = Selector.open();
Map<SocketChannel, Long> connectStartTimes = new ConcurrentHashMap<>();
long connectTimeoutNs = TimeUnit.SECONDS.toNanos(5);
// 发起连接
SocketChannel ch = SocketChannel.open();
ch.configureBlocking(false);
ch.connect(new InetSocketAddress("example.com", 8080));
ch.register(selector, SelectionKey.OP_CONNECT);
connectStartTimes.put(ch, System.nanoTime());
// 主循环中处理
while (running.get()) {
selector.select(100); // 最多阻塞 100ms
Set<SelectionKey> selected = selector.selectedKeys();
for (SelectionKey key : new HashSet<>(selected)) {
if (key.isConnectable()) {
SocketChannel ch = (SocketChannel) key.channel();
try {
if (ch.finishConnect()) {
// 连接成功，切换为 OP_READ 等
} else { /* 连接仍在进行 */ }
} catch (IOException e) { /* 连接失败 */ }
connectStartTimes.remove(ch);
}
}
selected.clear();
// 检查超时
long now = System.nanoTime();
connectStartTimes.entrySet().removeIf(entry -> {
SocketChannel ch = entry.getKey();
if (now - entry.getValue() >= connectTimeoutNs) {
try { ch.close(); } catch (IOException ignored) {}
return true;
}
return false;
});
}
