Java检测关闭流

Question

我有一个由 OutputStream 和 InputStream 组成的通用套接字实现。

完成一些工作后，我将关闭 OutputStream。

完成此操作后，我的 InputStream 的 read() 方法会在无限长的时间内返回 -1，而不是像我预期的那样抛出异常。

我现在不确定最安全的路线，所以我有几个问题：

• 我可以安全地假设 -1 是唯一的吗？ 当流关闭时返回？
• 有没有办法重新创建IO 当发生异常时 连接被强行断开？
• 我是否应该发送一个数据包来告诉我的 InputStream 它应该关闭，而不是前面的两种方法？

谢谢！

Answer 1

-1 是流结束时的预期行为。请参阅 InputStream.read ()：

从输入流中读取下一个数据字节。值字节以 0 到 255 范围内的 int 返回。如果由于已到达流末尾而没有可用字节，则返回值 -1。此方法将阻塞，直到输入数据可用，检测到流结束，或者抛出异常。

当然，您仍然应该捕获IOException以防止意外事件。

Answer 2

我可以安全地假设 -1 仅在流关闭时返回吗？

是的。

您不应该假设这样的事情。您应该阅读 javadoc 并根据指定 API 的行为方式来实现。特别是如果您希望代码健壮（或如您所说的“安全”）。

话虽如此，这或多或少就是javadoc在本例中所说的内容。 （有人可能会质疑 EOF 和“流已关闭”不一定意味着同一件事......并且通过调用 InputStream.close() 或 Socket.close 来关闭流() 本地 会产生不同的效果，但是，这些都与您的用例没有直接关系。）

有没有办法重新创建强行断开连接时发生的IO异常？

不会。首先，通常不会首先抛出任何异常，因此通常没有什么可以“重新创建”。其次，原始异常中的信息（如果有的话）消失了。

我应该发送一个数据包来告诉我的 InputStream 它应该关闭，而不是前面的两种方法吗？

不。最好的方法是测试 read 调用的结果。无论如何，您都需要对其进行测试，因为您不能假设 read(byte[]) 方法（或其他方法）将返回您实际要求的字节数。

我认为在某些情况下抛出应用程序特定的异常是可以的。

但请记住一般原则，即异常不应用于正常的流量控制。

---

其他答案之一建议创建一个代理 InputStream 来抛出一些异常而不是返回 -1。

海事组织，这是一个坏主意。您最终会得到一个声称是 InputStream 的代理类，但违反了 read 方法的约定。如果代理被传递给需要正确实现的InputStream，这可能会导致麻烦。

其次，InputStream是一个抽象类而不是接口，因此Java的动态代理机制不起作用。 （例如，newProxyInstance 方法需要接口列表，而不是类。）

Answer 3

根据InputStream javadoc，read()返回：

数据的下一个字节，如果到达流末尾，则为 -1。

因此，您可以安全地假设这一点，并且最好使用 API 中指定的内容，而不是尝试重新创建异常，因为引发的异常可能与实现相关。

Answer 4

此外，关闭套接字中的输出流也会关闭套接字本身。

Socket 的 JavaDoc 是这么说的：

公共输出流 getOutputStream()
抛出 IOException 异常

返回此套接字的输出流。

如果此套接字有关联的通道，则结果输出

流委托其所有操作
到频道。如果频道位于
非阻塞模式然后输出
流的写操作将抛出
IllegalBlockingModeException。

关闭返回的OutputStream将关闭关联的套接字。

返回：
    用于将字节写入此套接字的输出流。 
投掷：
    IOException - 如果创建输出流时发生 I/O 错误

或者如果套接字未连接。

不确定这是否是您真正想要做的。

Answer 5

有没有办法重新创建强行断开连接时发生的IO异常？

这个问题我来回答一下。 InputStream只是一个接口。如果您确实希望实现在 EOF 上抛出异常，请提供您自己的小包装器，重写 read() 并在 -1 结果上抛出异常。

最简单（最少编码）的方法是使用动态代理：

InputStream pxy = (InputStream) java.lang.reflect.Proxy.newProxyInstance(
    obj.getClass().getClassLoader(),
    new Class[]{ InputStream.class },
    new ThrowOnEOFProxy(obj));

其中 ThrowOnEOFProxy 将检查方法名称，调用它，如果结果为 -1，则抛出 IOException("EOF")。