S3上传时报错:Data read has a different length than the expected

2024-06-04 00:38

本文主要是介绍S3上传时报错:Data read has a different length than the expected,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

报错信息

使用S3上传文件时,发现存在几类报错。

第一种:Data read has a different length than the expected: dataLength=15932; expectedLength=19241;

这类报错的意思是,在上传时发现,该文件的实际长度和期望长度不一致。

完整的报错堆栈如下:

com.amazonaws.SdkClientException: Data read has a different length than the expected: dataLength=15932; expectedLength=19241; includeSkipped=false; in.getClass()=class com.amazonaws.internal.ResettableInputStream; markedSupported=true; marked=0; resetSinceLastMarked=false; markCount=1; resetCount=0at com.amazonaws.util.LengthCheckInputStream.checkLength(LengthCheckInputStream.java:151)at com.amazonaws.util.LengthCheckInputStream.read(LengthCheckInputStream.java:109)at com.amazonaws.internal.SdkFilterInputStream.read(SdkFilterInputStream.java:82)at com.amazonaws.event.ProgressInputStream.read(ProgressInputStream.java:180)at com.amazonaws.internal.SdkFilterInputStream.read(SdkFilterInputStream.java:82)at com.amazonaws.auth.AwsChunkedEncodingInputStream.setUpNextChunk(AwsChunkedEncodingInputStream.java:306)at com.amazonaws.auth.AwsChunkedEncodingInputStream.read(AwsChunkedEncodingInputStream.java:172)at org.apache.http.entity.InputStreamEntity.writeTo(InputStreamEntity.java:140)at com.amazonaws.http.RepeatableInputStreamRequestEntity.writeTo(RepeatableInputStreamRequestEntity.java:160)at org.apache.http.impl.DefaultBHttpClientConnection.sendRequestEntity(DefaultBHttpClientConnection.java:156)at org.apache.http.impl.conn.CPoolProxy.sendRequestEntity(CPoolProxy.java:160)at org.apache.http.protocol.HttpRequestExecutor.doSendRequest(HttpRequestExecutor.java:238)at com.amazonaws.http.protocol.SdkHttpRequestExecutor.doSendRequest(SdkHttpRequestExecutor.java:63)at org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:123)at org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:272)at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:185)at org.apache.http.impl.client.InternalHttpClient.doExecute$original$mo6pBbRM(InternalHttpClient.java:185)at org.apache.http.impl.client.InternalHttpClient.doExecute$original$mo6pBbRM$accessor$0Mzlaxvy(InternalHttpClient.java)at org.apache.http.impl.client.InternalHttpClient$auxiliary$3bqvKzTe.call(Unknown Source)at org.apache.skywalking.apm.agent.core.plugin.interceptor.enhance.InstMethodsInter.intercept(InstMethodsInter.java:95)at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java)at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:56)at com.amazonaws.http.apache.client.impl.SdkHttpClient.execute(SdkHttpClient.java:72)at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1258)at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1074)at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:745)at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:719)at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:701)at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:669)at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:651)at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:515)at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:4443)at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:4390)at com.amazonaws.services.s3.AmazonS3Client.putObject(AmazonS3Client.java:1774)at com.amazonaws.services.s3.AmazonS3Client.putObject(AmazonS3Client.java:1628)

第二种:Unable to calculate MD5 hash: /tmp/78c20e3adeb1202ade4ceb002cf4bd9e.png (No such file or directory)

这类报错的意思是,s3在上传文件时,会对文件做MD5的校验。在这个过程中发现指定的文件不存在。

这个堆栈信息比较少:

com.amazonaws.SdkClientException: Unable to calculate MD5 hash: /tmp/78c20e3adeb1202ade4ceb002cf4bd9e.png (No such file or directory)at com.amazonaws.services.s3.AmazonS3Client.putObject(AmazonS3Client.java:1675)at com.amazonaws.services.s3.AmazonS3Client.putObject(AmazonS3Client.java:1628)

原因推测

于是推测,第一种报错应该是因为s3在上传文件时,文件发生了变化导致的。而且可以看到,报错中基本都是expectedLength的长度大于dataLength的长度。那会不会是在上传的时候,这个文件被修改或者重新写入了?所以在重新写入的过程中,文件是不完整的,因此长度不一致。

代码排查

于是排查了一下代码,发现这部分上传的逻辑大概是这样的:

  1. 用时间戳拼接文件名,生成md5值。把这个值当做s3的key(就叫md5key吧)。
  2. 直接返回md5key,保存入库。之后通过线程池异步做上传逻辑
    1. 获取业务传入进来的附件链接,将文件存储到本地服务器,文件名是md5key.jpg。
    2. 调用s3的服务,将md5key.jpg进行上传。
    3. 删除服务器上的md5key.jpg。

问题就出现在这里!

  1. 如果业务方传入多个一样的附件链接(链接A、链接A、链接A),那么在处理的过程中,如果都是在同一毫秒去生成md5key,那是不是这三个链接的md5key都是一样的呢?
  2. 通过线程池去处理这三个文件时,线程1写入文件到md5key.jpg,开始上传。而此时线程2也开始写入文件到md5key.jpg,这时线程1的上传逻辑会发现,文件长度不一致,所以上传失败。
  3. 而当线程2写入md5key.jpg并上传完成后,线程3也开始写入。当线程3写入完成,准备上传时,这时凑巧线程2上传完成,并删除了md5key.jpg,那么线程3就会发现文件不见了,所以报出第二个错误,文件不存在。

排查了异常结果,发现果然是这个原因。并发场景,要考虑的东西还是很多的啊。

结论

  1. Data read has a different length than the expected这个报错,很有可能是文件准备上传时,被另一个写入线程覆盖了。可以按照这个思路去排查问题。
  2. No such file or directory这个报错,那就是如他所说,找不到文件。所以想想为啥文件没了呢?看看程序里有没有删除文件的逻辑呢?

这篇关于S3上传时报错:Data read has a different length than the expected的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1028573

相关文章

Python使用FastAPI实现大文件分片上传与断点续传功能

《Python使用FastAPI实现大文件分片上传与断点续传功能》大文件直传常遇到超时、网络抖动失败、失败后只能重传的问题,分片上传+断点续传可以把大文件拆成若干小块逐个上传,并在中断后从已完成分片继... 目录一、接口设计二、服务端实现(FastAPI)2.1 运行环境2.2 目录结构建议2.3 serv

Python一次性将指定版本所有包上传PyPI镜像解决方案

《Python一次性将指定版本所有包上传PyPI镜像解决方案》本文主要介绍了一个安全、完整、可离线部署的解决方案,用于一次性准备指定Python版本的所有包,然后导出到内网环境,感兴趣的小伙伴可以跟随... 目录为什么需要这个方案完整解决方案1. 项目目录结构2. 创建智能下载脚本3. 创建包清单生成脚本4

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot?二、环境准备与部署2.1 安装 RustF

SpringBoot实现不同接口指定上传文件大小的具体步骤

《SpringBoot实现不同接口指定上传文件大小的具体步骤》:本文主要介绍在SpringBoot中通过自定义注解、AOP拦截和配置文件实现不同接口上传文件大小限制的方法,强调需设置全局阈值远大于... 目录一  springboot实现不同接口指定文件大小1.1 思路说明1.2 工程启动说明二 具体实施2

Spring Boot 结合 WxJava 实现文章上传微信公众号草稿箱与群发

《SpringBoot结合WxJava实现文章上传微信公众号草稿箱与群发》本文将详细介绍如何使用SpringBoot框架结合WxJava开发工具包,实现文章上传到微信公众号草稿箱以及群发功能,... 目录一、项目环境准备1.1 开发环境1.2 微信公众号准备二、Spring Boot 项目搭建2.1 创建

MySQL中的LENGTH()函数用法详解与实例分析

《MySQL中的LENGTH()函数用法详解与实例分析》MySQLLENGTH()函数用于计算字符串的字节长度,区别于CHAR_LENGTH()的字符长度,适用于多字节字符集(如UTF-8)的数据验证... 目录1. LENGTH()函数的基本语法2. LENGTH()函数的返回值2.1 示例1:计算字符串

如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socket read timed out的问题

《如何解决Druid线程池Cause:java.sql.SQLRecoverableException:IO错误:Socketreadtimedout的问题》:本文主要介绍解决Druid线程... 目录异常信息触发场景找到版本发布更新的说明从版本更新信息可以看到该默认逻辑已经去除总结异常信息触发场景复

解决mysql插入数据锁等待超时报错:Lock wait timeout exceeded;try restarting transaction

《解决mysql插入数据锁等待超时报错:Lockwaittimeoutexceeded;tryrestartingtransaction》:本文主要介绍解决mysql插入数据锁等待超时报... 目录报错信息解决办法1、数据库中执行如下sql2、再到 INNODB_TRX 事务表中查看总结报错信息Lock

GitLab文件的上传与下载方式

《GitLab文件的上传与下载方式》:本文主要介绍GitLab文件的上传与下载方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录GitLab 项目拉取到本地GitLab 项目上传方法方法 1:本地项目未初始化Git方法 2:本地项目已初始化GitGitLab 上

IDEA下"File is read-only"可能原因分析及"找不到或无法加载主类"的问题

《IDEA下Fileisread-only可能原因分析及找不到或无法加载主类的问题》:本文主要介绍IDEA下Fileisread-only可能原因分析及找不到或无法加载主类的问题,具有很好的参... 目录1.File is read-only”可能原因2.“找不到或无法加载主类”问题的解决总结1.File