java.io.IOException: mark/reset not supported 异常

在 Azure 上传文件的时候遇到了一个下面的异常:

java.io.IOException: mark/reset not supported
at java.base/java.io.InputStream.reset(InputStream.java:655)
at com.azure.storage.common.Utility.lambda$convertStreamToByteBuffer$4(Utility.java:236)
at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:46)
at reactor.core.publisher.Mono.subscribe(Mono.java:4213)

问题解决

当给定的流不支持 mark 和 reset 就会报这个错误。

我们用的代码是:

blobClient.upload(inputStream , inputStream.available());

InputStream 是不支持 mark 和 reset 的。

BufferedInputStream继承于FilterInputStream,提供缓冲输入流功能。

缓冲输入流相对于普通输入流的优势是,它提供了一个缓冲数组,每次调用read方法的时候,它首先尝试从缓冲区里读取数据,若读取失败(缓冲区无可读数据),则选择从物理数据源(例如你指定的文件)读取新数据(这里会尝试尽可能读取多的字节)放入到缓冲区中,最后再将缓冲区中的内容部分或全部返回给用户。

由于从缓冲区里读取数据远比直接从物理数据源(譬如文件)读取速度快。

Azure 使用上面的方法来尽量保障数据能够上传到存储中。

解决方案是用 BufferedInputStream 再把原来的流包装一层。

什么时候会出现这种错误呢,当你获得一个 InputStream 流,这个流是不允许读写头来回移动,也就不允许 mark/reset 机制。

所以上面的代码修改为:

blobClient.upload(new BufferedInputStream(inputStream) , inputStream.available());

然后再重试,你就会看到文件上传上去了。

登录控制台查看上传的文件。