Java 8 FilterOutputStream 异常

Question

这是对 Java 8 中的 FilterOutputStream.close() 方法的更改，这给我们带来了一些问题。 (参见 http://hg.openjdk.java.net/jdk8/jdk8/jdk/rev/759aa847dcaf)

在以前的 Java 版本中，以下代码可以正常运行而不会引发异常。但是，在 Java 8 下，当 try-with-resources 机制关闭流时，我们总是会遇到异常。

try( InputStream bis = new BufferedInputStream( inputStream );
     OutputStream outStream = payloadData.setBinaryStream( 0 );
     BufferedOutputStream bos = new BufferedOutputStream( outStream );
     DeflaterOutputStream deflaterStream = new DeflaterOutputStream(
         bos, new Deflater( 3 ) ) )
{
    fileSize = IOUtil.copy( bis, deflaterStream );
}

try-with-resources 机制将首先调用 deflaterStream 上的 close()。由于 deflaterStream 包装了 bos，而 bos 包装了 outStream，deflaterStream.close() 将调用 bos.close( ) 将调用 outStream.close() 关闭数据库的基础流。

try-with-resources 机制接下来将在 bos 上调用 close()。由于 bos 扩展了 FilterOutputStream，因此 flush() 将首先在 outStream 上被调用。然而，由于 outStream 已经关闭，outStream.flush() 抛出异常:java.sql.SQLException: Closed LOB

caused by: java.io.IOException: Closed LOB
     at oracle.jdbc.driver.OracleBlobOutputStream.ensureOpen(OracleBlobOutputStream.java:265)
     at oracle.jdbc.driver.OracleBlobOutputStream.flush(OracleBlobOutputStream.java:167)
     at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:141)
     at java.io.FilterOutputStream.close(FilterOutputStream.java:158)
     at com.blah.uploadFile(CustomerUploadFacade.java:162)
     ... 38 more
Caused by: java.sql.SQLException: Closed LOB
     at oracle.jdbc.driver.OracleBlobOutputStream.ensureOpen(OracleBlobOutputStream.java:257)
     ... 42 more

有没有其他人遇到过这个问题？如果是这样，您是如何解决的？我们使用 try-with-resources 的方式有问题吗？

Answer 1

这是 FilterOutputStream 中的错误。这实现了 Closable .此接口(interface)的契约(Contract)规定:

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

所以第二次调用 .close() 应该没有效果，但在这种情况下它调用 flush() 会抛出异常。

FilterOutputStream 卡在继承层次结构中，因此不容易在问题点应用修复。

未能在 try block 中将某些流声明为局部变量将导致 FindBugs 和 Eclipse 等工具将代码标记为资源使用。稍后查看此代码的勤奋开发人员可能会想到同样的事情。

您可以创建一个类 CloseOnceBufferedOutputStream 来扩展 BufferedOutputStream。它将有一个 boolean 来记住它是否已经关闭以便它可以满足契约(Contract)。覆盖 close() 方法以检查流是否已关闭。如果是这样，只需返回即可。

如果 Oracle 修复了底层错误，您的新类将毫无用处，但代码将继续工作。