从客户端断开连接中恢复服务器的最佳方法

Question

我已经用 Java 编写了一个 tcp 服务器。它生成工作实例（可运行）并侦听传入的 tcp 连接。从客户端连接后，它将从客户端获取数据并进行自己的处理。

最近，我注意到在客户端断开连接时，整个服务器将崩溃并出现错误 java.net.SocketException: Connection reset when the client disconnects or quits。这是当我意识到我没有针对所有失败实例彻底测试 tcp 服务器的时候。

我查看了代码，发现 tcp 服务器将在此行崩溃 while((bytesRead.... -1) 在工作实例中

final int BUFFSIZE = 65535;
int bytesRead;
byte[] buffer = new byte[BUFFSIZE];
din = new BufferedInputStream(clientSocket.getInputStream());

while ((bytesRead = din.read(buffer)) != -1) {   //tcp server crashes at this line if client quits or disconnects.
// worker does its job.
}

我一直在思考在不导致 tcp 服务器崩溃的情况下关闭 worker 实例的最佳方法。我无权访问客户端源代码来修改他们的任何内容。

有什么想法吗？

布雷格斯 养乐多121

Answer 1

如果您想处理异常，网络 I/O 应该在 try/catch 块中完成。

Answer 2

如果连接关闭，此行应抛出 IOException。只要确保捕获 IOException 并在它发生时从 Runnable 的 run() 方法返回。这将停止处理此客户端连接的线程。

但是，如果它使整个服务器崩溃，那么您一定是做错了什么。这可能意味着每个客户端连接没有一个线程，而是一个线程依次处理客户端，一次一个。发布服务器代码以获取更多信息。

Answer 3

解决了问题。写下我为任何想要解决同样问题的人所做的事情。

private boolean isStopped = false;

while (!isStopped()) {
   try {
      while ((bytesRead = din.read(buffer)) != -1) {   
         // worker does its job.
      }
   }
   catch (IOException ex) {
      System.out.println("Exception called! Most likely due to client disconnect!");
      stop();
   }
}

public boolean isStopped() {
    return this.isStopped;
} 

public synchronized void stop(){
    this.isStopped = true;
}