setSoTimeout 的功能是什么以及它是如何工作的？

Question

我正在尝试自己学习 Socket。我对 Oracle 网站上的以下文字有点困惑。我对此有一些疑问。提前感谢您提供任何明确的解释。

setSoTimeout

public void setSoTimeout(int timeout) 抛出 SocketException

使用指定的超时启用/禁用 SO_TIMEOUT，以毫秒为单位。将此选项设置为非零超时后，对与此 Socket 关联的 InputStream 的 read() 调用将仅阻塞这段时间。如果超时到期，则会引发 java.net.SocketTimeoutException，尽管 Socket 仍然有效。必须在进入阻塞操作之前启用该选项才能生效。超时必须 > 0。超时为零被解释为无限超时。

1. 什么是 SO_TIMEOUT？

2. Socket 是连接的端点。如果我说

   mySocket.setSoTimeout(2000);
   

   这是否意味着我在 2000 毫秒内阻止从服务器/客户端读取此套接字的任何输入，而在此时间之后，套接字已准备好读取数据？

3. 超时过期是什么意思？

4. 在阻塞操作之前必须启用什么选项？

5. 无限超时意味着套接字不再读取？

Answer 1

这是否意味着我在 2000 毫秒内阻止从服务器/客户端读取此套接字的任何输入，而在此时间之后，套接字已准备好读取数据？

不，这意味着如果在 2000 毫秒内没有数据到达，则会抛出 SocketTimeoutException。

超时过期是什么意思？

这意味着 2000 毫秒（在您的情况下）过去了，没有任何数据到达。

在阻塞操作之前必须启用的选项是什么？

没有一个“必须”启用。如果您的意思是“可能启用”，这就是其中之一。

无限超时意味着套接字不再读取？

多么奇怪的建议。这意味着如果没有数据到达，您将永远阻塞读取。

Answer 2

JavaDoc 解释的很好：

将此选项设置为非零超时，read() 调用 与此 Socket 关联的 InputStream 将仅针对此阻塞 多少时间。如果超时到期，则 引发了 java.net.SocketTimeoutException，尽管 Socket 仍然存在 有效的。必须在进入阻止之前启用该选项 操作才能生效。超时必须 > 0。超时为零 被解释为无限超时。

SO_TIMEOUT 是read() 调用将阻塞的超时时间。如果达到超时，将抛出java.net.SocketTimeoutException。如果您想永久阻塞，将此选项设置为零（默认值），那么read() 调用将阻塞，直到至少可以读取 1 个字节。

Answer 3

这个例子让我明白了一切：
如您所见， setSoTimeout 防止程序挂起！它等待SO_TIMEOUT时间！如果它没有得到任何信号，它就会抛出异常！这意味着时间已到！

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketTimeoutException;

public class SocketTest extends Thread {
  private ServerSocket serverSocket;

  public SocketTest() throws IOException {
    serverSocket = new ServerSocket(8008);
    serverSocket.setSoTimeout(10000);
  }

  public void run() {
    while (true) {
      try {
        System.out.println("Waiting for client on port " + serverSocket.getLocalPort() + "...");
        Socket client = serverSocket.accept();

        System.out.println("Just connected to " + client.getRemoteSocketAddress());
        client.close();
      } catch (SocketTimeoutException s) {
        System.out.println("Socket timed out!");
        break;
      } catch (IOException e) {
        e.printStackTrace();
        break;
      }
    }
  }

  public static void main(String[] args) {
    try {
      Thread t = new SocketTest();
      t.start();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}