如何在Java 1.4中设置BufferedReader和PrintWriter的超时？

Question

如何在使用套接字连接创建的BufferedReader和PrintWriter上设置超时？这是我现在为服务器提供的代码,直到服务器或客户端崩溃为止:

while(isReceiving){
    str = null;
    BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);

    while ((str = br.readLine()) != null){
        System.out.println("Processing command " + str);
        pw.println(client.message(str));
    }
}

在这段代码的范围之外,我已经施加了1000毫秒的套接字超时,它在等待初始连接时按预期工作.但程序阻塞在(str = br.readLine()).如果客户端挂起或崩溃,它永远不会停止阻止,除非我终止进程(即使这样也不总是有效).

有问题的客户端代码与此非常相似,并且以类似的方式阻塞.

Answer 1

您可以使用Google的Guava库中的SimpleTimeLimiter.

示例代码(在Java 8中):

BufferedReader br = ...;
TimeLimiter timeLimiter = new SimpleTimeLimiter();

try {
    String line = timeLimiter.callWithTimeout(br::readLine, 10, TimeUnit.SECONDS);
} catch (TimeoutException | UncheckedTimeoutException e) {
    // timed out
} catch (Exception e) {
    // something bad happened while reading the line
}

Answer 2

1. 您需要在套接字上设置读取超时Socket.setSoTimeout().SocketTimeoutException如果指定的读取超时到期,这将导致任何读取方法抛出a .NB读取超时不是设置在流上,而是设置在底层Socket,通道上Socket.setSoTimeout().

2. 在TCP中没有写入超时这样的事情.

Answer 3

这个问题的答案描述了一种使用 aTimer关闭连接的有趣方法。我不是 100% 确定这在阅读过程中是否有效，但值得一试。

从那个答案复制：

TimerTask ft = new TimerTask(){
   public void run(){
     if (!isFinished){
       socket.close();
     }
   }
};

(new Timer()).schedule(ft, timeout);

isFinished应该是一个boolean变量，true当您完成从流中读取时应设置为该变量。

Answer 4

由于调用 socket.close() 似乎没有中断 br.readLine() 处的块，因此我做了一些解决方法。当断开客户端与服务器的连接时，我只需发送一个字符串“bye”，并告诉服务器在收到此命令时关闭套接字连接。

while ((str = br.readLine()) != null){
    // If we receive a command of "bye" the RemoteControl is instructing
    // the RemoteReceiver to close the connection.
    if (str.equalsIgnoreCase("bye")){
        socket.close();
            break;
    }
    System.out.println("Processing command " + str);
    pw.println(client.message(str));
}