多线程TCP服务器：java.net.SocketException：套接字关闭

Question

我的代码如下。当收到请求时，服务器将创建两个线程（生产者 - 消费者模式）：

... 
while(true) { 
    Socket clientSocket = server.accept(); 
    System.out.println("Got connection!"); 

    Thread consumerThread = new Thread(new ConsumerThread(sharedQueue, clientSocket)); 
    Thread producerThread = new Thread(new ProducerThread(sharedQueue, clientSocket)); 

    consumerThread.start(); 
    producerThread.start(); 
} 
... 

消费者线程读取哪些客户端发送和生产者线程返回响应。消费者：

@Override 
    public void run() { 
     try { 
      while (true) { 
       in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream())); 
       // read, do actions 
      } 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } finally { 
      try { 
       in.close(); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 

    } 

监制：

@Override 
    public void run() { 
     try { 
      out = new PrintStream(clientSocket.getOutputStream(), true); 
      // some actions 
      out.println("something"); 

     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } catch (IOException e) { 
      e.printStackTrace(); 
     } finally { 
      try { 
       out.close(); 
       clientSocket.close(); 
      } catch (IOException e) { 
       e.printStackTrace(); 
      } 
     } 

但在服务器我得到以下错误：

java.net.SocketException: Socket closed 
    at java.net.SocketInputStream.socketRead0(Native Method) 
    at java.net.SocketInputStream.read(SocketInputStream.java:150) 
    at java.net.SocketInputStream.read(SocketInputStream.java:121) 
    at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284) 
    at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326) 
    at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178) 
    at java.io.InputStreamReader.read(InputStreamReader.java:184) 
    at java.io.BufferedReader.fill(BufferedReader.java:161) 
    at java.io.BufferedReader.readLine(BufferedReader.java:324) 
    at java.io.BufferedReader.readLine(BufferedReader.java:389) 
    at ee.ut.ds.server.ConsumerThread.run(ConsumerThread.java:30) 
    at java.lang.Thread.run(Thread.java:745) 

什么可能会导致这样？我甚至看到客户端正确接受消息。另外，在生产者线程中，我关闭一个套接字。我不明白。

Answer 1

您关闭套接字，并继续使用它。

不要关闭套接字，或者它的输出流，直到您已经阅读流的末尾从BufferedReader.

构建BufferedReader外循环。

您可能不需要每个套接字两个线程。

Answer 2

您正在并行启动两个线程。你无法预测线程的细节。对于两个线程使用相同的套接字，并且如果生产者线程启动，则在finally节中关闭套接字。 你不应该关闭连接，并确保不会发生竞态条件。

Answer 3

问题是因为您在写入内容之后关闭了您的产品的套接字。 如果您希望套接字打开，只需关闭Producer中finally块中的输出流即可。 一旦确定没有更多的网络I/O通过套接字发生，就可以从服务器/生产者/使用者关闭套接字。

https://docs.oracle.com/javase/7/docs/api/java/net/Socket.html#close()