NIO Reactor 模式：每 N 毫秒在选择器循环内接收异步回调

Question

我想知道 Java NIO 中的标准/最佳实现是什么。这是实现每 N 秒一次心跳等功能的基础。 注意：由于明显的原因（线程是邪恶的并且上下文切换很慢），一切都必须始终发生在选择器循环内。

注1：回答 Apache MINA 不算数，除非您和框架能够演示一个清晰的场景，其中该场景是在 KISS（保持简单愚蠢）方式。

注2：管道需要螺纹。

Answer 1

不确定为什么没有后台线程来发送心跳或超时连接。心跳通常不被认为对性能至关重要。

您可以让选择器等待特定的时间并发送心跳并定期检查超时。

你的意思是像

selector.select(timeout);

if (System.currentTimeMS() > sendHeartbeatTime) {
    for(Connection conn: connections) 
        conn.checkAndSendHeartbeat();
}

// in Connection
private long lastSend = System.currentTimeMS();
private long lastRead = System.currentTimeMS();

public void writeData() {
   lastSend = System.currentTimeMS();
   // write data.
}

public void checkAndSendHeartbeat() {
   long now = System.currentTimeMS();
   if (now - lastRead > HEARTBEAT_TIMEOUT) {
      closeConnection();
   else if (now - lastSend > HEATBEAT_INTERVAL)
      writeHeartBeatData();
} 

Answer 2

创建一个管道，在选择器中注册可读管道的末端，调度一个计时器，在计时器回调中向可写管道的末端写入一个字节。 IO 处理程序应将管道可读事件视为心跳触发器。