命令 shell 上的 java 进程之间的管道工作不可靠

Question

我正在尝试在两个 java 程序之间传输文本。为了简单起见，我展示了这段代码：

import java.io.DataInputStream;
import java.io.IOException;

public class Test {
    public static void main(String[] args) throws IOException {
        DataInputStream stdin = new DataInputStream(System.in);
        String completeText = ""; 

        while (stdin.available() > 0) {
            byte[] tempByte = { stdin.readByte() };
            completeText += new String(tempByte);
        }

        System.out.println(completeText);
    }
}

在 Linux 或 Windows 上执行以下操作时，文本似乎被省略，就好像管道阻塞或丢失相当随机一样。有时一切都会通过，有时则不然：

echo "omg wtf" | java Test | java Test

对此有什么想法吗？ CPU 速度越慢，文本通过的频率似乎越高。当输入从 java System.out.println() 传送时，“available”是否会因任何原因返回错误的结果？

干杯!

Answer 1

首先，available() 方法不是确定流是否耗尽的可靠方法。流结束的可靠指示是通过检查 read() 方法的返回值（<0 表示流结束）。

简而言之，如果流暂时为空，则 available() 可以返回 false （这将终止循环）。如果管道仍然处于活动状态，一旦管道另一端的进程向其中写入一些字节，这种情况就会改变。为了确保读取所有数据，您需要检查流结束。

其次，如果您想读取字符（并将它们连接成字符串），您应该从 Reader （而不是来自流的字节）。这将允许您的代码处理 unicode 字符。

第三，如果使用 StringBuilder（而不是普通字符串）。

最后，如果您只需要读取字节，则可以直接使用输入流（不需要用 DataInputStream 包装它）。

我是这样写的：

Reader r = new InputStreamReader(System.in);
StringBuilder sb = new StringBuilder();
while(true) {
  int ch = r.read();
  if(ch < 0)
    break;
  sb.append((char) ch);
}

System.out.println(sb.toString());

Answer 2

available() 对于管道输入来说不可靠。它检查当前进程的输入缓冲区中是否有数据。它无法检查前面的（管道方式）进程是否要发送一些数据。

在您的情况下，阻止读取是一个可接受的解决方案：

public class Test {
    public static void main(String[] args) throws IOException {
        DataInputStream stdin = new DataInputStream(System.in);
        StringBuilder completeText = new StringBuilder(); 
        byte[] tempByte = new byte[1024];
        int len = 0;  
        while ((len = stdin.read(tempByte)) != -1) {
            completeText.append(new String(tempByte, 0, len));
        }
        System.out.println(completeText.toString());
    }
}

我还添加了 StringBuilder，因为这是连接字符串的“正确”java 方法。