客户端关闭或客户端重新启动时，Java服务器套接字TCP连接卡在CLOSE_WAIT状态

Question

当执行客户端重新启动或关闭时，服务器端的所有套接字连接都挂起CLOSE_WAIT。用于将序列化数据发送到XDR流中的XdrAble。池是标准KeyedSocketPool的对象。MAXIMUM_RETRY、MAXIMUM_RETYR_BEFORE_RESET_POOL是为重置池连接而定义的常量。关闭连接时我缺少了什么？

公共RESP调用（REQ request、RESP response、int requestLength和int timeOut）引发异常{
Socket Socket=Null；

IOException ioException = null;

short attempts = 0;
boolean needResetPool = false;

while (true)
{
  ioException = null;

  try
  {
    // Get socket (open if not connected)
    socket = (Socket) pool.borrowObject ();
    socket.setSoTimeout (timeOut);

    // Send request
    BufferedOutputStream outputStream = new BufferedOutputStream (socket
        .getOutputStream ());
    XdrBufferEncodingStream xdrIn = new XdrBufferEncodingStream (
        requestLength);
    xdrIn.beginEncoding (socket.getInetAddress (), socket.getPort ());
    request.xdrEncode (xdrIn);
    xdrIn.endEncoding ();
    outputStream.write (xdrIn.getXdrData ());
    outputStream.flush ();
    xdrIn.close ();

    // Read response
    BufferedInputStream inputStream = new BufferedInputStream (socket
        .getInputStream ());
    byte[] buffer = new byte[UreMsgBodyLength.MAXIMUM_MSG_LEN];
    int bytesRead = inputStream.read (buffer);

    if (bytesRead < UreMsgBodyLength.MESSAGE_HEADER_LEN)
      throw new IOException("Socket Read Failed - invalid bytesRead="+bytesRead);


    int encodedLength = bytesRead;
    if ( encodedLength < 0 || ( encodedLength & 3) != 0 )
      encodedLength = UreMsgBodyLength.MAXIMUM_MSG_LEN;

   XdrBufferDecodingStream xdrOut = new XdrBufferDecodingStream (buffer, encodedLength);
    xdrOut.beginDecoding ();
    response.xdrDecode (xdrOut);
    xdrOut.endDecoding ();
    xdrOut.close ();
    return response;
  }
  catch (ConnectException ex)
  {

    ioException = ex;
  }
  catch (IOException ex)
  {

    ioException = ex;

    if (socket != null)
    {
      needResetPool = true;
      try { socket.close (); } catch (Throwable t) {}

      try
      {
        pool.invalidateObject (socket);          // Mark the socket as invalid

      }
      catch (Throwable t)
      {

      }
      socket = null;
    }
  }
  finally
  {    
    if (socket != null)
    {
      try
      {
        pool.returnObject (socket);
      }
      catch (Throwable t)
      {

      }
    }
  }

  if (attempts >= MAXIMUM_RETYR_BEFORE_RESET_POOL && needResetPool)
  {

    pool.clear (pool.getKey ()); // clean all connect for the current server id
  }
  if (attempts >= MAXIMUM_RETRY)
  {

    throw ioException;
  }

  attempts++;

} // while

}

Answer 1

关闭连接时我错过了什么？

服务器没有关闭它的套接字来响应读取EOS（read（）返回-1）。这段代码也处理不好。CLOSE_WAIT表示对等方已关闭连接，本地系统正在等待应用程序关闭此端。