如何清理InputStream而不关闭它？

Question

客户端代码片段。基本上它从标准输入中读取消息并将消息发送到服务器。

public static void main(String[] args) { 

    try (Socket socket = new Socket("localhost", 1200)) { 
     OutputStreamWriter writer = new OutputStreamWriter(socket.getOutputStream(), StandardCharsets.US_ASCII); 

     Scanner scanner = new Scanner(System.in); 
     for (String msg = scanner.nextLine(); !msg.equals("end"); msg = scanner.nextLine()) { 
      writer.write(msg + "\n"); 
      writer.flush(); 
     } 

    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

Server code snippet。从流中打印消息。从客户端

public void run() { 

    try (InputStreamReader reader = new InputStreamReader(this.socket.getInputStream(), StandardCharsets 
      .US_ASCII)) { 

     StringBuilder builder = new StringBuilder(); 

     for (int c = reader.read(); c != -1; c = reader.read()) { 

      builder.append((char) c); 
      if ((char) c == '\n') 
       System.out.print(builder); 
     } 

    } catch (IOException e) { 
     e.printStackTrace(); 
    } 
} 

输入：

Text1 
Text2 

服务器输出：

Text1 
Text1 
Text2 

的问题，我面对的是服务器输出不刚刚收到的消息，而且之前的所有消息。

问题：如何在不关闭的情况下重置'clean'InputStream。如果这是不可能的，什么是首选的解决方案？

Answer 1

你不需要'清理'流 - 你只需要在每一行之后重置缓冲区。试着像使用StringBuilder.setLength如下：

if (c == '\n') { 
    System.out.print(builder.toString()); 
    builder.setLength(0); 
} 

在另一方面，我强烈鼓励不手动念台词像。考虑像在客户端代码中那样使用Scanner，或者使用BufferedReader。

try (final BufferedReader reader 
     = new BufferedReader(new InputStreamReader(socket.getInputStream(), StandardCharsets.US_ASCII))) { 
    for (String line = reader.readLine(); line != null; line = reader.readLine()) { 
    System.out.println(line); 
    } 
} catch (final IOException ex) { 
    ex.printStackTrace(); 
}