使用FileInputStream和File对象代替命名管道的问题

Question

我的问题是DataInputStream在流仍然打开但没有数据时抛出EOFException。我希望这会简单地阻止（尽管文档在这个问题上非常模糊）。

DataOutputStream：

public void onEvent() {
    fos.writeInt(width);
    fos.writeInt(height);
    fos.writeInt(newBuffer.length);
    fos.write(newBuffer);
}

DataInPutStream：

while(true) {
    int width = fis.readInt();
    int height = fis.readInt();
    int length = fis.readInt();
    byte[] bytes = new byte[length];
    fis.read(bytes);
}

    fos.write(intToByteArray(width));
    fos.write(intToByteArray(height));
    fos.write(intToByteArray(newBuffer.length));
    Log.e(this.class.getName(), "Writing width: " + Arrays.toString(intToByteArray(width)) + 
                                                      ", height: " + Arrays.toString(intToByteArray(height)) + 
                                                      ", length: " + Arrays.toString(intToByteArray(newBuffer.length)));
    fos.write(newBuffer);
    if(repeat == -1) {
        Log.e(this.class.getName(), "Closing ramFile");
        fos.flush();
        fos.close();
    }

另一边我用这个：

while(true) {
    byte[] intByteArray = new byte[] { -1,-1,-1,-1 };
    fis.read(intByteArray);
    Log.e(this.class.getName(), Arrays.toString(intByteArray));
    int width = toInt(intByteArray, 0);
    fis.read(intByteArray);
    int height = toInt(intByteArray, 0);
    fis.read(intByteArray);
    int length = toInt(intByteArray, 0);
    Log.e(this.class.getName(), "Reading width: " + width + ", height: " + height + ", length: " + length);
}

它给出：

[0, 0, 2, -48] 
Reading width: 720, height: 1280, length: 3686400 

奇怪的是，read()没有阻塞，它只是愉快地继续运行，没有阻塞，但也没有填充数组中的任何值（将数组初始化为{9,9,9,9}后仍然是9,9,9,9）。

[-1, -1, -1, -1] 
Reading width: -1, height: -1, length: -1 
java.lang.NegativeArraySizeException: -1

这就是疯狂的感觉吗？

Answer 1

这里的答案相当简单（没有很好的文档记录）。

FileInputStream的read请求没有超时--这意味着如果您从一个空的但未关闭的流中读取，它将返回而不填充字节（保持给定的字节“原样”）。

您可以使用LocalSocket和LocalServerSocket通过相同的机制流式传输数据，并使用

LocalServerSocket server = new LocalServerSocket(SOCKET_NAME);
LocalSocket socket = server.accept();
socket.setSoTimeout(60);