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></socketchannel> 存储）。

Java Maven Code Review

审查Java Maven项目（ZIP压缩包或GitLab仓库URL），检查代码规范、命名、模块边界、可维护性问题以及重复代码。

下载

• 发起 connect 时，存入当前 System.nanoTime()
• 在 select 循环中，对每个 pending connect 的 channel，计算已耗时：(now - start) >= timeoutNanos
• 超时则关闭 channel，清理 key，触发自定义超时回调
• 注意：超时检查应在 select 前或 select 返回后立即做，避免漏判

3. 构建守护式主循环（Daemon Loop）

守护进程本质是长期运行、不退出的后台线程。用 Thread.setDaemon(true) 标记，并在 while(true) 中驱动 Selector，同时支持优雅关闭。

• 用 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 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 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;
  });
}

Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南