在 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 就会报这个错误。
我们用的代码是:
代码语言:javascript复制blobClient.upload(inputStream , inputStream.available());
InputStream 是不支持 mark 和 reset 的。
BufferedInputStream继承于FilterInputStream,提供缓冲输入流功能。
缓冲输入流相对于普通输入流的优势是,它提供了一个缓冲数组,每次调用read方法的时候,它首先尝试从缓冲区里读取数据,若读取失败(缓冲区无可读数据),则选择从物理数据源(例如你指定的文件)读取新数据(这里会尝试尽可能读取多的字节)放入到缓冲区中,最后再将缓冲区中的内容部分或全部返回给用户。
由于从缓冲区里读取数据远比直接从物理数据源(譬如文件)读取速度快。
Azure 使用上面的方法来尽量保障数据能够上传到存储中。
解决方案是用 BufferedInputStream 再把原来的流包装一层。
什么时候会出现这种错误呢,当你获得一个 InputStream 流,这个流是不允许读写头来回移动,也就不允许 mark/reset 机制。
所以上面的代码修改为:
代码语言:javascript复制blobClient.upload(new BufferedInputStream(inputStream) , inputStream.available());
然后再重试,你就会看到文件上传上去了。
登录控制台查看上传的文件。
https://www.ossez.com/t/java-io-ioexception-mark-reset-not-supported/617/2