JavaNIO TCP超时问题

Question

我在两个线程中使用一个SocketChannel，一个线程用于发送数据，另一个线程用于接收数据。

SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress(ip,port));
socketChannel.configureBlocking(false);

线程1：使用上述socketchannel写入数据

线程2：使用相同的socketchannel读取数据

我没有在socketchannel中使用任何选择器，因为我需要写和读是异步的（使用两个不同的线程）

问题：当连接丢失时，socketchannel。write（）和socketchannel。read（）操作不会引发任何错误。它只是阻止了操作。

我需要检测连接丢失。

我尝试在线程2中使用heartbeat方法，但因为读取操作只是阻塞，所以该方法不起作用。有没有其他方法可以在不在新线程中使用心跳的情况下检测连接丢失？

如果连接丢失，是否可能在写入/读取时抛出错误？

提前谢谢。

编辑：

线程1：

public void run() {
  socketChannel = SendAndReceivePacketUtil.createConnection(ip, port);
  socketChannel.configureBlocking(false);

  RecTask task = new RecTask(socketChannel);
  Thread recThread = new Thread(task);
  recThread.start();

  while(true)
  {
     byte[] data= getDataFromQueue(ip);
     if(data!= null) {
         //print(new String(data));
         sendPacket(data, socketChannel);
     }
   }
}

线程2：（矩形任务）

public void run() {
  while(true) {
    byte[] data = receivePacket(socketChannel);
    //print(new String(data));
  }
}

两个线程1

发送包：

int dataSent = 0;
while (dataSent < data.length) {
    long n = socketChannel.write(buf);
        if (n < 0) {
            throw new Exception();
        }
        dataSent += (int) n;
 }

接收数据包：

int dataRec = 0;
byte[] data = new byte[length];
ByteBuffer buffer = ByteBuffer.wrap(data);

while (dataRec < length) {
    long n = socketChannel.read(buffer);
    if (n < 0) {
        throw new Exception();
    }
    dataRec += (int) n;
}       
return data;

我连续发送和接收数据。但是一旦连接丢失，就不会打印任何内容，代码就会被卡住。这是一款android wifi direct应用程序。对于连接丢失场景，我只需关闭wifi模块。

Answer 1

您可以在套接字上查找启用TCP-KEEP活动选项。在空闲连接上，发送消息并为TCP层的消息发送确认字符。

如果TCP-KEEP活动失败，您的下一次读/写操作将导致错误（ECONNRESET），这可以用作连接丢失的标志。

Answer 2

我没有在socketchannel中使用任何选择器，因为我需要写和读是异步的（使用两个不同的线程）

这不是避免使用选择器的原因

问题：当连接丢失时，socketchannel。write（）和socketchannel。read（）操作不会引发任何错误。它只是阻止了操作。

不，它没有。您处于非阻塞模式。它要么返回一个正整数，要么返回零，要么抛出一个异常。是哪一个？

我尝试在线程2中使用heartbeat方法，但因为读取操作只是阻塞，所以该方法不起作用。

读取操作在非阻塞模式下不阻塞。

有没有其他方法可以在新线程中不使用心跳来检测连接丢失？

在TCP中检测连接丢失的唯一可靠方法是写入连接。最终，这将引发IOException：连接重置 但由于缓冲、重试等原因，在连接丢失后不会发生第一次。

如果连接丢失，是否可能在写入/读取时抛出错误？

事情就是这样。

这个问题有严重的问题。要么您发布的代码不是真正的代码，要么它的行为不像您描述的那样。您需要发布更多，例如您的读写代码。