Socket inputStream 读取消息给出了意外的长度

Question

我有一个从客户端读取消息的函数，超时时间为 100 毫秒。在我的代码中，我在循环中使用这个函数，直到得到一个与“”不同的字符串，这就是我知道我得到了我需要的消息并可以继续我的代码的方式。由于某种原因，它适用于第一个套接字，但是当我将从套接字接收到的内容发送到套接字 2 并等待套接字 2 响应时，即使套接字 2 仍然连接并处于活动状态，我也会得到 bytesReceived = -1。

代码：

    public String getMessage(int socketNumber) {
        Socket socket = socket1;
        if(socketNumber == 2){
            socket = socket2;
        }
        byte[] message = new byte[4096];
        int bytesReceived = 0;

        try {
            socket.setSoTimeout(100);
            bytesReceived = socket.getInputStream().read(message);
        } catch (SocketTimeoutException e) {
            return "";
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        System.out.println("AMOUNT OF BYTES RECEIVED FROM" + socketNumber + " IS " + bytesReceived);
        // Convert the message to a string.
        return new String(message, 0, bytesReceived);
    }

Answer 1

你应该做类似的事情

try (InputStream in = socket.getInputStream()) {
   StringBuilder builder = new StringBuilder();
   byte[] buffer = new byte[4096];
   int count;
   while ((count = in.read(buffer) > 0) {
      builder.append(new String(buffer, 0, count));
   }
   return builder.toString();
}